Calculate block time interval from recent block headers (#355)

* Calculate block time interval from recent block headers

* Update changelog

* Handle insufficient data

* Fix build issue

* Update changelogs from syncing deps

Author: stwiname

packages/common-cosmos/CHANGELOG.md

@@ -5,6 +5,8 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
+### Changed
+- Updated `@subql/common` (#356)
 
 ## [5.5.0] - 2025-08-26
 ### Changed

packages/node/CHANGELOG.md

@@ -5,6 +5,9 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
+### Changed
+- Calculate block interval from block data rather than hard coded value (#355)
+- Updated `@subql/node-core` (#356)
 
 ## [5.3.0] - 2025-08-26
 ### Changed

packages/node/src/blockchain.service.ts

@@ -12,6 +12,7 @@ import {
 } from '@subql/common-cosmos';
 import {
   DatasourceParams,
+  getLogger,
   Header,
   IBlock,
   IBlockchainService,
@@ -27,13 +28,10 @@ import { SubqueryProject } from './configure/SubqueryProject';
 import { ApiService, CosmosSafeClient } from './indexer/api.service';
 import { BlockContent, getBlockSize } from './indexer/types';
 import { IIndexerWorker } from './indexer/worker/worker';
-import {
-  cosmosBlockToHeader,
-  getBlockTimestamp,
-  calcInterval,
-} from './utils/cosmos';
+import { cosmosBlockToHeader, getBlockTimestamp } from './utils/cosmos';
 
 const { version: packageVersion } = require('../package.json');
+const logger = getLogger('blockchain-service');
 
 const BLOCK_TIME_VARIANCE = 5000; //ms
 const INTERVAL_PERCENT = 0.9;
@@ -95,8 +93,13 @@ export class BlockchainService
 
   // eslint-disable-next-line @typescript-eslint/require-await
   async getChainInterval(): Promise<number> {
-    const chainInterval =
-      calcInterval(this.apiService.unsafeApi) * INTERVAL_PERCENT;
+    const interval = await this.apiService.unsafeApi
+      .getBlockInterval()
+      .catch((e) => {
+        logger.error(e, 'Failed to get chain interval');
+        return BLOCK_TIME_VARIANCE;
+      });
+    const chainInterval = interval * INTERVAL_PERCENT;
 
     return Math.min(BLOCK_TIME_VARIANCE, chainInterval);
   }

packages/node/src/indexer/api.service.test.ts

@@ -100,6 +100,19 @@ describe('ApiService', () => {
       tmpPath = await makeTempDir();
     });
 
+    it('can get the block time interval', async () => {
+      const endpoint = 'https://dymension.api.onfinality.io/tendermint/public';
+      const chainId = 'dymension_1100-1';
+
+      await prepareApiService(endpoint, chainId, tmpPath);
+      const interval = await apiService.api.getBlockInterval();
+
+      console.log('INTERVAL', interval);
+
+      expect(interval).toBeGreaterThan(0);
+      expect(interval).toBeLessThan(20_000); // 20 seconds
+    });
+
     it('Falls back on rpc if kyve fails', async () => {
       const endpoint = 'https://rpc.mainnet.archway.io:443';
       const chainId = 'archway-1';

packages/node/src/indexer/api.service.ts

@@ -6,7 +6,12 @@ import { CosmWasmClient, IndexedTx } from '@cosmjs/cosmwasm-stargate';
 import { toHex } from '@cosmjs/encoding';
 import { GeneratedType, Registry } from '@cosmjs/proto-signing';
 import { defaultRegistryTypes, SearchTxQuery } from '@cosmjs/stargate';
-import { CometClient } from '@cosmjs/tendermint-rpc';
+import {
+  Comet38Client,
+  CometClient,
+  Tendermint34Client,
+  Tendermint37Client,
+} from '@cosmjs/tendermint-rpc';
 import { Injectable, OnApplicationShutdown } from '@nestjs/common';
 import { EventEmitter2 } from '@nestjs/event-emitter';
 import { CosmosProjectNetConfig } from '@subql/common-cosmos';
@@ -203,6 +208,25 @@ export class CosmosClient extends CosmWasmClient {
     super(_cometClient as any);
   }
 
+  async getBlockInterval(): Promise<number> {
+    const { blockMetas } = await this._cometClient.blockchain();
+
+    if (!blockMetas || blockMetas.length < 2) {
+      throw new Error(
+        `Insufficient block headers to calculate interval: ${
+          blockMetas?.length ?? 0
+        } headers available`,
+      );
+    }
+
+    const timestamps = blockMetas.map((h) => h.header.time.getTime());
+
+    return Math.abs(
+      timestamps.slice(1).reduce((sum, v, i) => sum + (v - timestamps[i]), 0) /
+        (timestamps.length - 1),
+    );
+  }
+
   // eslint-disable-next-line @typescript-eslint/require-await
   async blockInfo(height?: number): Promise<BlockResponse> {
     return this._cometClient.block(height);

packages/node/src/indexer/worker/worker.service.ts

@@ -57,8 +57,8 @@ export class WorkerService extends BaseWorkerService<
     return block;
   }
 
-  protected toBlockResponse(block: BlockContent): FetchBlockResponse {
-    return cosmosBlockToHeader(block.block.header);
+  protected toBlockResponse(block: IBlock<BlockContent>): FetchBlockResponse {
+    return block.getHeader();
   }
 
   protected async processFetchedBlock(

packages/node/src/utils/cosmos.ts

@@ -670,8 +670,3 @@ export class LazyBlockContent implements BlockContent {
     return this._wrappedFinalizedBlockEvents;
   }
 }
-
-export function calcInterval(api: CosmosClient): number {
-  // TODO find a way to get this from the blockchain
-  return 6000;
-}

packages/types/CHANGELOG.md

@@ -5,6 +5,8 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
+### Changed
+- Updated `@subql/types-core` (#356)
 
 ## [4.2.0] - 2025-08-26
 ### Changed