private async Task GetHttpResponse()

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;
        }