websockets

package

v0.0.0-...-4da28bb Latest Latest Go to latest Published: Mar 19, 2024 License: MIT Imports: 8 Imported by: 0

Details

View Source

const (
	READSIZE  = 1024
	WRITESIZE = 1024
)

This section is empty.

This section is empty.

type Message struct {
	Author  string `json:"author"`
	Content string `json:"content"`
}

type Room struct {
	Members []string
	Lock    sync.Mutex
}

type WSServer struct {
	Upgrader    websocket.Upgrader
	Connections map[string]*websocket.Conn
	Rooms       map[string][]string
}

func NewWSServer() *WSServer

func (ws *WSServer) Broadcast(user, room string, msg []byte)

func (ws *WSServer) Close()

func (ws *WSServer) ConnectToRoom(c echo.Context) error

func (ws *WSServer) GetRoom(c echo.Context) error

getroom is a function that takes a websocket connection and handles it

func (ws *WSServer) GracefulDisconnect(room, user string, conn *websocket.Conn)

func (ws *WSServer) SendError(user string, err error)

SendError is a function that takes a websocket connection and sends an error message

func (ws *WSServer) SubscribeNewUser(room string) uuid.UUID

Subscribe returns a unique id for the client to use to subscribe to the websocket

func (ws *WSServer) Unsubscribe(id uuid.UUID, room string)

Unsubscribe removes the client from the list of connections

func (ws *WSServer) WSHandler(c echo.Context) error

WSHandler is a function that takes a websocket connection and handles it