Class BlockchainService

packages/node/src/blockchain.service.ts:47–196

@Injectable()
export class BlockchainService
  implements
    IBlockchainService<
      SubstrateDatasource,
      SubstrateCustomDatasource<
        string,
        SubstrateMapping<SubstrateCustomHandler>
      >,
      SubqueryProject,
      ApiAt,
      LightBlockContent,
      BlockContent,
      IIndexerWorker
    >
{
  constructor(
    @Inject('APIService') private apiService: ApiService,
    @Inject('RuntimeService') private runtimeService: RuntimeService,
  ) {}

  isCustomDs = isCustomDs;
  isRuntimeDs = isRuntimeDs;
  blockHandlerKind = SubstrateHandlerKind.Block;
  packageVersion = packageVersion;

  @mainThreadOnly()
  async fetchBlocks(
    blockNums: number[],
  ): Promise<IBlock<BlockContent>[] | IBlock<LightBlockContent>[]> {
    const specChanged = await this.runtimeService.specChanged(
      blockNums[blockNums.length - 1],
    );

    // If specVersion not changed, a known overallSpecVer will be pass in
    // Otherwise use api to fetch runtimes
    return this.apiService.fetchBlocks(
      blockNums,
      specChanged ? undefined : this.runtimeService.parentSpecVersion,
    );
  }

  async fetchBlockWorker(
    worker: IIndexerWorker,
    height: number,
    context: { workers: IIndexerWorker[] },
  ): Promise<Header> {
    // get SpecVersion from main runtime service
    const { blockSpecVersion, syncedDictionary } =
      await this.runtimeService.getSpecVersion(height);

    // if main runtime specVersion has been updated, then sync with all workers specVersion map, and lastFinalizedBlock
    if (syncedDictionary) {
      context.workers.map((w) =>
        w.syncRuntimeService(
          this.runtimeService.specVersionMap,
          this.runtimeService.latestFinalizedHeight,
        ),
      );