Add override SendAsync with HttpResponseMessage (#22)

SendAsync override for ConsulMetricsHttpClientWrapper.cs --------- Co-authored-by: Швед Дмитрий <[email protected]>
atidev · Nov 21, 2023 · 923bd19 · 923bd19
1 parent 294c363
commit 923bd19
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 1 deletion.
diff --git a/ATI.Services.Consul/ATI.Services.Consul.csproj b/ATI.Services.Consul/ATI.Services.Consul.csproj
@@ -18,7 +18,7 @@
   </PropertyGroup>
   <ItemGroup>
     <FrameworkReference Include="Microsoft.AspNetCore.App" />
-    <PackageReference Include="atisu.services.common" Version="12.3.0" />
+    <PackageReference Include="atisu.services.common" Version="13.2.1" />
     <PackageReference Include="Consul" Version="1.6.10.9" />
   </ItemGroup>
 </Project>
diff --git a/ATI.Services.Consul/ConsulMetricsHttpClientWrapper.cs b/ATI.Services.Consul/ConsulMetricsHttpClientWrapper.cs
@@ -243,6 +243,37 @@ public Task<OperationResult<string>> PatchAsync(
 
         #endregion
 
+        #region Send
+
+        public async Task<OperationResult<HttpResponseMessage<TResponse>>> SendAsync<TBody, TResponse>(
+            HttpMethod methodName,
+            string url,
+            TBody body,
+            string metricName,
+            Dictionary<string, string> headers = null,
+            string urlTemplate = null,
+            string[] additionalLabels = null)
+        {
+            using var _ =
+                _metricsTracingFactory.CreateLoggingMetricsTimer(metricName,
+                                                                 $"{methodName}:{urlTemplate ?? url}",
+                                                                 additionalLabels);
+            {
+                try
+                {
+                    var serviceAddress = await _serviceAddress.ToHttpAsync();
+                    return await _clientWrapper.SendAsync<TBody, TResponse>(new Uri(new Uri(serviceAddress),url), metricName, body, headers, methodName);
+                }
+                catch (Exception e)
+                {
+                    _logger.LogWithObject(_serviceOptions.LogLevelOverride(LogLevel.Error), e);
+                    return new(ActionStatus.InternalServerError);
+                }
+            }
+        }
+
+        #endregion
+
         private async Task<OperationResult<T>> SendAsync<T>(string url,
             string urlTemplate,
             string metricName,