fix: allow writes to finish in run-once mode to fix snaspshot tests (#…

…291)

* fix: allow writes to finish in run-once mode to fix snaspshot tests

* enh: clarify snapshot scripts and add convenience script

package.json

@@ -8,9 +8,10 @@
   "scripts": {
     "start": "node dist/src/index.js",
     "dev": "tsx watch src/index.ts | pino-pretty",
-    "dev:snap:before": "NODE_ENV=snapshot-testing INDEXED_CHAINS=mainnet STORAGE_DIR=test/snapshot.BEFORE/data CACHE_DIR=test/snapshot.BEFORE/cache tsx src/index.ts --to-block 17199975 --run-once | pino-pretty",
-    "dev:snap:after": "NODE_ENV=snapshot-testing INDEXED_CHAINS=mainnet STORAGE_DIR=test/snapshot.AFTER/data CACHE_DIR=test/snapshot.AFTER/cache tsx src/index.ts --to-block 17199975 --run-once | pino-pretty",
-    "dev:snap:compare": "diff -r --brief test/snapshot.BEFORE/data test/snapshot.AFTER/data",
+    "test:snapshot:generate-before": "NODE_ENV=snapshot-testing INDEXED_CHAINS=mainnet STORAGE_DIR=test/snapshot.BEFORE/data CACHE_DIR=test/snapshot.BEFORE/cache tsx src/index.ts --to-block 17199975 --run-once | pino-pretty",
+    "test:snapshot:generate-after": "NODE_ENV=snapshot-testing INDEXED_CHAINS=mainnet STORAGE_DIR=test/snapshot.AFTER/data CACHE_DIR=test/snapshot.AFTER/cache tsx src/index.ts --to-block 17199975 --run-once | pino-pretty",
+    "test:snapshot:compare": "diff -r --brief test/snapshot.BEFORE/data test/snapshot.AFTER/data",
+    "test:snapshot": "test -d test/snapshot.BEFORE/data || (echo 'Missing BEFORE snapshot.'; exit 1); npm run test:snapshot:generate-after && npm run test:snapshot:compare && echo 'Snapshots match!'",
     "build": "tsc",
     "lint": "eslint src",
     "test": "vitest run --reporter verbose",

src/index.ts

@@ -76,8 +76,10 @@ async function main(): Promise<void> {
       )
     );
     // Workaround for active handles preventing process to terminate
-    // TODO investigate with console.log(process._getActiveHandles())
+    // (to investigate: console.log(process._getActiveHandles()))
+    // Note: the delay is necessary to allow completing writes.
     baseLogger.info("exiting");
+    await new Promise((resolve) => setTimeout(resolve, 1000));
     process.exit(0);
   } else {
     // Promises will be resolved once the initial catchup is done. Afterwards, services