Fix web tests

Author: simolus3

packages/web/src/db/sync/SharedWebStreamingSyncImplementation.ts

@@ -257,6 +257,6 @@ export class SharedWebStreamingSyncImplementation extends WebStreamingSyncImplem
    */
   private async _testUpdateStatus(status: SyncStatus) {
     await this.isInitialized;
-    return (this.syncManager as any)['_testUpdateAllStatuses'](status.toJSON());
+    return this.syncManager._testUpdateAllStatuses(status.toJSON());
   }
 }

packages/web/src/worker/sync/SharedSyncImplementation.ts

@@ -494,7 +494,7 @@ export class SharedSyncImplementation extends BaseObserver<SharedSyncImplementat
    * A function only used for unit tests which updates the internal
    * sync stream client and all tab client's sync status
    */
-  private async _testUpdateAllStatuses(status: SyncStatusOptions) {
+  async _testUpdateAllStatuses(status: SyncStatusOptions) {
     if (!this.connectionManager.syncStreamImplementation) {
       throw new Error('Cannot update status without a sync stream implementation');
     }

packages/web/src/worker/sync/WorkerClient.ts

@@ -6,7 +6,7 @@ import {
   SharedSyncInitOptions,
   WrappedSyncPort
 } from './SharedSyncImplementation';
-import { ILogLevel, PowerSyncConnectionOptions, SubscribedStream } from '@powersync/common';
+import { ILogLevel, PowerSyncConnectionOptions, SubscribedStream, SyncStatusOptions } from '@powersync/common';
 
 /**
  * A client to the shared sync worker.
@@ -77,4 +77,8 @@ export class WorkerClient {
   disconnect() {
     return this.sync.disconnect();
   }
+
+  async _testUpdateAllStatuses(status: SyncStatusOptions) {
+    return this.sync._testUpdateAllStatuses(status);
+  }
 }

packages/web/tests/src/db/AbstractPowerSyncDatabase.test.ts

@@ -33,7 +33,16 @@ class TestPowerSyncDatabase extends AbstractPowerSyncDatabase {
 
   get database() {
     return {
-      get: vi.fn().mockResolvedValue({ version: '0.4.5' }),
+      get: vi.fn().mockResolvedValue({
+        version: '0.4.5',
+        r: JSON.stringify({
+          connected: false,
+          connecting: false,
+          priority_status: [],
+          downloading: null,
+          streams: []
+        })
+      }),
       getAll: vi.fn().mockResolvedValue([]),
       execute: vi.fn(),
       refreshSchema: vi.fn()