ws

Documentation

Index

• Constants
• Variables
• type Data
• type JWTValidationResponse
• type Message
• type MessageConnectRequest
• type MessageNewDataRequest
• type MessageNewDataResponse
• type MessageSetLeaderRequest
• type MessageSetLeaderResponse
• type MessageUserConnectedResponse
• type MessageUserDisconnectedResponse
• type MessageUserFailedToConnectResponse
• type WebSocketHandler
  • func NewWebSocketHandler(clientsStorage uStorage.Storage, roomStorage rStorage.Storage, ...) *WebSocketHandler
  • func (ws *WebSocketHandler) Handle(w http.ResponseWriter, r *http.Request)

Constants

const (
	EventConnect             = "connect"
	EventUserConnected       = "userConnected"
	EventUserDisconnected    = "userDisconnected"
	EventSetLeader           = "setLeader"
	EventUserFailedToConnect = "userFailedToConnect"
	EventNewData             = "newData"
)

Variables

var (
	ErrInvalidMessage = errors.New("invalid message")
	ErrValidatingJWT  = errors.New("failed to validate jwt")
)

Types

type Data

type Data struct {
	Elements string `json:"elements"`
	AppState string `json:"app_state"`
}

type JWTValidationResponse

type JWTValidationResponse struct {
	ID int `json:"id"`
}

type Message

type Message struct {
	Event string `json:"event"`
}

type MessageConnectRequest

type MessageConnectRequest struct {
	Message
	BoardID string `json:"board_id"`
	Jwt     string `json:"jwt"`
}

type MessageNewDataRequest

type MessageNewDataRequest struct {
	Message
	BoardID string `json:"board_id"`
	Jwt     string `json:"jwt"`
	Data    Data   `json:"data"`
}

type MessageNewDataResponse

type MessageNewDataResponse struct {
	Message
	BoardID string `json:"board_id"`
	Data    Data   `json:"data"`
}

type MessageSetLeaderRequest

type MessageSetLeaderRequest struct {
	Message
	BoardID string `json:"board_id"`
	Jwt     string `json:"jwt"`
}

type MessageSetLeaderResponse

type MessageSetLeaderResponse struct {
	Message
	BoardID string `json:"board_id"`
	UserID  string `json:"user_id"`
}

type MessageUserConnectedResponse

type MessageUserConnectedResponse struct {
	Message
	BoardID  string   `json:"board_id"`
	UserIDs  []string `json:"user_ids"`
	LeaderID string   `json:"leader_id"`
}

type MessageUserDisconnectedResponse

type MessageUserDisconnectedResponse struct {
	Message
	BoardID  string   `json:"board_id"`
	UserIDs  []string `json:"user_ids"`
	LeaderID string   `json:"leader_id"`
}

type MessageUserFailedToConnectResponse

type MessageUserFailedToConnectResponse struct {
	Message
	UserID string `json:"user_id"`
	Reason string `json:"reason"`
}

type WebSocketHandler

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

func NewWebSocketHandler

func NewWebSocketHandler(
	clientsStorage uStorage.Storage,
	roomStorage rStorage.Storage,
	jwtHeaderName string,
	jwtValidationURL string,
	boardValidationURL string,
	logger *zap.Logger,
) *WebSocketHandler

func (*WebSocketHandler) Handle

func (ws *WebSocketHandler) Handle(w http.ResponseWriter, r *http.Request)