ws

type WebSocketChannels interface {
	GetChannels(topic string) (senderChannel chan<- interface{}, broadcastChannel chan<- interface{}, receiverChannel <-chan *WebSocketCommandMessageOrError)
	SendReply(message interface{})
}

type WebSocketCommandMessage struct {
	Type        string `json:"type,omitempty"`
	Topic       string `json:"topic,omitempty"`  // synonym for "topic" - from a time when we let you configure the topic separate to the stream name
	Stream      string `json:"stream,omitempty"` // name of the event stream
	Message     string `json:"message,omitempty"`
	BatchNumber int64  `json:"batchNumber,omitempty"`
}

type WebSocketCommandMessageOrError struct {
	Msg *WebSocketCommandMessage
	Err error
}

type WebSocketServer interface {
	WebSocketChannels
	Handler(w http.ResponseWriter, r *http.Request)
	Close()
}