net

type AccountblockCallback = func(addr types.Address, block *ledger.AccountBlock, source types.BlockSource)

type Broadcaster interface {
	BroadcastSnapshotBlock(block *ledger.SnapshotBlock)
	BroadcastSnapshotBlocks(blocks []*ledger.SnapshotBlock)
	BroadcastAccountBlock(block *ledger.AccountBlock)
	BroadcastAccountBlocks(blocks []*ledger.AccountBlock)
}

type Chain interface {
	// the second return value mean chunk befor/after file
	GetSubLedgerByHeight(start, count uint64, forward bool) ([]*ledger.CompressedFileMeta, [][2]uint64)
	GetSubLedgerByHash(origin *types.Hash, count uint64, forward bool) ([]*ledger.CompressedFileMeta, [][2]uint64, error)

	// query chunk
	GetConfirmSubLedger(start, end uint64) ([]*ledger.SnapshotBlock, map[types.Address][]*ledger.AccountBlock, error)

	// single
	GetSnapshotBlockByHeight(height uint64) (*ledger.SnapshotBlock, error)
	GetSnapshotBlockByHash(hash *types.Hash) (*ledger.SnapshotBlock, error)
	// batcher
	GetSnapshotBlocksByHash(origin *types.Hash, count uint64, forward, content bool) ([]*ledger.SnapshotBlock, error)
	GetSnapshotBlocksByHeight(height, count uint64, forward, content bool) ([]*ledger.SnapshotBlock, error)

	// single
	GetAccountBlockByHash(blockHash *types.Hash) (*ledger.AccountBlock, error)
	GetAccountBlockByHeight(addr *types.Address, height uint64) (*ledger.AccountBlock, error)

	// batcher
	GetAccountBlocksByHash(addr types.Address, origin *types.Hash, count uint64, forward bool) ([]*ledger.AccountBlock, error)
	GetAccountBlocksByHeight(addr types.Address, start, count uint64, forward bool) ([]*ledger.AccountBlock, error)

	GetLatestSnapshotBlock() *ledger.SnapshotBlock
	GetGenesisSnapshotBlock() *ledger.SnapshotBlock

	Compressor() *compress.Compressor
}

type Config struct {
	Single bool // for test

	Port     uint16
	Chain    Chain
	Verifier Verifier

	// for topo
	Topology   []string
	Topic      string
	Interval   int64 // second
	TopoEnable bool
}

type Fetcher interface {
	FetchSnapshotBlocks(start types.Hash, count uint64)

	// address is optional
	FetchAccountBlocks(start types.Hash, count uint64, address *types.Address)

	// add snapshot height
	FetchAccountBlocksWithHeight(start types.Hash, count uint64, address *types.Address, sHeight uint64)
}

type Filter interface {
	// contains filtered or unexported methods
}

type MsgHandler interface {
	ID() string
	Cmds() []ViteCmd
	Handle(msg *p2p.Msg, sender Peer) error
}

type MsgIder interface {
	MsgID() uint64
}

type Net interface {
	Syncer
	Fetcher
	Broadcaster
	Receiver
	Protocols() []*p2p.Protocol
	Start(svr p2p.Server) error
	Stop()
	Info() *NodeInfo
	Tasks() []*Task
	AddPlugin(plugin p2p.Plugin)
}

type NodeInfo struct {
	PeerCount int         `json:"peerCount"`
	Peers     []*PeerInfo `json:"peers"`
	Latency   []int64     `json:"latency"` // [0,1,12,24]

}

type Peer interface {
	RemoteAddr() *net2.TCPAddr
	FileAddress() *net2.TCPAddr
	SetHead(head types.Hash, height uint64)
	SeeBlock(hash types.Hash)
	SendSnapshotBlocks(bs []*ledger.SnapshotBlock, msgId uint64) (err error)
	SendAccountBlocks(bs []*ledger.AccountBlock, msgId uint64) (err error)
	SendNewSnapshotBlock(b *ledger.SnapshotBlock) (err error)
	SendNewAccountBlock(b *ledger.AccountBlock) (err error)
	Send(code ViteCmd, msgId uint64, payload p2p.Serializable) (err error)
	Report(err error)
	ID() string
	Height() uint64
	Disconnect(reason p2p.DiscReason)
}

