websocket

type Client struct {
	ID int
	// contains filtered or unexported fields
}

type Listener struct {
	Event    string
	Message  []byte
	ClientID int
}

type Message struct {
	Type    string      `json:"type"`
	Action  string      `json:"action"`
	Message interface{} `json:"message"`
	From    *int        `json:"from,omitempty"`
	To      []int       `json:"to,omitempty"`
}

type WebSocket interface {
	InitHandler(api *gin.RouterGroup)
	SendMessage(ctx context.Context, m Message) error
	RegisterClientListener() <-chan Listener
	ShutDown()
}