deliver

type DeliverServer struct {
	DeliverSupport
	PolicyChecker
	Send func(msg proto.Message) error
}

type DeliverSupport interface {
	Recv() (*cb.Envelope, error)
	Context() context.Context
	CreateStatusReply(status cb.Status) proto.Message
	CreateBlockReply(block *cb.Block) proto.Message
}

type Handler interface {
	Handle(srv *DeliverServer) error
}

type PolicyChecker func(envelope *cb.Envelope, channelID string) error

type Support interface {
	// Sequence returns the current config sequence number, can be used to detect config changes
	Sequence() uint64

	// PolicyManager returns the current policy manager as specified by the chain configuration
	PolicyManager() policies.Manager

	// Reader returns the chain Reader for the chain
	Reader() blockledger.Reader

	// Errored returns a channel which closes when the backing consenter has errored
	Errored() <-chan struct{}
}

type SupportManager interface {
	GetChain(chainID string) (Support, bool)
}