[persisters] onIgnoredError

Author: jamesgpearce

src/persisters.ts

@@ -20,6 +20,7 @@ export const createCustomPersister = <ListeningHandle>(
   ) => Promise<void>,
   addPersisterListener: (listener: PersisterListener) => ListeningHandle,
   delPersisterListener: (listeningHandle: ListeningHandle) => void,
+  onIgnoredError?: (error: any) => void,
 ): Persister => {
   let listenerId: Id | undefined;
   let loadSave = 0;
@@ -39,7 +40,9 @@ export const createCustomPersister = <ListeningHandle>(
       while (!isUndefined((action = arrayShift(scheduledActions)))) {
         try {
           await action();
-        } catch {}
+        } catch (error) {
+          onIgnoredError?.(error);
+        }
       }
       running = 0;
     }
@@ -91,7 +94,9 @@ export const createCustomPersister = <ListeningHandle>(
                   getContent?.() ??
                     ((await getPersisted()) as [Tables, Values]),
                 );
-              } catch {}
+              } catch (error) {
+                onIgnoredError?.(error);
+              }
             }
           }),
       );
@@ -119,7 +124,9 @@ export const createCustomPersister = <ListeningHandle>(
         await persister.schedule(async () => {
           try {
             await setPersisted(store.getContent, getTransactionChanges);
-          } catch {}
+          } catch (error) {
+            onIgnoredError?.(error);
+          }
           loadSave = 0;
         });
       }

src/persisters/persister-automerge.ts

@@ -129,6 +129,7 @@ export const createAutomergePersister = (
   store: Store,
   docHandle: DocHandle<any>,
   docObjName = TINYBASE,
+  onIgnoredError?: (error: any) => void,
 ): Persister => {
   docHandle.change((doc) => (doc[docObjName] = {}));
 
@@ -167,5 +168,6 @@ export const createAutomergePersister = (
     setPersisted,
     addPersisterListener,
     delPersisterListener,
+    onIgnoredError,
   );
 };

src/persisters/persister-browser.ts

@@ -15,6 +15,7 @@ const getStoragePersister = (
   store: Store,
   storageName: string,
   storage: Storage,
+  onIgnoredError?: (error: any) => void,
 ): Persister => {
   const getPersisted = async (): Promise<[Tables, Values]> =>
     jsonParse(storage.getItem(storageName) as string);
@@ -42,6 +43,7 @@ const getStoragePersister = (
     setPersisted,
     addPersisterListener,
     delPersisterListener,
+    onIgnoredError,
   );
 };
 

src/persisters/persister-cr-sqlite-wasm.ts

@@ -10,6 +10,7 @@ export const createCrSqliteWasmPersister = ((
   db: DB,
   configOrStoreTableName?: DatabasePersisterConfig | string,
   logSql?: (sql: string, args?: any[]) => void,
+  onIgnoredError?: (error: any) => void,
 ): Persister =>
   createSqlitePersister(
     store,
@@ -20,4 +21,5 @@ export const createCrSqliteWasmPersister = ((
       db.onUpdate((_, _2, tableName) => listener(tableName)),
     (removeListener: () => void): void => removeListener(),
     logSql,
+    onIgnoredError,
   )) as typeof createCrSqliteWasmPersisterDecl;

src/persisters/persister-expo-sqlite.ts

@@ -12,6 +12,7 @@ export const createExpoSqlitePersister = ((
   db: SQLiteDatabase,
   configOrStoreTableName?: DatabasePersisterConfig | string,
   logSql?: (sql: string, args?: any[]) => void,
+  onIgnoredError?: (error: any) => void,
 ): Persister =>
   createSqlitePersister(
     store,
@@ -22,4 +23,5 @@ export const createExpoSqlitePersister = ((
       db.onDatabaseChange(({tableName}) => listener(tableName)),
     (subscription: Subscription) => subscription.remove(),
     logSql,
+    onIgnoredError,
   )) as typeof createExpoSqlitePersisterDecl;

src/persisters/persister-file.ts

@@ -10,6 +10,7 @@ import {createFilePersister as createFilePersisterDecl} from '../types/persister
 export const createFilePersister = ((
   store: Store,
   filePath: string,
+  onIgnoredError?: (error: any) => void,
 ): Persister => {
   const getPersisted = async (): Promise<[Tables, Values]> =>
     jsonParse(await readFile(filePath, UTF8));
@@ -29,5 +30,6 @@ export const createFilePersister = ((
     setPersisted,
     addPersisterListener,
     delPersisterListener,
+    onIgnoredError,
   );
 }) as typeof createFilePersisterDecl;

src/persisters/persister-remote.ts

@@ -12,6 +12,7 @@ export const createRemotePersister = ((
   loadUrl: string,
   saveUrl: string,
   autoLoadIntervalSeconds: number,
+  onIgnoredError?: (error: any) => void,
 ): Persister => {
   let lastEtag: string | null;
 
@@ -53,5 +54,6 @@ export const createRemotePersister = ((
     setPersisted,
     addPersisterListener,
     delPersisterListener,
+    onIgnoredError,
   );
 }) as typeof createRemotePersisterDecl;

src/persisters/persister-sqlite-wasm.ts

@@ -10,6 +10,7 @@ export const createSqliteWasmPersister = ((
   db: any,
   configOrStoreTableName?: DatabasePersisterConfig | string,
   logSql?: (sql: string, args?: any[]) => void,
+  onIgnoredError?: (error: any) => void,
 ): Persister =>
   createSqlitePersister(
     store,
@@ -26,4 +27,5 @@ export const createSqliteWasmPersister = ((
       ),
     (): void => sqlite3.capi.sqlite3_update_hook(db, () => 0, 0),
     logSql,
+    onIgnoredError,
   )) as typeof createSqliteWasmPersisterDecl;

src/persisters/persister-sqlite3.ts

@@ -15,6 +15,7 @@ export const createSqlite3Persister = ((
   db: Database,
   configOrStoreTableName?: DatabasePersisterConfig | string,
   logSql?: (sql: string, args?: any[]) => void,
+  onIgnoredError?: (error: any) => void,
 ): Persister =>
   createSqlitePersister(
     store,
@@ -35,4 +36,5 @@ export const createSqlite3Persister = ((
     },
     (observer: Observer): any => db.off(CHANGE, observer),
     logSql,
+    onIgnoredError,
   )) as typeof createSqlite3PersisterDecl;

src/persisters/persister-yjs.ts

@@ -192,6 +192,7 @@ export const createYjsPersister = (
   store: Store,
   yDoc: YDoc,
   yMapName = TINYBASE,
+  onIgnoredError?: (error: any) => void,
 ): Persister => {
   const yContent: YMap<any> = yDoc.getMap(yMapName);
 
@@ -230,5 +231,6 @@ export const createYjsPersister = (
     setPersisted,
     addPersisterListener,
     delPersisterListener,
+    onIgnoredError,
   );
 };