Reverted OPFS example change. Using abort controller signal to release lock.

Author: Chriztiaan

.changeset/blue-pets-count.md

@@ -3,7 +3,7 @@ import { AppSchema } from '@/library/powersync/AppSchema';
 import { SupabaseConnector } from '@/library/powersync/SupabaseConnector';
 import { CircularProgress } from '@mui/material';
 import { PowerSyncContext } from '@powersync/react';
-import { PowerSyncDatabase, WASQLiteOpenFactory, WASQLiteVFS } from '@powersync/web';
+import { PowerSyncDatabase } from '@powersync/web';
 import Logger from 'js-logger';
 import React, { Suspense } from 'react';
 import { NavigationPanelContextProvider } from '../navigation/NavigationPanelContext';
@@ -13,10 +13,9 @@ export const useSupabase = () => React.useContext(SupabaseContext);
 
 export const db = new PowerSyncDatabase({
   schema: AppSchema,
-  database: new WASQLiteOpenFactory({
-    dbFilename: 'one.sqlite',
-    vfs: WASQLiteVFS.OPFSCoopSyncVFS
-  })
+  database: {
+    dbFilename: 'example.db'
+  }
 });
 
 export const SystemProvider = ({ children }: { children: React.ReactNode }) => {
@@ -32,7 +31,7 @@ export const SystemProvider = ({ children }: { children: React.ReactNode }) => {
 
     powerSync.init();
     const l = connector.registerListener({
-      initialized: () => {},
+      initialized: () => { },
       sessionStarted: () => {
         powerSync.connect(connector);
       }

demos/react-supabase-todolist/src/components/providers/SystemProvider.tsx

@@ -29,11 +29,9 @@ export type WrappedWorkerConnectionOptions<Config extends ResolvedWebSQLOpenOpti
 export class WorkerWrappedAsyncDatabaseConnection<Config extends ResolvedWebSQLOpenOptions = ResolvedWebSQLOpenOptions>
   implements AsyncDatabaseConnection
 {
-  protected releaseSharedConnectionLock: (() => void) | null;
   protected lockAbortController: AbortController;
 
   constructor(protected options: WrappedWorkerConnectionOptions<Config>) {
-    this.releaseSharedConnectionLock = null;
     this.lockAbortController = new AbortController();
   }
 
@@ -74,8 +72,9 @@ export class WorkerWrappedAsyncDatabaseConnection<Config extends ResolvedWebSQLO
 
             // Hold the lock while the shared connection is in use.
             await new Promise<void>((releaseLock) => {
-              // We can use the resolver to free the lock
-              this.releaseSharedConnectionLock = releaseLock;
+              this.lockAbortController.signal.addEventListener('abort', () => {
+                releaseLock();
+              });
             });
           }
         )
@@ -98,7 +97,6 @@ export class WorkerWrappedAsyncDatabaseConnection<Config extends ResolvedWebSQLO
   async close(): Promise<void> {
     // Abort any pending lock requests.
     this.lockAbortController.abort();
-    this.releaseSharedConnectionLock?.();
     await this.baseConnection.close();
     this.options.remote[Comlink.releaseProxy]();
     this.options.onClose?.();