public async Task PollGroup()

in src/HttpRequestHelper/HttpClientHelper.cs [416:497]
66 lines of code
11 McCabe index (conditional complexity)

        public async Task<GroupPollResponse> PollGroup(UserInput userInputObj, string groupName)
        {
            if (userInputObj.CancellationContext.IsCancellationRequested)
                UtilityFunctions.InitiateCancellation(userInputObj);

            userInputObj.LoggerObj.LogInformation($"Polling group {groupName} for status");

            AuthenticationResult authResult = null;
            HttpResponseMessage response;

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

                string url = Routes.ProtocolScheme + Routes.AzureManagementApiHostname + Routes.ForwardSlash +
                             Routes.SubscriptionPath + Routes.ForwardSlash + userInputObj.Subscription.Key + Routes.ForwardSlash +
                             Routes.ResourceGroupPath + Routes.ForwardSlash + userInputObj.ResourceGroupName.Value + Routes.ForwardSlash +
                             Routes.ProvidersPath + Routes.ForwardSlash + Routes.MigrateProvidersPath + Routes.ForwardSlash +
                             Routes.AssessmentProjectsPath + Routes.ForwardSlash + userInputObj.AssessmentProjectName + Routes.ForwardSlash +
                             Routes.GroupsPath + Routes.ForwardSlash + groupName +
                             Routes.QueryStringQuestionMark +
                             Routes.QueryParameterApiVersion + Routes.QueryStringEquals + Routes.CreateGroupApiVersion;

                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");

                response = await httpClient.GetAsync(baseAddress);

                if (response == null || !response.IsSuccessStatusCode)
                {
                    userInputObj.LoggerObj.LogWarning($"Group {groupName} polling response was not success. Status: {response?.StatusCode} Content: {response?.Content}");
                    if (!HttpUtilities.IsRetryNeeded(response, null))
                        return GroupPollResponse.Error;

                    return GroupPollResponse.NotCompleted;
                }

                string responseContent = await response.Content.ReadAsStringAsync();
                GroupInformationJSON groupInformationObj = JsonConvert.DeserializeObject<GroupInformationJSON>(responseContent);

                if (groupInformationObj.Properties.GroupStatus.Equals("Completed"))
                {
                    userInputObj.LoggerObj.LogInformation($"Group {groupName} completed");
                    return GroupPollResponse.Completed;
                }
                else if (groupInformationObj.Properties.GroupStatus.Equals("Invalid"))
                {
                    userInputObj.LoggerObj.LogWarning($"Group {groupName} is in invalid state, corresponding assessments will be skipped");
                    return GroupPollResponse.Invalid;
                }

                userInputObj.LoggerObj.LogInformation($"Group {groupName} status is {groupInformationObj.Properties.GroupStatus}");
                return GroupPollResponse.NotCompleted;
            }
            catch (Exception exPollGroup)
            {
                userInputObj.LoggerObj.LogWarning($"Group {groupName} polling error: {exPollGroup.Message}");

                if (!HttpUtilities.IsRetryNeeded(null, exPollGroup))
                    return GroupPollResponse.Error;
            }

            return GroupPollResponse.NotCompleted;
        }