Skip to content
This repository has been archived by the owner on Apr 12, 2023. It is now read-only.

処理番号登録時のMock動作を変更 #1093

Merged
1 commit merged into from
Jul 28, 2022
Merged

処理番号登録時のMock動作を変更 #1093

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
188 changes: 24 additions & 164 deletions Covid19Radar/Covid19Radar/Services/HttpDataServiceMock.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,137 +3,51 @@
* file, You can obtain one at https://mozilla.org/MPL/2.0/. */

using Covid19Radar.Model;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Net;
using System.Threading;
using System.Threading.Tasks;
using System.Linq;
using System.Net.Http;
using System.Text.RegularExpressions;
using Covid19Radar.Services.Logs;

namespace Covid19Radar.Services
{
class HttpDataServiceMock : IHttpDataService
public class HttpDataServiceMock : IHttpDataService
{
private readonly HttpClient downloadClient;
private readonly MockCommonUtils mockCommonUtils = new MockCommonUtils();
private readonly ILoggerService _loggerSerivce;

public HttpDataServiceMock(IHttpClientService httpClientService)
public HttpDataServiceMock(ILoggerService loggerService)
{
downloadClient = httpClientService.Create();
_loggerSerivce = loggerService;
}

// copy from ./HttpDataService.cs
private async Task<string> GetCdnAsync(string url, CancellationToken cancellationToken)
public Task<HttpStatusCode> PostRegisterUserAsync()
{
HttpResponseMessage result = await downloadClient.GetAsync(url, cancellationToken);
await result.Content.ReadAsStringAsync();

if (result.StatusCode == System.Net.HttpStatusCode.OK)
{
return await result.Content.ReadAsStringAsync();
}
return null;
}

public Task MigrateFromUserData(UserDataModel userData)
{
return Task.CompletedTask;
}

public (string, string) GetCredentials()
{
return ("user-uuid", "secret");
}

public void RemoveCredentials()
{
}

private TemporaryExposureKeyExportFileModel CreateTestData(long created)
{
return new TemporaryExposureKeyExportFileModel()
{
Region = "440",
Url = "testUrl",
Created = created
};
}

private long CalcTimeAddDays(int day)
=> new DateTimeOffset(DateTime.UtcNow.AddDays(day)).ToUnixTimeMilliseconds();

private long CalcMidnightTimeAddDays(int day)
{
DateTime d = DateTime.UtcNow.AddDays(day);
// set 0 hour,1 min,2 sec,3 millisecond for debug
return new DateTimeOffset(new DateTime(d.Year, d.Month, d.Day, 0, 1, 2, 3)).ToUnixTimeMilliseconds();
}

enum PresetTekListType // PresetTekListData for Tek List
{
Nothing = 0, //nothing (default for v1.2.3)
RealTime = 1, // real time
MidnightTime = 2, // last night
// please add "YourDataType = <int>"
}

private List<TemporaryExposureKeyExportFileModel> PresetTekListData(int dataVersion)
{
switch ((PresetTekListType)dataVersion)
return Task.Factory.StartNew(() =>
{
case PresetTekListType.MidnightTime:
return new List<TemporaryExposureKeyExportFileModel> { CreateTestData(CalcMidnightTimeAddDays(-1)), CreateTestData(CalcMidnightTimeAddDays(0)) };
case PresetTekListType.RealTime:
return new List<TemporaryExposureKeyExportFileModel> { CreateTestData(CalcTimeAddDays(-1)), CreateTestData(CalcTimeAddDays(0)) };
case PresetTekListType.Nothing:
default:
return new List<TemporaryExposureKeyExportFileModel>();
}
return HttpStatusCode.OK;
});
}

async Task<HttpStatusCode> IHttpDataService.PostRegisterUserAsync()
public Task<HttpStatusCode> PutSelfExposureKeysAsync(DiagnosisSubmissionParameter request)
{
Debug.WriteLine("HttpDataServiceMock::PostRegisterUserAsync called");
var code = HttpStatusCode.OK;
var result = mockCommonUtils.GetRegisterDataType();
if (result >= 100)
{
code = (HttpStatusCode)result;
}
else
return Task.Factory.StartNew(() =>
{
if (result.Equals(1))
_loggerSerivce.StartMethod();
HttpStatusCode result;
try
{
code = HttpStatusCode.NoContent;
result = request.VerificationPayload switch
{
"99999910" => HttpStatusCode.NoContent,
"99999920" => HttpStatusCode.NotAcceptable,
_ => HttpStatusCode.ServiceUnavailable
};
}
}

return await Task.FromResult(code);
}

Task<HttpStatusCode> IHttpDataService.PutSelfExposureKeysAsync(DiagnosisSubmissionParameter request)
{
var code = HttpStatusCode.OK; // default. for PutSelfExposureKeys NG
var dataType = mockCommonUtils.GetDiagnosisDataType();
if (dataType >= 100) // HttpStatusCode >=100 by RFC2616#section-10
{
code = (HttpStatusCode)dataType;
}
else
{
switch (dataType)
finally
{
case 1:
code = HttpStatusCode.NoContent; // for Successful PutSelfExposureKeys
break;
_loggerSerivce.EndMethod();
}
}

Debug.WriteLine("HttpDataServiceMock::PutSelfExposureKeysAsync called");
return Task.FromResult(code);
return result;
});
}

