blockchain

type BlockCreationSubscriber interface {
	ReceiveBlock(*block.Block) error
}

type BlockMinter interface {
	// Mint creates a new block
	Mint(context.Context, crypto.PrivateKey) (*block.Block, error)
}

type BlockValidationCfg struct {
	// contains filtered or unexported fields
}

type BlockValidationOption func(*BlockValidationCfg)

type Blockchain interface {
	lifecycle.StartStopper

	// For exposing blockchain states
	// BlockHeaderByHeight return block header by height
	BlockHeaderByHeight(height uint64) (*block.Header, error)
	// BlockHeader return block header by hash
	BlockHeader(hash hash.Hash256) (*block.Header, error)
	// BlockFooterByHeight return block footer by height
	BlockFooterByHeight(height uint64) (*block.Footer, error)
	// ChainID returns the chain ID
	ChainID() uint32
	// EvmNetworkID returns the evm network ID
	EvmNetworkID() uint32
	// ChainAddress returns chain address on parent chain, the root chain return empty.
	ChainAddress() string
	// TipHash returns tip block's hash
	TipHash() hash.Hash256
	// TipHeight returns tip block's height
	TipHeight() uint64
	// Genesis returns the genesis
	Genesis() genesis.Genesis
	// Context returns current context
	Context(context.Context) (context.Context, error)
	// ContextAtHeight returns context at given height
	ContextAtHeight(context.Context, uint64) (context.Context, error)

	// For block operations
	// MintNewBlock creates a new block with given actions
	// Note: the coinbase transfer will be added to the given transfers when minting a new block
	MintNewBlock(time.Time, ...MintOption) (*block.Block, error)
	// CommitBlock validates and appends a block to the chain
	CommitBlock(blk *block.Block) error
	// ValidateBlock validates a new block before adding it to the blockchain
	ValidateBlock(*block.Block, ...BlockValidationOption) error

	// AddSubscriber make you listen to every single produced block
	AddSubscriber(BlockCreationSubscriber) error

	// RemoveSubscriber make you listen to every single produced block
	RemoveSubscriber(BlockCreationSubscriber) error
	//  Pause pauses the blockchain
	Pause(bool)
}

type Config struct {
	ChainDBPath            string `yaml:"chainDBPath"`
	TrieDBPatchFile        string `yaml:"trieDBPatchFile"`
	TrieDBPath             string `yaml:"trieDBPath"`
	StakingPatchDir        string `yaml:"stakingPatchDir"`
	IndexDBPath            string `yaml:"indexDBPath"`
	BloomfilterIndexDBPath string `yaml:"bloomfilterIndexDBPath"`
	CandidateIndexDBPath   string `yaml:"candidateIndexDBPath"`
	StakingIndexDBPath     string `yaml:"stakingIndexDBPath"`
	// deprecated
	SGDIndexDBPath             string           `yaml:"sgdIndexDBPath"`
	ContractStakingIndexDBPath string           `yaml:"contractStakingIndexDBPath"`
	BlobStoreDBPath            string           `yaml:"blobStoreDBPath"`
	BlobStoreRetentionDays     uint32           `yaml:"blobStoreRetentionDays"`
	HistoryIndexPath           string           `yaml:"historyIndexPath"`
	HistoryBlockRetention      uint64           `yaml:"historyBlockRetention"`
	ID                         uint32           `yaml:"id"`
	EVMNetworkID               uint32           `yaml:"evmNetworkID"`
	Address                    string           `yaml:"address"`
	ProducerPrivKey            string           `yaml:"producerPrivKey"`
	ProducerPrivKeySchema      string           `yaml:"producerPrivKeySchema"`
	ProducerPrivKeyRange       string           `yaml:"producerPrivKeyRange"`
	SignatureScheme            []string         `yaml:"signatureScheme"`
	EmptyGenesis               bool             `yaml:"emptyGenesis"`
	GravityChainDB             db.Config        `yaml:"gravityChainDB"`
	Committee                  committee.Config `yaml:"committee"`

	// EnableTrielessStateDB enables trieless state db (deprecated)
	EnableTrielessStateDB bool `yaml:"enableTrielessStateDB"`
	// EnableStateDBCaching enables cachedStateDBOption
	EnableStateDBCaching bool `yaml:"enableStateDBCaching"`
	// EnableArchiveMode is only meaningful when EnableTrielessStateDB is false
	// Deprecated: HistoryIndexPath is used to store the archived state
	EnableArchiveMode bool `yaml:"enableArchiveMode"`
	// EnableAsyncIndexWrite enables writing the block actions' and receipts' index asynchronously
	EnableAsyncIndexWrite bool `yaml:"enableAsyncIndexWrite"`
	// deprecated
	EnableSystemLogIndexer bool `yaml:"enableSystemLog"`
	// EnableStakingProtocol enables staking protocol
	EnableStakingProtocol bool `yaml:"enableStakingProtocol"`
	// EnableStakingIndexer enables staking indexer
	EnableStakingIndexer bool `yaml:"enableStakingIndexer"`
	// AllowedBlockGasResidue is the amount of gas remained when block producer could stop processing more actions
	AllowedBlockGasResidue uint64 `yaml:"allowedBlockGasResidue"`
	// MaxCacheSize is the max number of blocks that will be put into an LRU cache. 0 means disabled
	MaxCacheSize int `yaml:"maxCacheSize"`
	// PollInitialCandidatesInterval is the config for committee init db
	PollInitialCandidatesInterval time.Duration `yaml:"pollInitialCandidatesInterval"`
	// StateDBCacheSize is the max size of statedb LRU cache
	StateDBCacheSize int `yaml:"stateDBCacheSize"`
	// WorkingSetCacheSize is the max size of workingset cache in state factory
	WorkingSetCacheSize uint64 `yaml:"workingSetCacheSize"`
	// StreamingBlockBufferSize
	StreamingBlockBufferSize uint64 `yaml:"streamingBlockBufferSize"`
	// PersistStakingPatchBlock is the block to persist staking patch
	PersistStakingPatchBlock uint64 `yaml:"persistStakingPatchBlock"`
	// FixAliasForNonStopHeight is the height to fix candidate alias for a non-stopping node
	FixAliasForNonStopHeight uint64 `yaml:"fixAliasForNonStopHeight"`
	// FactoryDBType is the type of factory db
	FactoryDBType string `yaml:"factoryDBType"`
	// MintTimeout is the timeout for minting
	MintTimeout time.Duration `yaml:"-"`
}

type MintOption func(*MintOptions)

type MintOptions struct {
	ProducerPrivateKey crypto.PrivateKey
}

type Option func(*blockchain) error

type PubSubManager interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	AddBlockListener(BlockCreationSubscriber) error
	RemoveBlockListener(BlockCreationSubscriber) error
	SendBlockToSubscribers(*block.Block)
}