api

type Broadcaster interface {
	FromFeed(logger *zap.Logger, feed *event.Feed) error
	Broadcast(msg Message) error
	Register(conn broadcasted) bool
	Deregister(conn broadcasted) bool
}

type Conn interface {
	ID() string
	ReadNext() []byte
	Send(msg []byte)
	WriteLoop(logger *zap.Logger)
	ReadLoop(logger *zap.Logger)
	Close() error
	RemoteAddr() net.Addr
}

type Connection interface {
	Close() error
	RemoteAddr() net.Addr
}

type Message struct {
	// Type is the type of message
	Type MessageType `json:"type"`
	// Filter
	Filter MessageFilter `json:"filter"`
	// Values holds the results, optional as it's relevant for response
	Data interface{} `json:"data,omitempty"`
}

type MessageFilter struct {
	// From is the starting index of the desired data
	From uint64 `json:"from"`
	// To is the ending index of the desired data
	To uint64 `json:"to"`
	// Role is the duty type, optional as it's relevant for IBFT data
	Role string `json:"role,omitempty"`
	// PublicKey is optional, used for fetching decided messages or information about specific validator/operator
	PublicKey string `json:"publicKey,omitempty"`
}

type MessageType string

type NetworkMessage struct {
	Msg  Message
	Err  error
	Conn Connection
}

type QueryMessageHandler func(logger *zap.Logger, nm *NetworkMessage)

type SignedMessageAPI struct {
	Signature types.Signature
	Signers   []types.OperatorID
	Message   specqbft.Message

	FullData *types.ConsensusData
}

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

type WebSocketServer interface {
	Start(logger *zap.Logger, addr string) error
	BroadcastFeed() *event.Feed
	UseQueryHandler(handler QueryMessageHandler)
}