execute gen-client-api.sh against centril/websocket-light

support TransactionUpdateLight support SetReducerFlags
clockworklabs · Oct 30, 2024 · ee86464 · ee86464
1 parent e4911fe
commit ee86464
Show file tree

Hide file tree

Showing 14 changed files with 285 additions and 159 deletions.
diff --git a/examples~/quickstart/client/module_bindings/_Globals/SpacetimeDBClient.cs b/examples~/quickstart/client/module_bindings/_Globals/SpacetimeDBClient.cs
@@ -63,13 +63,14 @@ internal UserHandle()
 
 	public sealed class RemoteReducers : RemoteBase<DbConnection>
 	{
-		internal RemoteReducers(DbConnection conn) : base(conn) {}
+		internal RemoteReducers(DbConnection conn, SetReducerFlags SetReducerFlags) : base(conn) { this.SetCallReducerFlags = SetReducerFlags; }
+		internal readonly SetReducerFlags SetCallReducerFlags;
 		public delegate void SendMessageHandler(EventContext ctx, string text);
 		public event SendMessageHandler? OnSendMessage;
 
 		public void SendMessage(string text)
 		{
-			conn.InternalCallReducer(new SendMessage { Text = text });
+			conn.InternalCallReducer(new SendMessage { Text = text }, this.SetCallReducerFlags.SendMessageFlags);
 		}
 
 		public bool InvokeSendMessage(EventContext ctx, SendMessage args)
@@ -86,7 +87,7 @@ public bool InvokeSendMessage(EventContext ctx, SendMessage args)
 
 		public void SetName(string name)
 		{
-			conn.InternalCallReducer(new SetName { Name = name });
+			conn.InternalCallReducer(new SetName { Name = name }, this.SetCallReducerFlags.SetNameFlags);
 		}
 
 		public bool InvokeSetName(EventContext ctx, SetName args)
@@ -100,14 +101,25 @@ public bool InvokeSetName(EventContext ctx, SetName args)
 		}
 	}
 
+	public sealed class SetReducerFlags
+	{
+		internal SetReducerFlags() { }
+		internal CallReducerFlags SendMessageFlags;
+		public void SendMessage(CallReducerFlags flags) { this.SendMessageFlags = flags; }
+		internal CallReducerFlags SetNameFlags;
+		public void SetName(CallReducerFlags flags) { this.SetNameFlags = flags; }
+	}
+
 	public partial record EventContext : DbContext<RemoteTables>, IEventContext
 	{
 		public readonly RemoteReducers Reducers;
+		public readonly SetReducerFlags SetReducerFlags;
 		public readonly Event<Reducer> Event;
 
 		internal EventContext(DbConnection conn, Event<Reducer> reducerEvent) : base(conn.Db)
 		{
 			Reducers = conn.Reducers;
+			SetReducerFlags = conn.SetReducerFlags;
 			Event = reducerEvent;
 		}
 	}
