public async Task ExecuteLogAnalyticsQuery()

in wvd-templates/diagnostics-sample/src/MSFT.WVD.Diagnostics.Common/Services/LogAnalyticsService.cs [79:143]
59 lines of code
13 McCabe index (conditional complexity)

        public async Task<VMPerformance> ExecuteLogAnalyticsQuery(string refreshToken, string hostName, XmlDocument xmlDocument)
        {
            var loganalyticUrl = Configuration.GetSection("configurations").GetSection("LogAnalytic_URL").Value;
            var accesstoken = _commonService.GetAccessTokenLogAnalytic(refreshToken);
            //VMPerformance vMPerformance = new VMPerformance();
            List<Counter> counters = new List<Counter>();
            var body = new JObject();
            JArray jArray = PrepareBatchQueryRequest(hostName, out counters, xmlDocument);
            if (jArray == null || jArray.Count == 0)
            {
                return new VMPerformance()
                {
                    Message = "Invalid Queries or Queries are not availble in metrics file. Please ckeck 'metrics.xml' file. "
                };
            }
            else
            {
                body.Add("requests", jArray);
                // var body = new JObject();
                //  body = PrepareBatchQueryRequest(hostName, out counters, xmlDocument);
                var url = $"{loganalyticUrl}/v1/$batch";
                using (var client = new HttpClient())
                {
                    client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", accesstoken);
                    HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Post, url);
                    var content = new StringContent(JsonConvert.SerializeObject(body), Encoding.UTF8, "application/json");
                    request.Content = content;
                    HttpResponseMessage response = await client.SendAsync(request);
                    if (response.StatusCode == System.Net.HttpStatusCode.OK)
                    {
                        var data = response.Content.ReadAsStringAsync().Result;
                        foreach (var item in JObject.Parse(data)["responses"])
                        {
                            if (item["status"].ToString() == "200")
                            {
                                if (item["body"]["tables"] != null && item["body"]["tables"][0]["rows"] != null && item["body"]["tables"][0]["rows"].ToString() != "[]" && item["body"]["tables"][0]["rows"].Count() > 0)
                                {
                                    decimal avg = item["body"]["tables"][0]["rows"][0][0] != null ? (decimal)item["body"]["tables"][0]["rows"][0][0] : 0;
                                    decimal value = item["body"]["tables"][0]["rows"][0][1] != null ? (decimal)item["body"]["tables"][0]["rows"][0][1] : 0;
                                    var status = item["body"]["tables"][0]["rows"][0][3].ToString();
                                    counters.Where(x => x.id == (int)item["id"])
                                    .Select(x => { x.avg = avg; x.Value = value; x.Status = status; return x; })
                                    .ToList();
                                }
                            }
                        }
                    }
                    else
                    {
                        return new VMPerformance()
                        {
                            Message = response.StatusCode+" : "+ response.Content.ReadAsStringAsync().Result
                    };
                    }
                    
                   
                }
                return new VMPerformance()
                {
                    CurrentStateCounters = counters,
                    isHealthy = counters.Where(x => x.Status == "2").ToList().Count > 1 ? false : true
                };
            }

        }