api

type Broadcaster interface {
	FromFeed(feed *event.Feed) error
	Broadcast(msg Message) error
	Register(conn Conn) bool
	Deregister(conn Conn) bool
}

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

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

type DutyRole string

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 int64 `json:"from"`
	// To is the ending index of the desired data
	To int64 `json:"to"`
	// Role is the duty type enum, optional as it's relevant for IBFT data
	Role DutyRole `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 OperatorsMessage struct {
	Data []storage.OperatorInformation `json:"data,omitempty"`
}

type QueryMessageHandler func(nm *NetworkMessage)

type ValidatorsMessage struct {
	Data []storage.ValidatorInformation `json:"data,omitempty"`
}

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

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