add listener on fetch block

subquery · Apr 15, 2024 · dd70d21 · dd70d21
1 parent 44a5280
commit dd70d21
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/packages/node/src/indexer/api.service.ts b/packages/node/src/indexer/api.service.ts
@@ -117,6 +117,10 @@ export class ApiService
         this.nodeConfig.kyveChainId,
         this.project.fileCacheDir,
       );
+
+      this.eventEmitter.on('block_processing_height', (block) => {
+        console.log('block_processing_height', block);
+      });
     }
 
     return this;
@@ -129,7 +133,10 @@ export class ApiService
   ): Promise<IBlock<BlockContent>[]> {
     try {
       if (this.kyveApi) {
-        return this.kyveApi.fetchBlocksBatches(this.registry, heights);
+        const v = await this.kyveApi.fetchBlocksBatches(this.registry, heights);
+        // listen for processingblock, if it is
+
+        return v;
       } else {
         throw new Error('No kyve connection');
       }

diff --git a/packages/node/src/utils/kyve/kyve.ts b/packages/node/src/utils/kyve/kyve.ts
@@ -255,6 +255,8 @@ export class KyveApi {
         .on('error', reject)
         .pipe(writeStream)
         .on('finish', resolve);
+    }).catch((e) => {
+      throw e; // to ensure an on stack error is thrown
     });
 
     await fs.promises.chmod(bundleFilePath, 0o444);
@@ -281,7 +283,8 @@ export class KyveApi {
   }
 
   // todo unsure when to clear the file cache
-  private async clearFileCache(height: number): Promise<void> {
+  async clearFileCache(height: number, clearBuffer: number): Promise<void> {
+    // add listener
     const bundleToRemove = this.cachedBundleDetails.filter(
       (b) => parseDecimal(b.from_key) > height,
     );