public async Task Execute()

in src/ApiForFhirMigrationTool.Function/SurfaceCheck/SurfaceCheck.cs [37:166]
109 lines of code
10 McCabe index (conditional complexity)

        public async Task<string> Execute(string query)
        {
            var res = new JObject();
            var passResource = new JArray();
            var errorResource = new JArray();

            if (_options.ResourceTypes != null)
            {
                var surfaceCheckResource = new List<string>(_options.ResourceTypes);
                var baseUri = _options.SourceUri;
                var desbaseUri = _options.DestinationUri;
                string sourceFhirEndpoint = _options.SourceHttpClient;
                string destinationFhirEndpoint = _options.DestinationHttpClient;
                foreach (var item in surfaceCheckResource)
                {
                    _logger?.LogInformation($"Surface Check Function start for resource :{item}");
                    try
                    {
                        var request = new HttpRequestMessage
                        {
                            Method = HttpMethod.Get,
                            RequestUri = new Uri(baseUri, string.Format("{0}/{1}", item, query)),
                        };
                        HttpResponseMessage srcTask = await _fhirClient.Send(request, baseUri, sourceFhirEndpoint);

                        var objResponse = JObject.Parse(srcTask.Content.ReadAsStringAsync().Result);
                        JToken? srctotalCount = objResponse["total"];

                        // Destination count
                        var desrequest = new HttpRequestMessage
                        {
                            Method = HttpMethod.Get,
                            RequestUri = new Uri(desbaseUri, string.Format("{0}/{1}", item, query)),
                        };

                        HttpResponseMessage desTask = await _fhirClient.Send(desrequest, desbaseUri, destinationFhirEndpoint);

                        var desobjResponse = JObject.Parse(desTask.Content.ReadAsStringAsync().Result);
                        JToken? destotalCount = desobjResponse["total"];

                        // Comparing Count
                        if (destotalCount != null)
                        {
                            string srcTotal = string.Empty;
                            if (srctotalCount != null)
                            {
                                srcTotal = srctotalCount.ToString();
                            }

                            string destTotal = destotalCount.ToString();
                            if (destotalCount.Equals(srctotalCount))
                            {
                                var inputFormat = new JObject
                                {
                                    { "Resource", item },
                                    { "SourceCount", srctotalCount },
                                    { "DestinationCount", destotalCount },
                                };

                                passResource.Add(inputFormat);
                            }
                            else
                            {
                                var errorFormat = new JObject
                                {
                                    { "Resource", item },
                                    { "SourceCount", srctotalCount },
                                    { "DestinationCount", destotalCount },
                                };
                                errorResource.Add(errorFormat);
                            }

                            _logger?.LogInformation("Creating table clients");
                            TableClient chunktableClient = _azureTableClientFactory.Create(_options.ChunkTableName);
                            TableClient exportTableClient = _azureTableClientFactory.Create(_options.ExportTableName);
                            _logger?.LogInformation("Table clients created successfully.");


                            TableEntity qEntity = _azureTableMetadataStore.GetEntity(chunktableClient, _options.PartitionKey, _options.RowKey);
                            if (qEntity["SurfaceJobId"] != null)
                            {
                                int jobId = (int)qEntity["SurfaceJobId"];
                                string rowKey = _options.SurfaceRowKey + jobId++;

                                var tableEntity = new TableEntity(_options.PartitionKey, rowKey)
                                {
                                     { "Resource", item },
                                    { "SourceCount", srcTotal },
                                    { "DestinationCount", destTotal },
                                    { "Result", destotalCount.Equals(srctotalCount) ? "Pass" : "Fail" },
                                };
                                _logger?.LogInformation("Starting update of the export table.");
                                _azureTableMetadataStore.AddEntity(exportTableClient, tableEntity);
                                _logger?.LogInformation("Completed update of the export table.");

                                TableEntity qEntitynew = _azureTableMetadataStore.GetEntity(chunktableClient, _options.PartitionKey, _options.RowKey);

                                qEntitynew["SurfaceJobId"] = jobId++;

                                _logger?.LogInformation("Starting update of the chunk table.");
                                _azureTableMetadataStore.UpdateEntity(chunktableClient, qEntitynew);
                                _logger?.LogInformation("Completed update of the chunk table.");

                                _logger?.LogInformation("Updating logs in Application Insights.");

                                _telemetryClient.TrackEvent(
                                "SurfaceCheck",
                                new Dictionary<string, string>()
                                {
                                    { "Resource", item },
                                    { "SourceCount", srcTotal },
                                    { "DestinationCount", destTotal },
                                    { "Result", destotalCount.Equals(srctotalCount) ? "Pass" : "Fail" },
                                });
                            }
                        }
                    }
                    catch
                    {
                        throw;
                    }
                }
            }

            res.Add("ResourceMatched", passResource);
            res.Add("ResourceNotMatched", errorResource);
            var importRequestJson = res.ToString(Formatting.None);

            return importRequestJson;
        }