modernize: Standardize UpdateStatus

packages/sdk/src/client_api/update_status.ts

@@ -1,18 +1,23 @@
-// THIS FILE IS AUTOMATICALLY GENERATED BY SPACETIMEDB. EDITS TO THIS FILE
-// WILL NOT BE SAVED. MODIFY TABLES IN RUST INSTEAD.
-
 import {
   AlgebraicType,
   BuiltinType,
   SumTypeVariant,
 } from '../algebraic_type.ts';
 import type { AlgebraicValue } from '../algebraic_value.ts';
-import { DatabaseUpdate as __DatabaseUpdate } from './database_update.ts';
+import { DatabaseUpdate } from './database_update.ts';
+
+export class UpdateStatus {
+  constructor(
+    public tag: 'Committed' | 'Failed' | 'OutOfEnergy',
+    public value: DatabaseUpdate | string | undefined
+  ) {
+    this.tag = tag;
+    this.value = value;
+  }
 
-export namespace UpdateStatus {
-  export function getAlgebraicType(): AlgebraicType {
+  static getAlgebraicType(): AlgebraicType {
     return AlgebraicType.createSumType([
-      new SumTypeVariant('Committed', __DatabaseUpdate.getAlgebraicType()),
+      new SumTypeVariant('Committed', DatabaseUpdate.getAlgebraicType()),
       new SumTypeVariant(
         'Failed',
         AlgebraicType.createPrimitiveType(BuiltinType.Type.String)
@@ -21,10 +26,12 @@ export namespace UpdateStatus {
     ]);
   }
 
-  export function serialize(value: UpdateStatus): object {
+  static serialize(value: UpdateStatus): object {
     switch (value.tag) {
       case 'Committed':
-        return { Committed: __DatabaseUpdate.serialize(value.value) };
+        return {
+          Committed: DatabaseUpdate.serialize(value.value as DatabaseUpdate),
+        };
       case 'Failed':
         return { Failed: value.value };
       case 'OutOfEnergy':
@@ -34,36 +41,30 @@ export namespace UpdateStatus {
     }
   }
 
-  export type Committed = { tag: 'Committed'; value: __DatabaseUpdate };
-  export const Committed = (value: __DatabaseUpdate): Committed => ({
-    tag: 'Committed',
-    value,
-  });
-  export type Failed = { tag: 'Failed'; value: string };
-  export const Failed = (value: string): Failed => ({ tag: 'Failed', value });
-  export type OutOfEnergy = { tag: 'OutOfEnergy'; value: undefined };
-  export const OutOfEnergy = { tag: 'OutOfEnergy', value: undefined };
-
-  export function fromValue(value: AlgebraicValue): UpdateStatus {
+  static fromValue(value: AlgebraicValue): UpdateStatus {
     let sumValue = value.asSumValue();
     switch (sumValue.tag) {
       case 0:
-        return {
-          tag: 'Committed',
-          value: __DatabaseUpdate.fromValue(sumValue.value),
-        };
+        return new UpdateStatus(
+          'Committed',
+          DatabaseUpdate.fromValue(sumValue.value)
+        );
       case 1:
-        return { tag: 'Failed', value: sumValue.value.asString() };
+        return new UpdateStatus('Failed', sumValue.value.asString());
       case 2:
-        return { tag: 'OutOfEnergy', value: undefined };
+        return new UpdateStatus('OutOfEnergy', undefined);
       default:
         throw 'unreachable';
     }
   }
-}
 
-export type UpdateStatus =
-  | UpdateStatus.Committed
-  | UpdateStatus.Failed
-  | UpdateStatus.OutOfEnergy;
-export default UpdateStatus;
+  static Committed(value: DatabaseUpdate): UpdateStatus {
+    return new UpdateStatus('Committed', value);
+  }
+  static Failed(value: string): UpdateStatus {
+    return new UpdateStatus('Failed', value);
+  }
+  static OutOfEnergy(): UpdateStatus {
+    return new UpdateStatus('OutOfEnergy', undefined);
+  }
+}

packages/sdk/src/spacetimedb.ts

@@ -516,11 +516,13 @@ export class SpacetimeDBClient {
         let errMessage = '';
         switch (txUpdate.status.tag) {
           case 'Committed':
-            subscriptionUpdate = parseDatabaseUpdate(txUpdate.status.value);
+            subscriptionUpdate = parseDatabaseUpdate(
+              txUpdate.status.value as ws.DatabaseUpdate
+            );
             break;
           case 'Failed':
             subscriptionUpdate = new SubscriptionUpdateMessage([]);
-            errMessage = txUpdate.status.value;
+            errMessage = txUpdate.status.value as string;
             break;
           case 'OutOfEnergy':
             subscriptionUpdate = new SubscriptionUpdateMessage([]);