Adopt OPFS file system

Author: simolus3

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

@@ -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 { createBaseLogger, LogLevel, PowerSyncDatabase } from '@powersync/web';
+import { createBaseLogger, LogLevel, PowerSyncDatabase, WASQLiteOpenFactory, WASQLiteVFS } from '@powersync/web';
 import React, { Suspense } from 'react';
 import { NavigationPanelContextProvider } from '../navigation/NavigationPanelContext';
 
@@ -12,9 +12,16 @@ export const useSupabase = () => React.useContext(SupabaseContext);
 
 export const db = new PowerSyncDatabase({
   schema: AppSchema,
-  database: {
-    dbFilename: 'example.db'
-  }
+  database: new WASQLiteOpenFactory({
+    dbFilename: 'example.db',
+    vfs: WASQLiteVFS.OPFSCoopSyncVFS,
+    flags: {
+      enableMultiTabs: typeof SharedWorker !== 'undefined'
+    } 
+  }),
+  flags: {
+    enableMultiTabs: typeof SharedWorker !== 'undefined'
+  } 
 });
 
 export const SystemProvider = ({ children }: { children: React.ReactNode }) => {

demos/react-supabase-todolist/src/library/powersync/SupabaseConnector.ts

@@ -86,78 +86,17 @@ export class SupabaseConnector extends BaseObserver<SupabaseConnectorListener> i
   }
 
   async fetchCredentials() {
-    const {
-      data: { session },
-      error
-    } = await this.client.auth.getSession();
-
-    if (!session || error) {
-      throw new Error(`Could not fetch Supabase credentials: ${error}`);
-    }
-
-    console.debug('session expires at', session.expires_at);
+    const response = await fetch('http://localhost:6060/api/auth/token');
+    const { token } = await response.json();
 
     return {
       endpoint: this.config.powersyncUrl,
-      token: session.access_token ?? ''
+      token,
     } satisfies PowerSyncCredentials;
   }
 
-  async uploadData(database: AbstractPowerSyncDatabase): Promise<void> {
-    const transaction = await database.getNextCrudTransaction();
-
-    if (!transaction) {
-      return;
-    }
-
-    let lastOp: CrudEntry | null = null;
-    try {
-      // Note: If transactional consistency is important, use database functions
-      // or edge functions to process the entire transaction in a single call.
-      for (const op of transaction.crud) {
-        lastOp = op;
-        const table = this.client.from(op.table);
-        let result: any;
-        switch (op.op) {
-          case UpdateType.PUT:
-            const record = { ...op.opData, id: op.id };
-            result = await table.upsert(record);
-            break;
-          case UpdateType.PATCH:
-            result = await table.update(op.opData).eq('id', op.id);
-            break;
-          case UpdateType.DELETE:
-            result = await table.delete().eq('id', op.id);
-            break;
-        }
-
-        if (result.error) {
-          console.error(result.error);
-          result.error.message = `Could not update Supabase. Received error: ${result.error.message}`;
-          throw result.error;
-        }
-      }
-
-      await transaction.complete();
-    } catch (ex: any) {
-      console.debug(ex);
-      if (typeof ex.code == 'string' && FATAL_RESPONSE_CODES.some((regex) => regex.test(ex.code))) {
-        /**
-         * Instead of blocking the queue with these errors,
-         * discard the (rest of the) transaction.
-         *
-         * Note that these errors typically indicate a bug in the application.
-         * If protecting against data loss is important, save the failing records
-         * elsewhere instead of discarding, and/or notify the user.
-         */
-        console.error('Data upload error - discarding:', lastOp, ex);
-        await transaction.complete();
-      } else {
-        // Error may be retryable - e.g. network error or temporary server error.
-        // Throwing an error here causes this call to be retried after a delay.
-        throw ex;
-      }
-    }
+  async uploadData(): Promise<void> {
+    throw 'unsupported';
   }
 
   updateSession(session: Session | null) {

packages/common/rollup.config.mjs

@@ -27,7 +27,7 @@ export default (commandLineArgs) => {
         // Used by can-ndjson-stream
         TextDecoder: ['text-encoding', 'TextDecoder']
       }),
-      terser()
+//      terser()
     ],
     // This makes life easier
     external: [