Refactor event handler missing logic and update comments

ClientProxyBase/ClientProxyBase_PUT.cs

@@ -36,7 +36,7 @@ protected virtual async Task<Result> SendHttpPutRequest<TRequest>(String uri,
                 requestMessage.Content = new StringContent(JsonConvert.SerializeObject(request), Encoding.UTF8, "application/json");
             }
 
-            // Make the Http Call here;
+            // Make the Http Call here
             HttpResponseMessage httpResponse = await this.HttpClient.SendAsync(requestMessage, cancellationToken);
 
             // Process the response

Shared.EventStore/SubscriptionWorker/PersistentSubscription.cs

@@ -1,13 +1,11 @@
-using System.Runtime.CompilerServices;
-using KurrentDB.Client;
+using KurrentDB.Client;
 using SimpleResults;
 
 namespace Shared.EventStore.SubscriptionWorker;
 
 using Aggregate;
 using DomainDrivenDesign.EventSourcing;
 using EventHandling;
-using global::EventStore.Client;
 using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
 using Shared.General;
@@ -24,7 +22,7 @@
 {
     public EventHandler<String> SubscriptionHasDropped;
 
-    public EventHandler<String> EventHandlerMissing;
+    public EventHandler<String> EventHandlerIsMissing;
 
     private readonly Func<CancellationToken, Task<KurrentDB.Client.PersistentSubscription>> Subscribe;
 
@@ -44,6 +42,18 @@
         }
     }
 
+    public void EventHandlerMissing(String reason)
+    {
+        this.Connected = false;
+        Logger.Logger.LogWarning($"Event handler missing - {reason}");
+
+        if (this.EventHandlerIsMissing != null)
+        {
+            //Broadcast to owner
+            this.EventHandlerIsMissing(this, reason);
+        }
+    }
+
     private PersistentSubscription(IPersistentSubscriptionsClient persistentSubscriptionsClient,
                                    PersistentSubscriptionDetails persistentSubscriptionDetails,
                                    IDomainEventHandlerResolver domainEventHandlerResolver,
@@ -144,8 +154,7 @@
 
             if (domainEventHandlersResult.IsFailed) {
                 // Log a line of trace out 
-                if (this.EventHandlerMissing != null)
-                    this.EventHandlerMissing(this, $"No event handlers configured for Event Type [{domainEvent.GetType().Name}]");
+                this.EventHandlerMissing($"No event handlers configured for Event Type [{domainEvent.GetType().Name}]");
 
                 await PersistentSubscriptionsHelper.AckEvent(persistentSubscription, resolvedEvent);
                 return;