diff --git a/core-indexers/receiver-blocks/unit.test.ts b/core-indexers/receiver-blocks/unit.test.ts index 1d0c103b..0ed8140a 100644 --- a/core-indexers/receiver-blocks/unit.test.ts +++ b/core-indexers/receiver-blocks/unit.test.ts @@ -15,6 +15,9 @@ describe('Receiver Blocks Indexer Tests', () => { test('Try executing on a block', async () => { const localIndexer = new LocalIndexer(indexerConfig); - await localIndexer.executeOnBlock(123621232); + const context = localIndexer.getContext(); + + await localIndexer.executeOnBlock(100000000); + const receivers = context.db.Receivers.select({}) }); }); diff --git a/runner/src/local-indexer/local-indexer.ts b/runner/src/local-indexer/local-indexer.ts index 56b1ac7b..689d5c24 100644 --- a/runner/src/local-indexer/local-indexer.ts +++ b/runner/src/local-indexer/local-indexer.ts @@ -1,4 +1,4 @@ -import ContextBuilder from '../context-builder'; +import ContextBuilder, { type ContextObject } from '../context-builder'; import InMemoryDmlHandler from '../dml-handler/in-memory-dml-handler'; import IndexerConfig from '../indexer-config'; import { type LocalIndexerConfig } from '../indexer-config/indexer-config'; @@ -27,6 +27,10 @@ export default class LocalIndexer { this.lakeClient = new LakeClient(); } + getContext (): ContextObject { + return this.indexer.deps.contextBuilder.buildContext(0, []); + } + async executeOnBlock (blockHeight: number): Promise { // TODO: Cache Block data locally const block = await this.lakeClient.fetchBlock(blockHeight);