reinitialize the cache entry in case of error

PaimaStudios · Dec 12, 2023 · b6de71c · b6de71c
1 parent e334a4d
commit b6de71c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/packages/engine/paima-funnel/src/funnels/FunnelCache.ts b/packages/engine/paima-funnel/src/funnels/FunnelCache.ts
@@ -92,6 +92,10 @@ export class CarpFunnelCacheEntry implements FunnelCacheEntry {
     }
   }
 
+  public initialized(): boolean {
+    return !!this.state;
+  }
+
   public getState(): Readonly<CarpFunnelCacheEntryState> {
     if (!this.state) {
       throw new Error('[carp-funnel] Uninitialized cache entry');

diff --git a/packages/engine/paima-funnel/src/funnels/carp/funnel.ts b/packages/engine/paima-funnel/src/funnels/carp/funnel.ts
@@ -193,7 +193,7 @@ export class CarpFunnel extends BaseFunnel implements ChainFunnel {
 
     const cacheEntry = (async (): Promise<CarpFunnelCacheEntry> => {
       const entry = sharedData.cacheManager.cacheEntries[CarpFunnelCacheEntry.SYMBOL];
-      if (entry != null) return entry;
+      if (entry != null && entry.initialized()) return entry;
 
       const newEntry = new CarpFunnelCacheEntry();
       sharedData.cacheManager.cacheEntries[CarpFunnelCacheEntry.SYMBOL] = newEntry;