Method init

packages/node-core/src/indexer/fetch.service.ts:74–112

(startHeight: number)

  }

  async init(startHeight: number): Promise<void> {
    const interval = await this.blockchainSevice.getChainInterval();

    await Promise.all([this.getFinalizedBlockHead(), this.getBestBlockHead()]);

    const chainLatestHeight = this.latestHeight();
    if (startHeight > chainLatestHeight) {
      // This is at init stage, lastProcessedHeight should be always - 1 from the startHeight in this case
      // this is reverse calculated from projectService.nextProcessHeight()
      // Alternative, we can expose async function getLastProcessedHeight() to ensure accuracy.
      if (startHeight - 1 === chainLatestHeight) {
        logger.warn(
          `Project last processed height is same as current chain height (${chainLatestHeight}). Please ensure the RPC endpoint provider is behaving correctly.`
        );
      } else {
        throw new Error(
          `The startBlock of dataSources in your project manifest (${startHeight}) is higher than the current chain height (${chainLatestHeight}). Please adjust your startBlock to be less that the current chain height.`
        );
      }
    }

    this.schedulerRegistry.addInterval(
      'getFinalizedBlockHead',
      setInterval(() => void this.getFinalizedBlockHead(), interval)
    );
    this.schedulerRegistry.addInterval(
      'getBestBlockHead',
      setInterval(() => void this.getBestBlockHead(), interval)
    );

    await this.dictionaryService.initDictionaries();
    // Update all dictionaries execute before find one usable dictionary
    this.updateDictionary();
    // Find one usable dictionary at start

    await this.blockDispatcher.init(this.resetForNewDs.bind(this));

    void this.startLoop(startHeight);
  }

  private updateDictionary(): void {
    return this.dictionaryService.buildDictionaryEntryMap(this.projectService.getDataSourcesMap());