add ping/pong message handling and retry policy to EngineIO adapters

Author: doghappy

src/SocketIOClient.Core/Messages/PingMessage.cs

@@ -0,0 +1,6 @@
+namespace SocketIOClient.Core.Messages;
+
+public class PingMessage : IMessage
+{
+    public MessageType Type => MessageType.Ping;
+}

src/SocketIOClient.Core/Messages/PongMessage.cs

@@ -0,0 +1,9 @@
+using System;
+
+namespace SocketIOClient.Core.Messages;
+
+public class PongMessage : IMessage
+{
+    public MessageType Type => MessageType.Pong;
+    public TimeSpan Duration { get; set; }
+}

src/SocketIOClient.Core/Messages/TypeOnlyMessage.cs

@@ -42,8 +42,8 @@ protected override IMessage NewMessage(MessageType type, string text)
         return type switch
         {
             MessageType.Opened => NewOpenedMessage(text),
-            MessageType.Ping => new TypeOnlyMessage(MessageType.Ping),
-            MessageType.Pong => new TypeOnlyMessage(MessageType.Pong),
+            MessageType.Ping => new PingMessage(),
+            MessageType.Pong => new PongMessage(),
             MessageType.Connected => EngineIOMessageAdapter.DeserializeConnectedMessage(text),
             MessageType.Disconnected => NewDisconnectedMessage(text),
             MessageType.Event => NewEventMessage(text),

src/SocketIOClient.Serializer.NewtonsoftJson/NewtonJsonSerializer.cs

@@ -62,6 +62,14 @@ public IMessage Deserialize(string text)
         return NewMessage(result.Type!.Value, result.Data);
     }
 
+    public ProtocolMessage NewPingMessage()
+    {
+        return new ProtocolMessage
+        {
+            Text = "2",
+        };
+    }
+
     protected abstract IMessage NewMessage(MessageType type, string text);
 
     private static List<ProtocolMessage> GetSerializeResult(string text, IEnumerable<byte[]> bytes)

src/SocketIOClient.Serializer/BaseJsonSerializer.cs

@@ -9,5 +9,6 @@ public interface ISerializer
         string Namespace { get; set; }
         List<ProtocolMessage> Serialize(object[] data);
         IMessage Deserialize(string text);
+        ProtocolMessage NewPingMessage();
     }
 }

src/SocketIOClient.Serializer/ISerializer.cs

@@ -1,5 +1,6 @@
 using System.Net.Http;
 using SocketIOClient.Serializer.Decapsulation;
+using SocketIOClient.V2.Infrastructure;
 using SocketIOClient.V2.Protocol.Http;
 using SocketIOClient.V2.Serializer.SystemTextJson;
 using SocketIOClient.V2.Session;
@@ -10,28 +11,27 @@ namespace SocketIOClient.V2;
 
 public interface ISessionFactory
 {
-    ISession New(EngineIO eio);
+    ISession New(EngineIO eio, SessionOptions options);
 }
 
 public class DefaultSessionFactory : ISessionFactory
 {
-    public ISession New(EngineIO eio)
+    public ISession New(EngineIO eio, SessionOptions options)
     {
-        var engineIOAdapter = NewEnginIOAdapter(eio);
         var httpClient = new SystemHttpClient(new HttpClient());
+        var httpAdapter = new HttpAdapter(httpClient);
+        var serializer = new SystemJsonSerializer(new Decapsulator());
+        var stopwatch = new SystemStopwatch();
+        var random = new SystemRandom();
+        var randomDelayRetryPolicy = new RandomDelayRetryPolicy(random);
+        IEngineIOAdapter engineIOAdapter = eio == EngineIO.V3
+            ? new EngineIO3Adapter(stopwatch, serializer, httpAdapter, options.Timeout, randomDelayRetryPolicy)
+            : new EngineIO4Adapter(stopwatch, httpAdapter, options.Timeout);
         return new HttpSession(
+            options,
             engineIOAdapter,
             new HttpAdapter(httpClient),
-            new SystemJsonSerializer(new Decapsulator()),
+            serializer,
             new DefaultUriConverter((int)eio));
     }
-
-    private static IEngineIOAdapter NewEnginIOAdapter(EngineIO eio)
-    {
-        if (eio == EngineIO.V3)
-        {
-            return new EngineIO3Adapter();
-        }
-        return new EngineIO4Adapter();
-    }
 }

src/SocketIOClient/V2/DefaultSessionFactory.cs

@@ -0,0 +1,8 @@
+using System;
+
+namespace SocketIOClient.V2.Infrastructure;
+
+public interface IRandom
+{
+    int Next(int max);
+}

src/SocketIOClient/V2/Infrastructure/IRandom.cs

@@ -0,0 +1,9 @@
+using System;
+using System.Threading.Tasks;
+
+namespace SocketIOClient.V2.Infrastructure;
+
+public interface IRetriable
+{
+    Task RetryAsync(int times, Func<Task> func);
+}

src/SocketIOClient/V2/Infrastructure/IRetriable.cs

@@ -0,0 +1,10 @@
+using System;
+
+namespace SocketIOClient.V2.Infrastructure;
+
+public interface IStopwatch
+{
+    TimeSpan Elapsed { get; }
+    void Restart();
+    void Stop();
+}