type PeerInfo struct {
	ID     string `json:"id"`
	Addr   string `json:"addr"`
	Head   string `json:"head"`
	Height uint64 `json:"height"`
	// MsgReceived        uint64            `json:"msgReceived"`
	// MsgHandled         uint64            `json:"msgHandled"`
	// MsgSend            uint64            `json:"msgSend"`
	// MsgDiscarded       uint64            `json:"msgDiscarded"`
	// MsgReceivedDetail  map[string]uint64 `json:"msgReceived"`
	// MsgDiscardedDetail map[string]uint64 `json:"msgDiscarded"`
	// MsgHandledDetail   map[string]uint64 `json:"msgHandledDetail"`
	// MsgSendDetail      map[string]uint64 `json:"msgSendDetail"`
	Created string `json:"created"`
}

type Receiver interface {
	ReceiveSnapshotBlock(block *ledger.SnapshotBlock, sender Peer) (err error)
	ReceiveAccountBlock(block *ledger.AccountBlock, sender Peer) (err error)

	ReceiveSnapshotBlocks(blocks []*ledger.SnapshotBlock, sender Peer) (err error)
	ReceiveAccountBlocks(blocks []*ledger.AccountBlock, sender Peer) (err error)

	ReceiveNewSnapshotBlock(block *ledger.SnapshotBlock, sender Peer) (err error)
	ReceiveNewAccountBlock(block *ledger.AccountBlock, sender Peer) (err error)

	SubscribeAccountBlock(fn AccountblockCallback) (subId int)
	// if subId is 0, then ignore
	UnsubscribeAccountBlock(subId int)

	// return the subId, use to unsubscibe
	// subId is always larger than 0
	SubscribeSnapshotBlock(fn SnapshotBlockCallback) (subId int)
	// if subId is 0, then ignore
	UnsubscribeSnapshotBlock(subId int)
	// contains filtered or unexported methods
}

type Request interface {
	Handle(ctx context, msg *p2p.Msg, peer Peer)
	ID() uint64
	SetID(id uint64)
	Run(ctx context)
	Done(ctx context)
	Catch(err error)
	Expired() bool
	State() reqState
	Req() Request
	Band() (from, to uint64)
	SetBand(from, to uint64)
	SetPeer(peer Peer)
	Peer() Peer
}

type SnapshotBlockCallback = func(block *ledger.SnapshotBlock, source types.BlockSource)

type Subscriber interface {
	// return the subId, use to unsubscibe
	// subId is always larger than 0
	SubscribeAccountBlock(fn AccountblockCallback) (subId int)
	// if subId is 0, then ignore
	UnsubscribeAccountBlock(subId int)

	// return the subId, use to unsubscibe
	// subId is always larger than 0
	SubscribeSnapshotBlock(fn SnapshotBlockCallback) (subId int)
	// if subId is 0, then ignore
	UnsubscribeSnapshotBlock(subId int)

	// return the subId, use to unsubscibe
	// subId is always larger than 0
	SubscribeSyncStatus(fn SyncStateCallback) (subId int)
	// if subId is 0, then ignore
	UnsubscribeSyncStatus(subId int)

	SyncState() SyncState
}

type SyncState uint

type SyncStateCallback = func(SyncState)

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

type SyncStatus struct {
	From     uint64
	To       uint64
	Current  uint64
	Received uint64
	State    SyncState
}

type Syncer interface {
	Status() *SyncStatus
	SubscribeSyncStatus(fn SyncStateCallback) (subId int)
	UnsubscribeSyncStatus(subId int)
	SyncState() SyncState
}

type Task struct {
	Msg    string `json:"Msg"`
	Sender string `json:"Sender"`
}

type Verifier interface {
	//VerifyforP2P(block *ledger.AccountBlock) bool
	VerifyNetSb(block *ledger.SnapshotBlock) error
	VerifyNetAb(block *ledger.AccountBlock) error
}

type ViteCmd p2p.Cmd