cleanup

ponder-sh · Jun 11, 2024 · 86451ab · 86451ab
1 parent cbe1023
commit 86451ab
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 1 deletion.
diff --git a/packages/core/src/_test/setup.ts b/packages/core/src/_test/setup.ts
@@ -171,6 +171,7 @@ export async function setupDatabaseServices(
             namespaceInfo: result.namespaceInfo,
             db: database.indexingDb,
             common: context.common,
+            isCacheFull: true,
           })
         : getRealtimeStore({
             encoding: "sqlite",
@@ -224,6 +225,7 @@ export async function setupDatabaseServices(
             namespaceInfo: result.namespaceInfo,
             db: database.indexingDb,
             common: context.common,
+            isCacheFull: true,
           })
         : getRealtimeStore({
             encoding: "postgres",

diff --git a/packages/core/src/bin/utils/run.ts b/packages/core/src/bin/utils/run.ts
@@ -195,6 +195,7 @@ export async function run({
     namespaceInfo,
     db: database.indexingDb,
     common,
+    isCacheFull: isCheckpointEqual(zeroCheckpoint, initialCheckpoint),
   });
 
   let indexingStore: IndexingStore = {

diff --git a/packages/core/src/indexing-store/historical.ts b/packages/core/src/indexing-store/historical.ts
@@ -53,12 +53,14 @@ export const getHistoricalStore = ({
   namespaceInfo,
   db,
   common,
+  isCacheFull: _isCacheFull,
 }: {
   encoding: "sqlite" | "postgres";
   schema: Schema;
   namespaceInfo: NamespaceInfo;
   db: HeadlessKysely<any>;
   common: Common;
+  isCacheFull: boolean;
 }): HistoricalStore => {
   const maxSizeBytes = common.options.indexingCacheBytes;
   const storeCache: StoreCache = {};
@@ -76,7 +78,7 @@ export const getHistoricalStore = ({
   });
 
   /** True if the cache contains the complete state of the store. */
-  let isCacheFull = true;
+  let isCacheFull = _isCacheFull;
 
   let cacheSize = 0;
   let cacheSizeBytes = 0;
@@ -438,6 +440,7 @@ export const getHistoricalStore = ({
           schema,
           skipValidate: false,
         });
+
         sanitizeRecord(record, tableName);
 
         const bytes = getRecordSize(record);