feat: wait for seq to be available

CumpsD · Jun 30, 2020 · c2f2888 · c2f2888
1 parent 1e7b780
commit c2f2888
Show file tree

Hide file tree

Showing 4 changed files with 221 additions and 3 deletions.
diff --git a/src/FunctionalLiving.Api/Infrastructure/WaitFor.cs b/src/FunctionalLiving.Api/Infrastructure/WaitFor.cs
@@ -0,0 +1,72 @@
+namespace FunctionalLiving.Api.Infrastructure
+{
+    using System;
+    using System.Collections.Generic;
+    using System.Linq;
+    using System.Net.Http;
+    using System.Threading;
+    using System.Threading.Tasks;
+    using Microsoft.Extensions.Configuration;
+
+    internal class WriteTo
+    {
+        public string Name { get; set; }
+
+        public Dictionary<string, string> Args { get; set; }
+
+        public WriteTo()
+        {
+            Args = new Dictionary<string, string>(StringComparer.InvariantCultureIgnoreCase);
+        }
+    }
+
+    internal static class WaitFor
+    {
+        public static async Task SeqToBecomeAvailable(
+            IConfiguration configuration,
+            CancellationToken token = default)
+        {
+            var writeTos = configuration
+                .GetSection("Serilog:WriteTo")
+                .Get<WriteTo[]>();
+
+            var seq = writeTos.SingleOrDefault(to => "Seq".Equals(to.Name, StringComparison.InvariantCultureIgnoreCase));
+            if (seq == null)
+                return;
+
+            using (var client = new HttpClient { BaseAddress = new Uri(seq.Args["ServerUrl"]) })
+            {
+                var exit = false;
+                while (!exit)
+                {
+                    Console.WriteLine("Waiting for Seq to become available...");
+
+                    try
+                    {
+                        using (var response = await client.GetAsync("/api", token))
+                        {
+                            if (!response.IsSuccessStatusCode)
+                            {
+                                await Task.Delay(TimeSpan.FromSeconds(1), token);
+                            }
+                            else
+                            {
+                                exit = true;
+                            }
+                        }
+                    }
+                    catch (Exception exception)
+                    {
+                        Console.WriteLine(
+                            "Observed an exception while waiting for Seq to become available. Exception: {0}",
+                            exception);
+
+                        await Task.Delay(TimeSpan.FromSeconds(1), token);
+                    }
+                }
+            }
+
+            Console.WriteLine("Seq became available.");
+        }
+    }
+}
diff --git a/src/FunctionalLiving.Knx.Listener/Infrastructure/WaitFor.cs b/src/FunctionalLiving.Knx.Listener/Infrastructure/WaitFor.cs
@@ -0,0 +1,72 @@
+namespace FunctionalLiving.Knx.Listener.Infrastructure
+{
+    using System;
+    using System.Collections.Generic;
+    using System.Linq;
+    using System.Net.Http;
+    using System.Threading;
+    using System.Threading.Tasks;
+    using Microsoft.Extensions.Configuration;
+
+    internal class WriteTo
+    {
+        public string Name { get; set; }
+
+        public Dictionary<string, string> Args { get; set; }
+
+        public WriteTo()
+        {
+            Args = new Dictionary<string, string>(StringComparer.InvariantCultureIgnoreCase);
+        }
+    }
+
+    internal static class WaitFor
+    {
+        public static async Task SeqToBecomeAvailable(
+            IConfiguration configuration,
+            CancellationToken token = default)
+        {
+            var writeTos = configuration
+                .GetSection("Serilog:WriteTo")
+                .Get<WriteTo[]>();
+
+            var seq = writeTos.SingleOrDefault(to => "Seq".Equals(to.Name, StringComparison.InvariantCultureIgnoreCase));
+            if (seq == null)
+                return;
+
+            using (var client = new HttpClient { BaseAddress = new Uri(seq.Args["ServerUrl"]) })
+            {
+                var exit = false;
+                while (!exit)
+                {
+                    Console.WriteLine("Waiting for Seq to become available...");
+
+                    try
+                    {
+                        using (var response = await client.GetAsync("/api", token))
+                        {
+                            if (!response.IsSuccessStatusCode)
+                            {
+                                await Task.Delay(TimeSpan.FromSeconds(1), token);
+                            }
+                            else
+                            {
+                                exit = true;
+                            }
+                        }
+                    }
+                    catch (Exception exception)
+                    {
+                        Console.WriteLine(
+                            "Observed an exception while waiting for Seq to become available. Exception: {0}",
+                            exception);
+
+                        await Task.Delay(TimeSpan.FromSeconds(1), token);
+                    }
+                }
+            }
+
+            Console.WriteLine("Seq became available.");
+        }
+    }
+}
diff --git a/src/FunctionalLiving.Knx.Listener/Program.cs b/src/FunctionalLiving.Knx.Listener/Program.cs
@@ -1,12 +1,12 @@
 namespace FunctionalLiving.Knx.Listener
 {
     using System;
-    using System.Diagnostics;
     using System.IO;
     using System.Threading;
     using System.Threading.Tasks;
     using Autofac;
     using Autofac.Extensions.DependencyInjection;
+    using FunctionalLiving.Knx.Listener.Infrastructure;
     using Infrastructure.Modules;
     using Microsoft.Extensions.Configuration;
     using Microsoft.Extensions.DependencyInjection;
@@ -51,10 +51,12 @@ public static async Task Main(string[] args)
             var openTelemetry = container.GetService<TracerFactoryBase>();
             var logger = container.GetRequiredService<ILogger<Program>>();
 
-            logger.LogInformation("Starting FunctionalLiving.Knx.Listener");
-
             try
             {
+                await WaitFor.SeqToBecomeAvailable(configuration).ConfigureAwait(false);
+
+                logger.LogInformation("Starting FunctionalLiving.Knx.Listener");
+
                 var runner = container.GetRequiredService<KnxListener>();
 
                 runner.Start();

diff --git a/src/FunctionalLiving.Knx.Sender/Infrastructure/WaitFor.cs b/src/FunctionalLiving.Knx.Sender/Infrastructure/WaitFor.cs
@@ -0,0 +1,72 @@
+namespace FunctionalLiving.Knx.Sender.Infrastructure
+{
+    using System;
+    using System.Collections.Generic;
+    using System.Linq;
+    using System.Net.Http;
+    using System.Threading;
+    using System.Threading.Tasks;
+    using Microsoft.Extensions.Configuration;
+
+    internal class WriteTo
+    {
+        public string Name { get; set; }
+
+        public Dictionary<string, string> Args { get; set; }
+
+        public WriteTo()
+        {
+            Args = new Dictionary<string, string>(StringComparer.InvariantCultureIgnoreCase);
+        }
+    }
+
+    internal static class WaitFor
+    {
+        public static async Task SeqToBecomeAvailable(
+            IConfiguration configuration,
+            CancellationToken token = default)
+        {
+            var writeTos = configuration
+                .GetSection("Serilog:WriteTo")
+                .Get<WriteTo[]>();
+
+            var seq = writeTos.SingleOrDefault(to => "Seq".Equals(to.Name, StringComparison.InvariantCultureIgnoreCase));
+            if (seq == null)
+                return;
+
+            using (var client = new HttpClient { BaseAddress = new Uri(seq.Args["ServerUrl"]) })
+            {
+                var exit = false;
+                while (!exit)
+                {
+                    Console.WriteLine("Waiting for Seq to become available...");
+
+                    try
+                    {
+                        using (var response = await client.GetAsync("/api", token))
+                        {
+                            if (!response.IsSuccessStatusCode)
+                            {
+                                await Task.Delay(TimeSpan.FromSeconds(1), token);
+                            }
+                            else
+                            {
+                                exit = true;
+                            }
+                        }
+                    }
+                    catch (Exception exception)
+                    {
+                        Console.WriteLine(
+                            "Observed an exception while waiting for Seq to become available. Exception: {0}",
+                            exception);
+
+                        await Task.Delay(TimeSpan.FromSeconds(1), token);
+                    }
+                }
+            }
+
+            Console.WriteLine("Seq became available.");
+        }
+    }
+}