[persister] Added tolerance for loading invalid content

Author: jamesgpearce

src/persisters/index.ts

@@ -162,7 +162,10 @@ export const createCustomPersister = <
       loads++;
       await schedule(async () => {
         try {
-          setContentOrChanges(await getPersisted());
+          const content = await getPersisted();
+          isArray(content)
+            ? setContentOrChanges(content)
+            : errorNew(`Content is not an array ${content}`);
         } catch (error) {
           onIgnoredError?.(error);
           if (initialContent) {

src/store/index.ts

@@ -116,6 +116,7 @@ import {
 } from '../common/cell.ts';
 import {
   ifNotUndefined,
+  isArray,
   isFunction,
   isTypeStringOrBoolean,
   isUndefined,
@@ -245,6 +246,8 @@ export const createStore: typeof createStoreDecl = (): Store => {
     return true;
   };
 
+  const validateContent = isArray;
+
   const validateTables = (tables: Tables): boolean =>
     objValidate(tables, validateTable, cellInvalid);
 
@@ -411,6 +414,11 @@ export const createStore: typeof createStoreDecl = (): Store => {
   const setOrDelTables = (tables: Tables) =>
     objIsEmpty(tables) ? delTables() : setTables(tables);
 
+  const setValidContent = ([tables, values]: Content): void => {
+    (objIsEmpty(tables) ? delTables : setTables)(tables);
+    (objIsEmpty(values) ? delValues : setValues)(values);
+  };
+
   const setValidTables = (tables: Tables): TablesMap =>
     mapMatch(
       tablesMap,
@@ -1069,11 +1077,10 @@ export const createStore: typeof createStoreDecl = (): Store => {
   const getSchemaJson = (): Json =>
     jsonStringWithMap([tablesSchemaMap, valuesSchemaMap]);
 
-  const setContent = ([tables, values]: Content): Store =>
-    fluentTransaction(() => {
-      (objIsEmpty(tables) ? delTables : setTables)(tables);
-      (objIsEmpty(values) ? delValues : setValues)(values);
-    });
+  const setContent = (content: Content): Store =>
+    fluentTransaction(() =>
+      validateContent(content) ? setValidContent(content) : 0,
+    );
 
   const setTables = (tables: Tables): Store =>
     fluentTransaction(() =>