websocket: receive ids, not names

clockworklabs · Nov 5, 2024 · 0671175 · 0671175
1 parent b0cfe58
commit 0671175
Show file tree

Hide file tree

Showing 26 changed files with 289 additions and 46 deletions.
diff --git a/packages/sdk/src/client_api/after_connecting_type.ts b/packages/sdk/src/client_api/after_connecting_type.ts
@@ -0,0 +1,83 @@
+// THIS FILE IS AUTOMATICALLY GENERATED BY SPACETIMEDB. EDITS TO THIS FILE
+// WILL NOT BE SAVED. MODIFY TABLES IN RUST INSTEAD.
+
+import {
+  // @ts-ignore
+  Address,
+  // @ts-ignore
+  AlgebraicType,
+  // @ts-ignore
+  AlgebraicValue,
+  // @ts-ignore
+  BinaryReader,
+  // @ts-ignore
+  BinaryWriter,
+  // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
+  DBConnectionBuilder,
+  // @ts-ignore
+  DBConnectionImpl,
+  // @ts-ignore
+  DBContext,
+  // @ts-ignore
+  Event,
+  // @ts-ignore
+  EventContextInterface,
+  // @ts-ignore
+  Identity,
+  // @ts-ignore
+  ProductType,
+  // @ts-ignore
+  ProductTypeElement,
+  // @ts-ignore
+  SumType,
+  // @ts-ignore
+  SumTypeVariant,
+  // @ts-ignore
+  TableCache,
+  // @ts-ignore
+  deepEqual,
+} from '..';
+// @ts-ignore
+import { IdentityToken as __IdentityToken } from './identity_token_type';
+// @ts-ignore
+import { IdsToNames as __IdsToNames } from './ids_to_names_type';
+
+export type AfterConnecting = {
+  identityToken: __IdentityToken;
+  idsToNames: __IdsToNames;
+};
+
+/**
+ * A namespace for generated helper functions.
+ */
+export namespace AfterConnecting {
+  /**
+   * A function which returns this type represented as an AlgebraicType.
+   * This function is derived from the AlgebraicType used to generate this type.
+   */
+  export function getTypeScriptAlgebraicType(): AlgebraicType {
+    return AlgebraicType.createProductType([
+      new ProductTypeElement(
+        'identityToken',
+        __IdentityToken.getTypeScriptAlgebraicType()
+      ),
+      new ProductTypeElement(
+        'idsToNames',
+        __IdsToNames.getTypeScriptAlgebraicType()
+      ),
+    ]);
+  }
+
+  export function serialize(
+    writer: BinaryWriter,
+    value: AfterConnecting
+  ): void {
+    AfterConnecting.getTypeScriptAlgebraicType().serialize(writer, value);
+  }
+
+  export function deserialize(reader: BinaryReader): AfterConnecting {
+    return AfterConnecting.getTypeScriptAlgebraicType().deserialize(reader);
+  }
+}
diff --git a/packages/sdk/src/client_api/bsatn_row_list_type.ts b/packages/sdk/src/client_api/bsatn_row_list_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/call_reducer_type.ts b/packages/sdk/src/client_api/call_reducer_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,
@@ -38,7 +40,7 @@ import {
   deepEqual,
 } from '..';
 export type CallReducer = {
-  reducer: string;
+  reducerId: number;
   args: Uint8Array;
   requestId: number;
   flags: number;
@@ -54,7 +56,7 @@ export namespace CallReducer {
    */
   export function getTypeScriptAlgebraicType(): AlgebraicType {
     return AlgebraicType.createProductType([
-      new ProductTypeElement('reducer', AlgebraicType.createStringType()),
+      new ProductTypeElement('reducerId', AlgebraicType.createU32Type()),
       new ProductTypeElement(
         'args',
         AlgebraicType.createArrayType(AlgebraicType.createU8Type())

diff --git a/packages/sdk/src/client_api/client_message_type.ts b/packages/sdk/src/client_api/client_message_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/compressable_query_update_type.ts b/packages/sdk/src/client_api/compressable_query_update_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/database_update_type.ts b/packages/sdk/src/client_api/database_update_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/energy_quanta_type.ts b/packages/sdk/src/client_api/energy_quanta_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/identity_token_type.ts b/packages/sdk/src/client_api/identity_token_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/ids_to_names_type.ts b/packages/sdk/src/client_api/ids_to_names_type.ts
@@ -0,0 +1,85 @@
+// THIS FILE IS AUTOMATICALLY GENERATED BY SPACETIMEDB. EDITS TO THIS FILE
+// WILL NOT BE SAVED. MODIFY TABLES IN RUST INSTEAD.
+
+import {
+  // @ts-ignore
+  Address,
+  // @ts-ignore
+  AlgebraicType,
+  // @ts-ignore
+  AlgebraicValue,
+  // @ts-ignore
+  BinaryReader,
+  // @ts-ignore
+  BinaryWriter,
+  // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
+  DBConnectionBuilder,
+  // @ts-ignore
+  DBConnectionImpl,
+  // @ts-ignore
+  DBContext,
+  // @ts-ignore
+  Event,
+  // @ts-ignore
+  EventContextInterface,
+  // @ts-ignore
+  Identity,
+  // @ts-ignore
+  ProductType,
+  // @ts-ignore
+  ProductTypeElement,
+  // @ts-ignore
+  SumType,
+  // @ts-ignore
+  SumTypeVariant,
+  // @ts-ignore
+  TableCache,
+  // @ts-ignore
+  deepEqual,
+} from '..';
+export type IdsToNames = {
+  reducerIds: number[];
+  reducerNames: string[];
+  tableIds: number[];
+  tableNames: string[];
+};
+
+/**
+ * A namespace for generated helper functions.
+ */
+export namespace IdsToNames {
+  /**
+   * A function which returns this type represented as an AlgebraicType.
+   * This function is derived from the AlgebraicType used to generate this type.
+   */
+  export function getTypeScriptAlgebraicType(): AlgebraicType {
+    return AlgebraicType.createProductType([
+      new ProductTypeElement(
+        'reducerIds',
+        AlgebraicType.createArrayType(AlgebraicType.createU32Type())
+      ),
+      new ProductTypeElement(
+        'reducerNames',
+        AlgebraicType.createArrayType(AlgebraicType.createStringType())
+      ),
+      new ProductTypeElement(
+        'tableIds',
+        AlgebraicType.createArrayType(AlgebraicType.createU32Type())
+      ),
+      new ProductTypeElement(
+        'tableNames',
+        AlgebraicType.createArrayType(AlgebraicType.createStringType())
+      ),
+    ]);
+  }
+
+  export function serialize(writer: BinaryWriter, value: IdsToNames): void {
+    IdsToNames.getTypeScriptAlgebraicType().serialize(writer, value);
+  }
+
+  export function deserialize(reader: BinaryReader): IdsToNames {
+    return IdsToNames.getTypeScriptAlgebraicType().deserialize(reader);
+  }
+}
diff --git a/packages/sdk/src/client_api/index.ts b/packages/sdk/src/client_api/index.ts
@@ -45,6 +45,8 @@ import {
 // Import and reexport all table handle types
 
 // Import and reexport all types
+import { AfterConnecting } from './after_connecting_type.ts';
+export { AfterConnecting };
 import { BsatnRowList } from './bsatn_row_list_type.ts';
 export { BsatnRowList };
 import { CallReducer } from './call_reducer_type.ts';
@@ -59,6 +61,8 @@ import { EnergyQuanta } from './energy_quanta_type.ts';
 export { EnergyQuanta };
 import { IdentityToken } from './identity_token_type.ts';
 export { IdentityToken };
+import { IdsToNames } from './ids_to_names_type.ts';
+export { IdsToNames };
 import { InitialSubscription } from './initial_subscription_type.ts';
 export { InitialSubscription };
 import { OneOffQuery } from './one_off_query_type.ts';

diff --git a/packages/sdk/src/client_api/initial_subscription_type.ts b/packages/sdk/src/client_api/initial_subscription_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/one_off_query_response_type.ts b/packages/sdk/src/client_api/one_off_query_response_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/one_off_query_type.ts b/packages/sdk/src/client_api/one_off_query_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/one_off_table_type.ts b/packages/sdk/src/client_api/one_off_table_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,
@@ -41,7 +43,7 @@ import {
 import { BsatnRowList as __BsatnRowList } from './bsatn_row_list_type';
 
 export type OneOffTable = {
-  tableName: string;
+  tableId: number;
   rows: __BsatnRowList;
 };
 
@@ -55,7 +57,7 @@ export namespace OneOffTable {
    */
   export function getTypeScriptAlgebraicType(): AlgebraicType {
     return AlgebraicType.createProductType([
-      new ProductTypeElement('tableName', AlgebraicType.createStringType()),
+      new ProductTypeElement('tableId', AlgebraicType.createU32Type()),
       new ProductTypeElement(
         'rows',
         __BsatnRowList.getTypeScriptAlgebraicType()

diff --git a/packages/sdk/src/client_api/query_update_type.ts b/packages/sdk/src/client_api/query_update_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,

diff --git a/packages/sdk/src/client_api/reducer_call_info_type.ts b/packages/sdk/src/client_api/reducer_call_info_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,
@@ -38,8 +40,8 @@ import {
   deepEqual,
 } from '..';
 export type ReducerCallInfo = {
-  reducerName: string;
   reducerId: number;
+  reducerName: void;
   args: Uint8Array;
   requestId: number;
 };
@@ -54,8 +56,11 @@ export namespace ReducerCallInfo {
    */
   export function getTypeScriptAlgebraicType(): AlgebraicType {
     return AlgebraicType.createProductType([
-      new ProductTypeElement('reducerName', AlgebraicType.createStringType()),
       new ProductTypeElement('reducerId', AlgebraicType.createU32Type()),
+      new ProductTypeElement(
+        'reducerName',
+        AlgebraicType.createProductType([])
+      ),
       new ProductTypeElement(
         'args',
         AlgebraicType.createArrayType(AlgebraicType.createU8Type())

diff --git a/packages/sdk/src/client_api/row_size_hint_type.ts b/packages/sdk/src/client_api/row_size_hint_type.ts
@@ -13,6 +13,8 @@ import {
   // @ts-ignore
   BinaryWriter,
   // @ts-ignore
+  CallReducerFlags,
+  // @ts-ignore
   DBConnectionBuilder,
   // @ts-ignore
   DBConnectionImpl,