From 8fdd0f0a249fd186a43a9f46041cfd01f173e935 Mon Sep 17 00:00:00 2001
From: Rune Nielsen <runenielsen@runbox.com>
Date: Thu, 17 Mar 2022 10:33:56 +0100
Subject: [PATCH] is now async hostbuilder

---
 OpenFTTH.RelationalProjector/Program.cs                |  5 +++--
 .../RelationalDatabaseProjection.cs                    | 10 +++-------
 2 files changed, 6 insertions(+), 9 deletions(-)

diff --git a/OpenFTTH.RelationalProjector/Program.cs b/OpenFTTH.RelationalProjector/Program.cs
index 14bb32b..c32b1c5 100644
--- a/OpenFTTH.RelationalProjector/Program.cs
+++ b/OpenFTTH.RelationalProjector/Program.cs
@@ -1,12 +1,13 @@
 using Microsoft.Extensions.Hosting;
+using System.Threading.Tasks;
 
 namespace OpenFTTH.RelationalProjector
 {
     class Program
     {
-        static void Main(string[] args)
+        static async Task Main(string[] args)
         {
-            Startup.CreateHostBuilder(args).Build().Run();
+            await Startup.CreateHostBuilder(args).Build().RunAsync();
         }
     }
 }
diff --git a/OpenFTTH.RelationalProjector/RelationalDatabaseProjection.cs b/OpenFTTH.RelationalProjector/RelationalDatabaseProjection.cs
index e2b4ef3..6996fb2 100644
--- a/OpenFTTH.RelationalProjector/RelationalDatabaseProjection.cs
+++ b/OpenFTTH.RelationalProjector/RelationalDatabaseProjection.cs
@@ -33,7 +33,7 @@ public RelationalDatabaseProjection(ILogger<RelationalDatabaseProjection> logger
         {
             _logger = logger;
             _dbWriter = dbWriter;
-            
+
             ProjectEvent<WalkOfInterestRegistered>(Project);
             ProjectEvent<WalkOfInterestRouteNetworkElementsModified>(Project);
             ProjectEvent<InterestUnregistered>(Project);
@@ -104,7 +104,7 @@ private void Handle(WalkOfInterestRegistered @event)
                 _dbWriter.InsertGuidsIntoRouteElementToInterestTable(_schemaName, @event.Interest.Id, RemoveDublicatedIds(@event.Interest.RouteNetworkElementRefs));
             }
         }
-        
+
 
         private void Handle(WalkOfInterestRouteNetworkElementsModified @event)
         {
@@ -124,7 +124,7 @@ private void Handle(InterestUnregistered @event)
             if (_bulkMode)
             {
                 if (_interestToRouteElementRel.ContainsKey(@event.InterestId))
-                _interestToRouteElementRel.Remove(@event.InterestId);
+                    _interestToRouteElementRel.Remove(@event.InterestId);
             }
             else
             {
@@ -178,7 +178,6 @@ private void Handle(SpanEquipmentSpecificationChanged @event)
                 var diameter = _spanStructureSpecificationById[_spanEquipmentSpecificationById[@event.NewSpecificationId].RootTemplate.SpanStructureSpecificationId].OuterDiameter;
 
                 _dbWriter.UpdateSpanEquipmentDiameterInConduitTable(_schemaName, @event.SpanEquipmentId, diameter.Value);
-
             }
         }
 
@@ -206,11 +205,8 @@ public override void DehydrationFinish()
             _bulkMode = false;
 
             _logger.LogInformation("Bulk write finish.");
-
-
         }
 
-
         private IEnumerable<Guid> RemoveDublicatedIds(RouteNetworkElementIdList routeNetworkElementRefs)
         {
             RouteNetworkElementIdList result = new();