Class TonRedisBlockStorageV2

Implements

TonBlockStorageV2

Index

Constructors

Methods

clean getLastMasterchainBlock getUnprocessedShardchainBlock insertMasterchainBlock insertShardchainBlocks setShardchainBlockProcessed

Constructors

constructor

new TonRedisBlockStorageV2(conn: string): TonRedisBlockStorageV2
Parameters
- conn: string
Returns TonRedisBlockStorageV2
- Defined in src/TonSubscriberV2/TonRedisBlockStorageV2.ts:9

Methods

clean

clean(): Promise<void>
Clean up the hashtables.

Returns Promise<void>
Implementation of TonBlockStorageV2.clean
- Defined in src/TonSubscriberV2/TonRedisBlockStorageV2.ts:106

getLastMasterchainBlock

getLastMasterchainBlock(): Promise<null | number>
Get the last inserted masterchain block from the masterchain hashtable.

Returns Promise<null | number>
Implementation of TonBlockStorageV2.getLastMasterchainBlock
- Defined in src/TonSubscriberV2/TonRedisBlockStorageV2.ts:42

getUnprocessedShardchainBlock

getUnprocessedShardchainBlock(): Promise<
null
| { seqno: number; shard: string; workchain: number },
>
Get the last unprocessed shardchain block from the shardchains hashtable.

Returns Promise<null | { seqno: number; shard: string; workchain: number }>
Implementation of TonBlockStorageV2.getUnprocessedShardchainBlock
- Defined in src/TonSubscriberV2/TonRedisBlockStorageV2.ts:53

insertMasterchainBlock

insertMasterchainBlock(seqno: number): Promise<void>
Insert a new masterchain block into the masterchain hashtable.
Parameters
- seqno: number
Returns Promise<void>
Implementation of TonBlockStorageV2.insertMasterchainBlock
- Defined in src/TonSubscriberV2/TonRedisBlockStorageV2.ts:32

insertShardchainBlocks

insertShardchainBlocks(
    shards: {
        "@type": "ton.blockIdExt";
        file_hash: string;
        root_hash: string;
        seqno: number;
        shard: string;
        workchain: number;
    }[],
): Promise<void>
Insert new shardchain blocks into the shardchains hashtable.
Parameters
- shards: {
      "@type": "ton.blockIdExt";
      file_hash: string;
      root_hash: string;
      seqno: number;
      shard: string;
      workchain: number;
  }[]
Returns Promise<void>
Implementation of TonBlockStorageV2.insertShardchainBlocks
- Defined in src/TonSubscriberV2/TonRedisBlockStorageV2.ts:17

setShardchainBlockProcessed

setShardchainBlockProcessed(
    workchain: number,
    shard: string,
    seqno: number,
    prevShardBlocks: {
        "@type": "ton.blockIdExt";
        file_hash: string;
        root_hash: string;
        seqno: number;
        shard: string;
        workchain: number;
    }[],
): Promise<void>
Process a shardchain block in the sharchains hashtable.
Parameters
- workchain: number
- shard: string
- seqno: number
- prevShardBlocks: {
      "@type": "ton.blockIdExt";
      file_hash: string;
      root_hash: string;
      seqno: number;
      shard: string;
      workchain: number;
  }[]
Returns Promise<void>
Implementation of TonBlockStorageV2.setShardchainBlockProcessed
- Defined in src/TonSubscriberV2/TonRedisBlockStorageV2.ts:90