Implement smarter reconnection logic

LucHeart · LucHeart · commit ab1e4375994d · 2025-07-06T23:39:47.000+02:00
diff --git a/SDK.CSharp.Live/LiveControlReconnectionPolicy.cs b/SDK.CSharp.Live/LiveControlReconnectionPolicy.cs
@@ -0,0 +1,17 @@
+﻿using LucHeart.WebsocketLibrary.Reconnection;
+
+namespace OpenShock.SDK.CSharp.Live;
+
+internal sealed class LiveControlReconnectionPolicy : IReconnectPolicy
+{
+    public TimeSpan NextReconnectionDelay(ReconnectionContext reconnectionContext)
+    {
+        return reconnectionContext.Attempt switch
+        {
+            > 10 => TimeSpan.FromSeconds(30),
+            > 3 => TimeSpan.FromSeconds(10),
+            > 1 => TimeSpan.FromSeconds(5),
+            <= 1 => TimeSpan.FromMilliseconds(0),
+        };
+    }
+}
diff --git a/SDK.CSharp.Live/OpenShockLiveControlClient.cs b/SDK.CSharp.Live/OpenShockLiveControlClient.cs
@@ -182,15 +182,16 @@ private OpenShockLiveControlClient(Guid hubId,
     private WebsocketClientOptions GetWebsocketOptions(string authToken, ApiClientOptions.ProgramInfo? programInfo,
         IEnumerable<KeyValuePair<string, string>>? headers, ILogger? logger)
     {
-        var options = new WebsocketClientOptions()
+        var options = new WebsocketClientOptions
         {
             JsonSerializerOptions = JsonSerializerOptions,
             Headers =
             {
                 { "OpenShockToken", authToken },
                 { "User-Agent", GetUserAgent(programInfo) }
             },
-            Logger = logger
+            Logger = logger,
+            ReconnectPolicy = new LiveControlReconnectionPolicy()
         };
         if (headers is null) return options;
         
diff --git a/SDK.CSharp.Live/SDK.CSharp.Live.csproj b/SDK.CSharp.Live/SDK.CSharp.Live.csproj
@@ -6,7 +6,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="LucHeart.WebsocketLibrary" Version="1.0.1" />
+        <PackageReference Include="LucHeart.WebsocketLibrary" Version="1.1.0" />
         <PackageReference Include="Microsoft.Extensions.Logging" Version="9.0.6" />
         <PackageReference Include="Microsoft.IO.RecyclableMemoryStream" Version="3.0.1" />
         <PackageReference Condition=" '$(Configuration)' == 'Release' " Include="OpenShock.SDK.CSharp" Version="$(Version)" />
diff --git a/Shared.props b/Shared.props
@@ -2,7 +2,7 @@
     <PropertyGroup>
         <Company>OpenShock</Company>
         <Product>$(Company).$(MSBuildProjectName)</Product>
-        <Version>0.0.37</Version>
+        <Version>0.0.38</Version>
 
         <Title>$(Product)</Title>
         <Authors>OpenShock</Authors>

Original file line number	Diff line number	Diff line change
`@@ -182,15 +182,16 @@ private OpenShockLiveControlClient(Guid hubId,`
`182`	`182`	`private WebsocketClientOptions GetWebsocketOptions(string authToken, ApiClientOptions.ProgramInfo? programInfo,`
`183`	`183`	`IEnumerable<KeyValuePair<string, string>>? headers, ILogger? logger)`
`184`	`184`	`{`
`185`		`- var options = new WebsocketClientOptions()`
	`185`	`+ var options = new WebsocketClientOptions`
`186`	`186`	`{`
`187`	`187`	`JsonSerializerOptions = JsonSerializerOptions,`
`188`	`188`	`Headers =`
`189`	`189`	`{`
`190`	`190`	`{ "OpenShockToken", authToken },`
`191`	`191`	`{ "User-Agent", GetUserAgent(programInfo) }`
`192`	`192`	`},`
`193`		`- Logger = logger`
	`193`	`+ Logger = logger,`
	`194`	`+ ReconnectPolicy = new LiveControlReconnectionPolicy()`
`194`	`195`	`};`
`195`	`196`	`if (headers is null) return options;`
`196`	`197`