fix: patch filesystem cache

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@bgd-labs/aave-v3-governance-cache",
-  "version": "1.0.4",
+  "version": "1.0.5",
   "sideEffects": false,
   "files": [
     "cache",

scripts/refreshCache.ts

@@ -1,7 +1,18 @@
 import {customStorageProvider} from '../src/providers/customStorageProvider';
 import {refreshCache} from '../src/common/refreshCache';
-import {fileSystemStorage} from '../dist/fileSystem';
+import {fileSystemStorageAdapter} from '../dist/providers/storage/fileSystem';
+import {fallbackProvider} from '../dist/providers/fallbackProvider';
+import {githubPagesProvider} from '../dist/providers/githubPagesProvider';
 
-const provider = customStorageProvider(fileSystemStorage);
+const provider = customStorageProvider(fileSystemStorageAdapter);
 
 refreshCache(provider);
+
+// test
+// const fb = fallbackProvider(githubPagesProvider, provider);
+
+// fb.getPayload({
+//   chainId: 42161,
+//   payloadsController: '0x89644CA1bB8064760312AE4F03ea41b05dA3637C',
+//   payloadId: 31,
+// });

src/providers/customStorageProvider.ts

@@ -1,26 +1,25 @@
 import {type GovernanceCacheAdapterWithSync} from '..';
-import {ISSUES_FETCHING_PAYLOAD, ISSUES_FETCHING_PROPOSAL} from '../errors';
 
 export const customStorageProvider = (
   adapter: GovernanceCacheAdapterWithSync,
 ): GovernanceCacheAdapterWithSync => ({
   async getPayload(args) {
-    let cache = await adapter.getPayload(args);
-    if (!cache) {
+    try {
+      const cache = await adapter.getPayload(args);
+      return cache;
+    } catch (e) {
       await adapter.syncPayloadsCache(args);
-      cache = await adapter.getPayload(args);
-      if (!cache) throw new Error(ISSUES_FETCHING_PAYLOAD);
+      return await adapter.getPayload(args);
     }
-    return cache;
   },
   async getProposal(args) {
-    let cache = await adapter.getProposal(args);
-    if (!cache) {
+    try {
+      const cache = await adapter.getProposal(args);
+      return cache;
+    } catch (e) {
       await adapter.syncProposalCache(args);
-      cache = await adapter.getProposal(args);
-      if (!cache) throw new Error(ISSUES_FETCHING_PROPOSAL);
+      return await adapter.getProposal(args);
     }
-    return cache;
   },
   syncPayloadsCache(args) {
     return adapter.syncPayloadsCache(args);

src/providers/fallbackProvider.ts

@@ -10,6 +10,7 @@ export const fallbackProvider = <T extends GovernanceCacheAdapter>(
         const response = await providers[i].getPayload(args);
         return response;
       } catch (e) {
+        console.log(e);
         console.log('falling back to next provider');
       }
     }
@@ -21,6 +22,7 @@ export const fallbackProvider = <T extends GovernanceCacheAdapter>(
         const response = await providers[i].getProposal(args);
         return response;
       } catch (e) {
+        console.log(e);
         console.log('falling back to next provider');
       }
     }