demux-js
Options
All
  • Public
  • Public/Protected
  • All
Menu

Connects to a Postgres database using MassiveJS. This expects that the database is already migrated, including an _index_state table. Refer to the tests for more information.

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

Protected effects

effects: Effect[]

Protected lastProcessedBlockHash

lastProcessedBlockHash: string = ""

Protected lastProcessedBlockNumber

lastProcessedBlockNumber: number = 0

Protected massiveInstance

massiveInstance: any

Protected updaters

updaters: Updater[]

Methods

Protected handleActions

  • handleActions(state: any, block: Block, context: any, isReplay: boolean): Promise<void>

handleBlock

  • handleBlock(block: Block, isRollback: boolean, isFirstBlock: boolean, isReplay?: boolean): Promise<[boolean, number]>

Protected handleWithState

  • handleWithState(handle: function): Promise<void>

Protected loadIndexState

Protected rollbackTo

  • rollbackTo(blockNumber: number): Promise<void>

Protected runEffects

  • runEffects(state: any, block: Block, context: any): void

Protected runUpdaters

  • runUpdaters(state: any, block: Block, context: any): Promise<void>

Protected updateIndexState

  • updateIndexState(state: any, block: Block, isReplay: boolean): Promise<void>