public Task<ApiResponse<LogStorageSas>> GetLogStorageSas()
Expand All @@ -153,58 +67,4 @@ public Task<ApiResponse<string>> PutEventLog(V1EventLogRequest request)
});
}
}

public class MockCommonUtils
{
public string CdnUrlBase => AppSettings.Instance.CdnUrlBase;
public string ApiUrlBase => AppSettings.Instance.ApiUrlBase;

public bool IsDownloadRequired()
=> Regex.IsMatch(CdnUrlBase, @"^https://.*\..*\..*/$");

public bool IsDirectInput()
=> Regex.IsMatch(CdnUrlBase, @"^(\d+,)+\d+,*$");


private ushort NumberEndofSentence(string url)
{
Match match = Regex.Match(url, @"(?<d>\d+)$");
ushort number = 0;
if (match.Success)
{
number = Convert.ToUInt16(match.Groups["d"].Value);
}
return number;
}
public List<string> GetCreatedTimes()
=> CdnUrlBase.Split(",").ToList();
public ushort GetTekListDataType()
=> NumberEndofSentence(CdnUrlBase);
public string[] GetApiUrlSegment()
{
// "url/api" -> { "url/api", "", "" }
// "url/base/api/register1/diagnosis2" -> { "url/base/api", "/register1", "/diagnosis2" }
// "url/api1/r1/d2" -> { "url/api1", "/r1", "/d2" }
// "url/api1/d2/r1" -> { "url/api1", "/r1", "/d2" }
var url = ApiUrlBase;
var r = new Regex("/r(egister)?[0-9]+");
var d = new Regex("/d(iagnosis)?[0-9]+");
var urlRegister = r.Match(url).Value;
url = r.Replace(url, "");
var urlDiagnosis = d.Match(url).Value;
url = d.Replace(url, "");
var urlApi = url;
return new string[] { urlApi, urlRegister, urlDiagnosis };
}
public ushort GetDiagnosisDataType()
=> NumberEndofSentence(GetApiUrlSegment()[2]);
public ushort GetRegisterDataType()
=> NumberEndofSentence(GetApiUrlSegment()[1]);
public ushort GetApiDataType()
=> NumberEndofSentence(GetApiUrlSegment()[0]);
public bool IsDirectInputApi()
=> Regex.IsMatch(GetApiUrlSegment()[0], @"^(\d+,)+\d+,?$");
public List<string> GetApiStrings()
=> GetApiUrlSegment()[0].Split(",").ToList();
}
}