Updated interface to include Async events. (#353)

* Updated interface to include Async events.

* Updated Mocks

* Formatting fix

* More adjustments

src/NATS.Client.Core/INatsConnection.cs

@@ -1,7 +1,17 @@
+using System.Diagnostics.CodeAnalysis;
+
 namespace NATS.Client.Core;
 
 public interface INatsConnection : IAsyncDisposable
 {
+    event AsyncEventHandler<NatsEventArgs>? ConnectionDisconnected;
+
+    event AsyncEventHandler<NatsEventArgs>? ConnectionOpened;
+
+    event AsyncEventHandler<NatsEventArgs>? ReconnectFailed;
+
+    event AsyncEventHandler<NatsMessageDroppedEventArgs>? MessageDropped;
+
     INatsServerInfo? ServerInfo { get; }
 
     NatsOpts Opts { get; }

tests/NATS.Client.Core.Tests/NatsConnectionTest.cs

@@ -380,10 +380,6 @@ public void InterfaceShouldHaveSamePublicPropertiesEventsAndMethodAsClass()
         {
             var name = classInfo.Name;
 
-            // TODO: enable this check when we have events pulled up to the interface
-            if (Regex.IsMatch(name, @"add_|remove_"))
-                continue;
-
             interfaceMethods.Select(m => m.Name).Should().Contain(name);
         }
     }

tests/NATS.Client.JetStream.Tests/NatsJsContextFactoryTest.cs

@@ -1,5 +1,4 @@
 using NATS.Client.Core.Tests;
-using NATS.Client.JetStream.Models;
 
 namespace NATS.Client.JetStream.Tests;
 
@@ -83,6 +82,14 @@ public void Create_Context_WithMockConnection_Test()
 
     public class MockConnection : INatsConnection
     {
+        public event AsyncEventHandler<NatsEventArgs>? ConnectionDisconnected;
+
+        public event AsyncEventHandler<NatsEventArgs>? ConnectionOpened;
+
+        public event AsyncEventHandler<NatsEventArgs>? ReconnectFailed;
+
+        public event AsyncEventHandler<NatsMessageDroppedEventArgs>? MessageDropped;
+
         public INatsServerInfo? ServerInfo { get; } = null;
 
         public NatsOpts Opts { get; } = new();
@@ -103,10 +110,26 @@ public class MockConnection : INatsConnection
 
         public string NewInbox() => throw new NotImplementedException();
 
-        public ValueTask<NatsMsg<TReply>> RequestAsync<TRequest, TReply>(string subject, TRequest? data, NatsHeaders? headers = default, INatsSerialize<TRequest>? requestSerializer = default, INatsDeserialize<TReply>? replySerializer = default, NatsPubOpts? requestOpts = default, NatsSubOpts? replyOpts = default, CancellationToken cancellationToken = default)
+        public ValueTask<NatsMsg<TReply>> RequestAsync<TRequest, TReply>(
+            string subject,
+            TRequest? data,
+            NatsHeaders? headers = default,
+            INatsSerialize<TRequest>? requestSerializer = default,
+            INatsDeserialize<TReply>? replySerializer = default,
+            NatsPubOpts? requestOpts = default,
+            NatsSubOpts? replyOpts = default,
+            CancellationToken cancellationToken = default)
             => throw new NotImplementedException();
 
-        public IAsyncEnumerable<NatsMsg<TReply>> RequestManyAsync<TRequest, TReply>(string subject, TRequest? data, NatsHeaders? headers = default, INatsSerialize<TRequest>? requestSerializer = default, INatsDeserialize<TReply>? replySerializer = default, NatsPubOpts? requestOpts = default, NatsSubOpts? replyOpts = default, CancellationToken cancellationToken = default)
+        public IAsyncEnumerable<NatsMsg<TReply>> RequestManyAsync<TRequest, TReply>(
+            string subject,
+            TRequest? data,
+            NatsHeaders? headers = default,
+            INatsSerialize<TRequest>? requestSerializer = default,
+            INatsDeserialize<TReply>? replySerializer = default,
+            NatsPubOpts? requestOpts = default,
+            NatsSubOpts? replyOpts = default,
+            CancellationToken cancellationToken = default)
             => throw new NotImplementedException();
 
         public ValueTask ConnectAsync() => throw new NotImplementedException();