syncer

type BlockHash struct {
	Height int
	Hash   string
}

type Fetcher interface {
	FetchAccount(address common.Address, hash common.HashHeight, prevCnt uint64)
	FetchSnapshot(hash common.HashHeight, prevCnt uint64)
	Fetch(request face.FetchRequest)
}

type Handlers interface {
	RegisterHandler(MsgHandler)
	UnRegisterHandler(MsgHandler)
}

type MsgHandler interface {
	Handle(common.NetMsgType, []byte, p2p.Peer)
	Types() []common.NetMsgType
	Id() string
}

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

type Sender interface {
	// when new block create
	BroadcastAccountBlocks(common.Address, []*common.AccountStateBlock) error
	BroadcastSnapshotBlocks([]*common.SnapshotBlock) error

	// when fetch block message be arrived
	SendAccountBlocks(common.Address, []*common.AccountStateBlock, p2p.Peer) error
	SendSnapshotBlocks([]*common.SnapshotBlock, p2p.Peer) error

	SendAccountHashes(common.Address, []common.HashHeight, p2p.Peer) error
	SendSnapshotHashes([]common.HashHeight, p2p.Peer) error

	RequestAccountHash(common.Address, common.HashHeight, uint64) error
	RequestSnapshotHash(common.HashHeight, uint64) error
	RequestAccountBlocks(common.Address, []common.HashHeight) error
	RequestSnapshotBlocks([]common.HashHeight) error
}

type Syncer interface {
	Fetcher() Fetcher
	Sender() Sender
	Handlers() Handlers
	DefaultHandler() MsgHandler
	Init(reader face.ChainReader, writer face.PoolWriter)
	Start()
	Stop()
	Done() bool
}