@@ -124,10 +136,12 @@ public class DbConnection : DbConnectionBase<DbConnection, Reducer>
 	{
 		public readonly RemoteTables Db = new();
 		public readonly RemoteReducers Reducers;
+		public readonly SetReducerFlags SetReducerFlags;
 
 		public DbConnection()
 		{
-			Reducers = new(this);
+			SetReducerFlags = new();
+			Reducers = new(this, this.SetReducerFlags);
 
 			clientDB.AddTable<Message>("message", Db.Message);
 			clientDB.AddTable<User>("user", Db.User);
@@ -136,7 +150,8 @@ public DbConnection()
 		protected override Reducer ToReducer(TransactionUpdate update)
 		{
 			var encodedArgs = update.ReducerCall.Args;
-			return update.ReducerCall.ReducerName switch {
+			return update.ReducerCall.ReducerName switch
+			{
 				"send_message" => new Reducer.SendMessage(BSATNHelpers.Decode<SendMessage>(encodedArgs)),
 				"set_name" => new Reducer.SetName(BSATNHelpers.Decode<SetName>(encodedArgs)),
 				"<none>" => new Reducer.StdbNone(default),
@@ -153,7 +168,8 @@ protected override IEventContext ToEventContext(Event<Reducer> reducerEvent) =>
 		protected override bool Dispatch(IEventContext context, Reducer reducer)
 		{
 			var eventContext = (EventContext)context;
-			return reducer switch {
+			return reducer switch
+			{
 				Reducer.SendMessage(var args) => Reducers.InvokeSendMessage(eventContext, args),
 				Reducer.SetName(var args) => Reducers.InvokeSetName(eventContext, args),
 				Reducer.StdbNone or

diff --git a/src/CallReducerFlags.cs b/src/CallReducerFlags.cs
@@ -0,0 +1,9 @@
+namespace SpacetimeDB
+{
+    public enum CallReducerFlags : byte
+    {
+        // This is the default.
+        FullUpdate = 0,
+        NoSuccessNotify = 1,
+    }
+}
diff --git a/src/SpacetimeDB/ClientApi/BsatnRowList.cs b/src/SpacetimeDB/ClientApi/BsatnRowList.cs
@@ -7,7 +7,6 @@
 using System;
 using SpacetimeDB;
 using System.Collections.Generic;
-using System.Linq;
 using System.Runtime.Serialization;
 
 namespace SpacetimeDB.ClientApi

diff --git a/src/SpacetimeDB/ClientApi/CallReducer.cs b/src/SpacetimeDB/ClientApi/CallReducer.cs
@@ -7,7 +7,6 @@
 using System;
 using SpacetimeDB;
 using System.Collections.Generic;
-using System.Linq;
 using System.Runtime.Serialization;
 
 namespace SpacetimeDB.ClientApi
@@ -22,16 +21,20 @@ public partial class CallReducer
 		public byte[] Args;
 		[DataMember(Name = "request_id")]
 		public uint RequestId;
+		[DataMember(Name = "flags")]
+		public byte Flags;
 
 		public CallReducer(
 			string Reducer,
 			byte[] Args,
-			uint RequestId
+			uint RequestId,
+			byte Flags
 		)
 		{
 			this.Reducer = Reducer;
 			this.Args = Args;
 			this.RequestId = RequestId;
+			this.Flags = Flags;
 		}
 
 		public CallReducer()

diff --git a/src/SpacetimeDB/ClientApi/OneOffQuery.cs b/src/SpacetimeDB/ClientApi/OneOffQuery.cs
@@ -7,7 +7,6 @@
 using System;
 using SpacetimeDB;
 using System.Collections.Generic;
-using System.Linq;
 using System.Runtime.Serialization;
 
 namespace SpacetimeDB.ClientApi

diff --git a/src/SpacetimeDB/ClientApi/OneOffQueryResponse.cs b/src/SpacetimeDB/ClientApi/OneOffQueryResponse.cs
@@ -7,7 +7,6 @@
 using System;
 using SpacetimeDB;
 using System.Collections.Generic;
-using System.Linq;
 using System.Runtime.Serialization;
 
 namespace SpacetimeDB.ClientApi

diff --git a/src/SpacetimeDB/ClientApi/QueryUpdate.cs b/src/SpacetimeDB/ClientApi/QueryUpdate.cs
@@ -7,7 +7,6 @@
 using System;
 using SpacetimeDB;
 using System.Collections.Generic;
-using System.Linq;
 using System.Runtime.Serialization;
 
 namespace SpacetimeDB.ClientApi

diff --git a/src/SpacetimeDB/ClientApi/ReducerCallInfo.cs b/src/SpacetimeDB/ClientApi/ReducerCallInfo.cs
@@ -7,7 +7,6 @@
 using System;
 using SpacetimeDB;
 using System.Collections.Generic;
-using System.Linq;
 using System.Runtime.Serialization;
 
 namespace SpacetimeDB.ClientApi

diff --git a/src/SpacetimeDB/ClientApi/ServerMessage.cs b/src/SpacetimeDB/ClientApi/ServerMessage.cs
@@ -13,6 +13,7 @@ namespace SpacetimeDB.ClientApi
 	public partial record ServerMessage : SpacetimeDB.TaggedEnum<(
 		SpacetimeDB.ClientApi.InitialSubscription InitialSubscription,
 		SpacetimeDB.ClientApi.TransactionUpdate TransactionUpdate,
+		SpacetimeDB.ClientApi.TransactionUpdateLight TransactionUpdateLight,
 		SpacetimeDB.ClientApi.IdentityToken IdentityToken,
 		SpacetimeDB.ClientApi.OneOffQueryResponse OneOffQueryResponse
 	)>;

diff --git a/src/SpacetimeDB/ClientApi/TransactionUpdateLight.cs b/src/SpacetimeDB/ClientApi/TransactionUpdateLight.cs
@@ -0,0 +1,38 @@
+// THIS FILE IS AUTOMATICALLY GENERATED BY SPACETIMEDB. EDITS TO THIS FILE
+// WILL NOT BE SAVED. MODIFY TABLES IN RUST INSTEAD.
+// <auto-generated />
+
+#nullable enable
+
+using System;
+using SpacetimeDB;
+using System.Collections.Generic;
+using System.Runtime.Serialization;
+
+namespace SpacetimeDB.ClientApi
+{
+	[SpacetimeDB.Type]
+	[DataContract]
+	public partial class TransactionUpdateLight
+	{
+		[DataMember(Name = "request_id")]
+		public uint RequestId;
+		[DataMember(Name = "update")]
+		public SpacetimeDB.ClientApi.DatabaseUpdate Update;
+
+		public TransactionUpdateLight(
+			uint RequestId,
+			SpacetimeDB.ClientApi.DatabaseUpdate Update
+		)
+		{
+			this.RequestId = RequestId;
+			this.Update = Update;
+		}
+
+		public TransactionUpdateLight()
+		{
+			this.Update = new();
+		}
+
+	}
+}