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"`
	ContentType int         `json:"-"`
}

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