feat: add httpclient to api

Author: CumpsD

src/FunctionalLiving.Api/Infrastructure/Modules/HttpModule.cs

@@ -0,0 +1,51 @@
+namespace FunctionalLiving.Api.Infrastructure.Modules
+{
+    using System;
+    using System.Net.Http;
+    using Autofac;
+    using Microsoft.Extensions.Configuration;
+    using Microsoft.Extensions.DependencyInjection;
+    using Microsoft.Extensions.Logging;
+    using Microsoft.Net.Http.Headers;
+    using Polly;
+
+    public class HttpModule : Module
+    {
+        public static string HttpClientName = "KnxSender";
+
+        public HttpModule(
+            IConfiguration configuration,
+            IServiceCollection services,
+            ILoggerFactory loggerFactory)
+        {
+            var logger = loggerFactory.CreateLogger<HttpModule>();
+            var retryCount = 5;
+            var lifeTimeInMinutes = 20;
+
+            // https://github.com/App-vNext/Polly/wiki/Polly-and-HttpClientFactory
+            services
+                .AddHttpClient(HttpClientName, client =>
+                {
+                    client.BaseAddress = configuration.GetValue<Uri>("KnxSender:Endpoint");
+                    client.DefaultRequestHeaders.Add(HeaderNames.UserAgent, "FunctionalLiving.Api");
+                })
+
+                .SetHandlerLifetime(TimeSpan.FromMinutes(lifeTimeInMinutes))
+
+                .ConfigurePrimaryHttpMessageHandler(c =>
+                        new HttpClientHandler())
+
+                // HttpRequestException, HTTP 5XX, and HTTP 408
+                .AddTransientHttpErrorPolicy(policyBuilder => policyBuilder
+                    .WaitAndRetryAsync(
+                        retryCount,
+                        retryAttempt =>
+                        {
+                            var value = Math.Pow(2, retryAttempt) / 4;
+                            var randomValue = new Random().Next((int)value * 3, (int)value * 5);
+                            logger?.LogInformation("Retrying after {Seconds} seconds...", randomValue);
+                            return TimeSpan.FromSeconds(randomValue);
+                        }));
+        }
+    }
+}

src/FunctionalLiving.Api/appsettings.json

@@ -4,6 +4,10 @@
     "http://localhost:5000"
   ],
 
+  "KnxSender": {
+    "Endpoint": "http://localhost:9001"
+  },
+
   "Serilog": {
     "MinimumLevel": {
       "Default": "Information",

src/FunctionalLiving.Api/paket.references

@@ -1,6 +1,9 @@
 Be.Vlaanderen.Basisregisters.Api
 Be.Vlaanderen.Basisregisters.EventHandling.Autofac
 
+Microsoft.Extensions.Http
+Microsoft.Extensions.Http.Polly
+
 Serilog.Sinks.Seq
 
 SourceLink.Embed.AllSourceFiles

src/FunctionalLiving.Knx.Listener/Infrastructure/Modules/HttpModule.cs

@@ -19,6 +19,8 @@ public HttpModule(
             ILoggerFactory loggerFactory)
         {
             var logger = loggerFactory.CreateLogger<HttpModule>();
+            var retryCount = 5;
+            var lifeTimeInMinutes = 20;
 
             // https://github.com/App-vNext/Polly/wiki/Polly-and-HttpClientFactory
             services
@@ -28,13 +30,15 @@ public HttpModule(
                     client.DefaultRequestHeaders.Add(HeaderNames.UserAgent, "FunctionalLiving.Knx.Listener");
                 })
 
+                .SetHandlerLifetime(TimeSpan.FromMinutes(lifeTimeInMinutes))
+
                 .ConfigurePrimaryHttpMessageHandler(c =>
                         new HttpClientHandler())
 
                 // HttpRequestException, HTTP 5XX, and HTTP 408
                 .AddTransientHttpErrorPolicy(policyBuilder => policyBuilder
                     .WaitAndRetryAsync(
-                        5,
+                        retryCount,
                         retryAttempt =>
                         {
                             var value = Math.Pow(2, retryAttempt) / 4;