p2p

type Broadcaster[M any] interface {
	// Broadcast will broadcast the message to the whole validator set. The function should not be blocking.
	Broadcast(context.Context, M)
}

type Broadcasters[V types.Hashable[H], H types.Hash, A types.Addr] struct {
	ProposalBroadcaster  Broadcaster[*types.Proposal[V, H, A]]
	PrevoteBroadcaster   Broadcaster[*types.Prevote[H, A]]
	PrecommitBroadcaster Broadcaster[*types.Precommit[H, A]]
}

type Listener[M any] interface {
	// Listen would return consensus messages to Tendermint which are set by the validator set.
	Listen() <-chan M
}

type Listeners[V types.Hashable[H], H types.Hash, A types.Addr] struct {
	ProposalListener  Listener[*types.Proposal[V, H, A]]
	PrevoteListener   Listener[*types.Prevote[H, A]]
	PrecommitListener Listener[*types.Precommit[H, A]]
}

type P2P[V types.Hashable[H], H types.Hash, A types.Addr] interface {
	service.Service
	Broadcasters() Broadcasters[V, H, A]
	Listeners() Listeners[V, H, A]
	OnCommit(ctx context.Context, height types.Height, value V)
}