Merge pull request #103 from clockworklabs/tyler/stable-sdk/fix-1

Make `subscribe` private

Author: bfops

packages/sdk/src/db_connection_impl.ts

@@ -271,7 +271,8 @@ export class DBConnectionImpl<DBView = any, Reducers = any>
    * spacetimeDBClient.subscribe(["SELECT * FROM User","SELECT * FROM Message"]);
    * ```
    */
-  subscribe(
+  // This is marked private but not # because we need to use it from the builder
+  private subscribe(
     queryOrQueries: string | string[],
     onApplied?: (ctx: EventContextInterface) => void,
     _onError?: (ctx: EventContextInterface) => void

packages/sdk/src/db_context.ts

@@ -92,7 +92,7 @@ export class SubscriptionBuilder {
   /// Consumes the `SubscriptionBuilder`,
   /// because the callbacks are not necessarily `Clone`.
   subscribe(query_sql: string[]): void {
-    this.db.subscribe(query_sql, this.#onApplied, this.#onError);
+    this.db['subscribe'](query_sql, this.#onApplied, this.#onError);
   }
 }
 

packages/sdk/tests/spacetimedb_client.test.ts

@@ -45,8 +45,10 @@ describe('SpacetimeDBClient', () => {
       .withWSFn(wsAdapter.createWebSocketFn.bind(wsAdapter))
       .build();
 
-    client.subscribe('SELECT * FROM Player');
-    client.subscribe(['SELECT * FROM Position', 'SELECT * FROM Coin']);
+    client.subscriptionBuilder().subscribe(['SELECT * FROM Player']);
+    client
+      .subscriptionBuilder()
+      .subscribe(['SELECT * FROM Position', 'SELECT * FROM Coin']);
 
     let called = false;
     client.onConnect(() => {