Update C# counterpart

Switch from OnConnect/OnDisconnect events to special reducers.

Author: RReverser

crates/bindings-csharp/Runtime/Module.cs

@@ -142,6 +142,8 @@ public static class ReducerKind
 {
     public const string Init = "__init__";
     public const string Update = "__update__";
+    public const string Connect = "__identity_connected__";
+    public const string Disconnect = "__identity_disconnected__";
 }
 
 public interface IReducer

crates/bindings-csharp/Runtime/Runtime.cs

@@ -229,37 +229,6 @@ public DbEventArgs(byte[] senderIdentity, ulong timestamp_us)
         }
     }
 
-    public static event Action<DbEventArgs>? OnConnect;
-    public static event Action<DbEventArgs>? OnDisconnect;
-
-    // Note: this is accessed by C bindings.
-    private static string? IdentityConnected(byte[] sender_identity, ulong timestamp)
-    {
-        try
-        {
-            OnConnect?.Invoke(new(sender_identity, timestamp));
-            return null;
-        }
-        catch (Exception e)
-        {
-            return e.ToString();
-        }
-    }
-
-    // Note: this is accessed by C bindings.
-    private static string? IdentityDisconnected(byte[] sender_identity, ulong timestamp)
-    {
-        try
-        {
-            OnDisconnect?.Invoke(new(sender_identity, timestamp));
-            return null;
-        }
-        catch (Exception e)
-        {
-            return e.ToString();
-        }
-    }
-
     [MethodImpl(MethodImplOptions.InternalCall)]
     private extern static void ScheduleReducer(
         string name,

modules/sdk-test-connect-disconnect-cs/Lib.cs

@@ -1,6 +1,5 @@
 using SpacetimeDB.Module;
 using static SpacetimeDB.Runtime;
-using System.Runtime.CompilerServices;
 
 static partial class Module
 {
@@ -16,18 +15,16 @@ public partial struct Disconnected
         public Identity identity;
     }
 
-    [ModuleInitializer]
-    public static void Init()
+    [SpacetimeDB.Reducer(ReducerKind.Connect)]
+    public static void OnConnect(DbEventArgs e)
     {
-        OnConnect += (e) =>
-        {
-            new Connected { identity = e.Sender }.Insert();
-        };
+        new Connected { identity = e.Sender }.Insert();
+    }
 
-        OnDisconnect += (e) =>
-        {
-            new Disconnected { identity = e.Sender }.Insert();
-        };
+    [SpacetimeDB.Reducer(ReducerKind.Disconnect)]
+    public static void OnDisconnect(DbEventArgs e)
+    {
+        new Disconnected { identity = e.Sender }.Insert();
     }
 
     [SpacetimeDB.Reducer]