Clean up

subquery · Dec 2, 2024 · a858912 · a858912
1 parent ce2d0dd
commit a858912
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 17 deletions.
diff --git a/packages/node-core/src/db/sync-helper.ts b/packages/node-core/src/db/sync-helper.ts
@@ -297,10 +297,6 @@ export function createSchemaTriggerFunction(schema: string): string {
   $$ LANGUAGE plpgsql;`;
 }
 
-// export function enumNameToHash(enumName: string): string {
-//   return blake2AsHex(enumName).substr(2, 10);
-// }
-
 export function getExistedIndexesQuery(schema: string): string {
   return `SELECT indexname FROM pg_indexes WHERE schemaname = '${schema}'`;
 }

diff --git a/packages/node-core/src/indexer/blockDispatcher/base-block-dispatcher.ts b/packages/node-core/src/indexer/blockDispatcher/base-block-dispatcher.ts
@@ -82,7 +82,6 @@ export abstract class BaseBlockDispatcher<Q extends IQueue, DS, B> implements IB
   }
 
   get batchSize(): number {
-    // TODO make this smarter
     return this.nodeConfig.batchSize;
   }
 

diff --git a/packages/node-core/src/indexer/fetch.service.ts b/packages/node-core/src/indexer/fetch.service.ts
@@ -207,14 +207,6 @@ export abstract class BaseFetchService<DS extends BaseDataSource, B extends IBlo
 
       const latestHeight = this.latestHeight();
 
-      console.log(
-        'XXXX',
-        this.blockDispatcher.freeSize,
-        scaledBatchSize,
-        startBlockHeight,
-        latestHeight,
-        this.blockDispatcher.freeSize < scaledBatchSize || startBlockHeight > latestHeight
-      );
       if (this.blockDispatcher.freeSize < scaledBatchSize || startBlockHeight > latestHeight) {
         if (this.blockDispatcher.freeSize < scaledBatchSize) {
           logger.debug(
@@ -268,7 +260,6 @@ export abstract class BaseFetchService<DS extends BaseDataSource, B extends IBlo
             await this.enqueueSequential(startBlockHeight, scaledBatchSize, latestHeight);
           }
         } catch (e: any) {
-          console.log('RERRR', e);
           logger.debug(`Fetch dictionary stopped: ${e.message}`);
           this.eventEmitter.emit(IndexerEvent.SkipDictionary);
           await this.enqueueSequential(startBlockHeight, scaledBatchSize, latestHeight);
@@ -325,7 +316,6 @@ export abstract class BaseFetchService<DS extends BaseDataSource, B extends IBlo
     scaledBatchSize: number,
     latestHeight: number
   ): Promise<void> {
-    console.log('FFFF');
     // End height from current dataSource
     const {endHeight, value: relevantDs} = this.getRelevantDsDetails(startBlockHeight);
     // Estimated range end height
@@ -338,7 +328,6 @@ export abstract class BaseFetchService<DS extends BaseDataSource, B extends IBlo
       ? this.getEnqueuedModuloBlocks(startBlockHeight, latestHeight)
       : range(startBlockHeight, estRangeEndHeight + 1);
 
-    console.log('GGGGGG', enqueuingBlocks, estRangeEndHeight);
     await this.enqueueBlocks(enqueuingBlocks, estRangeEndHeight);
   }
 
@@ -347,7 +336,6 @@ export abstract class BaseFetchService<DS extends BaseDataSource, B extends IBlo
       ...this.projectService.bypassBlocks,
       ...this.getDatasourceBypassBlocks(),
     ]);
-    console.log('EEEEEE', cleanedBatchBlocks);
     await this.blockDispatcher.enqueueBlocks(
       cleanedBatchBlocks,
       this.getLatestBufferHeight(enqueuingBlocks, latestHeight)
-Original file line number
+Diff line change
@@ Expand Up @@
       }
       get batchSize(): number {
-        // TODO make this smarter
         return this.nodeConfig.batchSize;
       }
@@ Expand Down @@