walker

type BlockMetadata struct {
	MedianTime uint64  // The median block time in seconds since UNIX epoch (Jan 1 1970 GMT)
	Difficulty float64 // The difficulty
	ChainWork  string  // Expected number of hashes required to produce the chain up to this block (hex)
	BlockSize  int     // The size of the block in bytes
}

type BlockOrUndo struct {
	LastProcessedBlock string          // the `LastProcessedBlock` hash to resume from (always)
	Height             int64           // the new block height (after this message is processed)
	Block              *ChainBlock     // either the next block in the chain
	Undo               *UndoForkBlocks // or an undo event (roll back blocks on a fork)
	Idle               bool            // or "idle" meaning we're at the tip of the blockchain
}

type ChainBlock struct {
	Hash     string        // hash of the block
	Height   int64         // height of the block
	Block    doge.Block    // decoded block header and transactions
	Metadata BlockMetadata // block metadata from Core Node
}

type UndoForkBlocks struct {
	LastValidHeight int64         // undo all blocks greater than this height
	LastValidHash   string        // hash of the last on-chain block that's still valid
	UndoBlocks      []string      // hashes of blocks to be undone
	FullBlocks      []*ChainBlock // optional: present if FullUndoBlocks is true in WalkerOptions
}

type WalkerOptions struct {
	Chain              *doge.ChainParams           // chain parameters, e.g. doge.DogeMainNetChain
	LastProcessedBlock string                      // last processed block hash to begin walking from (hex)
	Client             spec.Blockchain             // from NewCoreRPCClient()
	ChainEvents        <-chan spec.BlockchainEvent // from TipChaser()
	FullUndoBlocks     bool                        // fully decode blocks in UndoForkBlocks (or just hash and height)
	BufferBlocks       int                         // number of blocks to decode ahead of the consumer (channel size, default 10)
}