MCPcopy Create free account
hub / github.com/subquery/subql / enqueueBlocks

Method enqueueBlocks

packages/node-core/src/indexer/fetch.service.ts:324–333  ·  view source on GitHub ↗
(enqueuingBlocks: (IBlock<FB> | number)[], latestHeight: number)

Source from the content-addressed store, hash-verified

322 }
323
324 private async enqueueBlocks(enqueuingBlocks: (IBlock<FB> | number)[], latestHeight: number): Promise<void> {
325 const cleanedBatchBlocks = filterBypassBlocks<FB>(enqueuingBlocks, [
326 ...this.projectService.bypassBlocks,
327 ...this.getDatasourceBypassBlocks(),
328 ]);
329 await this.blockDispatcher.enqueueBlocks(
330 cleanedBatchBlocks,
331 this.getLatestBufferHeight(enqueuingBlocks, latestHeight)
332 );
333 }
334
335 /**
336 *

Callers 2

fillNextBlockBufferMethod · 0.95
enqueueSequentialMethod · 0.95

Calls 4

getLatestBufferHeightMethod · 0.95
filterBypassBlocksFunction · 0.90
enqueueBlocksMethod · 0.65

Tested by

no test coverage detected