in src/HttpRequestHelper/HttpClientHelper.cs [120:189]
private async Task<HttpResponseMessage> GetHttpResponse(string Url, UserInput userInputObj, bool isPost = false)
{
if (userInputObj.CancellationContext.IsCancellationRequested)
UtilityFunctions.InitiateCancellation(userInputObj);
NumberOfTries++;
AuthenticationResult authResult = null;
HttpResponseMessage response;
bool isException = false;
try
{
authResult = await AzureAuthenticationHandler.RetrieveAuthenticationToken();
}
catch (Exception exCacheTokenRetrieval)
{
throw new Exception($"Cached token retrieval failed: {exCacheTokenRetrieval.Message} Please re-login");
}
string workflow = userInputObj.WorkflowObj.IsExpressWorkflow ? "express" : "custom";
try
{
HttpClient httpClient = new HttpClient()
{
Timeout = TimeSpan.FromSeconds(60),
};
Uri baseAddress = new Uri(Url);
string clientRequestId = Guid.NewGuid().ToString();
httpClient.DefaultRequestHeaders.Add("Authorization", "Bearer " + authResult.AccessToken);
httpClient.DefaultRequestHeaders.Add("Accept", "application/json");
httpClient.DefaultRequestHeaders.Add("x-ms-client-request-id", clientRequestId + "-" + workflow + "-azmigexp");
if (isPost)
{
string blankContent = "";
byte[] buffer = Encoding.UTF8.GetBytes(blankContent);
ByteArrayContent byteContent = new ByteArrayContent(buffer);
byteContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");
response = await httpClient.PostAsync(baseAddress, byteContent);
}
else
response = await httpClient.GetAsync(baseAddress);
}
catch (Exception exGeneralGetHttpRequest)
{
isException = true;
if (NumberOfTries < HttpUtilities.MaxInformationDataRetries && HttpUtilities.IsRetryNeeded(null, exGeneralGetHttpRequest))
{
userInputObj.LoggerObj.LogWarning($"HTTP GET request to url: {Url} error: {exGeneralGetHttpRequest.Message} Will try again after 1 minute");
Thread.Sleep(60000);
response = await GetHttpResponse(Url, userInputObj);
}
else
throw;
}
if (!isException)
{
if((response == null || !response.IsSuccessStatusCode) && HttpUtilities.IsRetryNeeded(response, null) && NumberOfTries < HttpUtilities.MaxInformationDataRetries)
{
userInputObj.LoggerObj.LogWarning($"HTTP GET request to url {Url} failed: {response.StatusCode}: {response.Content} Will try again after 1 minute");
Thread.Sleep(60000);
response = await GetHttpResponse(Url, userInputObj);
}
}
return response;
}