websocket

Documentation

Index

• func EchoHandler(_ context.Context, s *Service, conn *Connection, svc string, cmd string, ...) error
• func LogHandler(_ context.Context, _ *Service, conn *Connection, svc string, cmd string, ...) error
• func OnMessage(ctx context.Context, s *Service, connID uuid.UUID, message *Message, ...) error
• func ReadSocketLoop(connID uuid.UUID, sock *websocket.Conn, onMessage func(m *Message) error, ...) error
• type Channel
• type ConnectEvent
• type Connection
  • func NewConnection(svc string, profile *user.Profile, socket *websocket.Conn, handler Handler) *Connection
  • func (c *Connection) Close() error
  • func (c *Connection) Read() ([]byte, error)
  • func (c *Connection) String() string
  • func (c *Connection) ToStatus() *Status
  • func (c *Connection) Username() string
  • func (c *Connection) Write(b []byte) error
• type Handler
• type Message
  • func NewMessage(userID *uuid.UUID, ch string, cmd string, param any) *Message
  • func (m *Message) String() string
• type OnlineUpdate
• type Service
  • func NewService(onOpen ConnectEvent, onClose ConnectEvent) *Service
  • func (s *Service) Broadcast(message *Message, logger util.Logger, except ...uuid.UUID) error
  • func (s *Service) ChannelList(params *filter.Params) []string
  • func (s *Service) Close()
  • func (s *Service) Count() int
  • func (s *Service) Disconnect(connID uuid.UUID, logger util.Logger) (bool, error)
  • func (s *Service) GetAllMembers(key string) []*Connection
  • func (s *Service) GetByID(id uuid.UUID, logger util.Logger) *Status
  • func (s *Service) GetChannel(ch string) *Channel
  • func (s *Service) GetConnection(id uuid.UUID) *Connection
  • func (s *Service) GetOnline(key string) []uuid.UUID
  • func (s *Service) Join(connID uuid.UUID, ch string, logger util.Logger) (bool, error)
  • func (s *Service) Leave(connID uuid.UUID, ch string, logger util.Logger) (bool, error)
  • func (s *Service) ReadLoop(ctx context.Context, connID uuid.UUID, logger util.Logger) error
  • func (s *Service) Register(profile *user.Profile, c *websocket.Conn, h Handler, logger util.Logger) (*Connection, error)
  • func (s *Service) RegisterTap(w http.ResponseWriter, r *http.Request, logger util.Logger) (uuid.UUID, error)
  • func (s *Service) RemoveTap(connID uuid.UUID, logger util.Logger)
  • func (s *Service) ReplaceHandlers(onOpen ConnectEvent, onClose ConnectEvent)
  • func (s *Service) Status() ([]string, []*Connection, []uuid.UUID)
  • func (s *Service) Terminal(ch string, logger util.Logger) func(_ string, b []byte) error
  • func (s *Service) Upgrade(ctx context.Context, w http.ResponseWriter, r *http.Request, channel string, ...) (uuid.UUID, error)
  • func (s *Service) UserList(params *filter.Params) Statuses
  • func (s *Service) WriteChannel(message *Message, logger util.Logger, except ...uuid.UUID) error
  • func (s *Service) WriteCloseRequest(connID uuid.UUID, logger util.Logger) error
  • func (s *Service) WriteMessage(connID uuid.UUID, message *Message, logger util.Logger) error
  • func (s *Service) WriteTap(message *Message, logger util.Logger)
• type Status
• type Statuses
• type UpdateMemberParams

Functions

func EchoHandler

func EchoHandler(_ context.Context, s *Service, conn *Connection, svc string, cmd string, param []byte, logger util.Logger) error

func LogHandler

func LogHandler(_ context.Context, _ *Service, conn *Connection, svc string, cmd string, param []byte, logger util.Logger) error

func OnMessage

func OnMessage(ctx context.Context, s *Service, connID uuid.UUID, message *Message, logger util.Logger) error

func ReadSocketLoop

func ReadSocketLoop(connID uuid.UUID, sock *websocket.Conn, onMessage func(m *Message) error, onDisconnect func() error, logger util.Logger) error

Types

type Channel

type Channel struct {
	Key          string      `json:"key"`
	ConnIDs      []uuid.UUID `json:"connIDs"`
	LastUpdate   time.Time   `json:"lastUpdate"`
	MessageCount int         `json:"messageCount"`
}

type ConnectEvent

type ConnectEvent func(s *Service, conn *Connection, logger util.Logger) error

type Connection

type Connection struct {
	ID       uuid.UUID     `json:"id"`
	Profile  *user.Profile `json:"profile,omitempty"`
	Svc      string        `json:"svc,omitempty"`
	ModelID  *uuid.UUID    `json:"modelID,omitempty"`
	Channels []string      `json:"channels,omitempty"`
	Started  time.Time     `json:"started,omitempty"`
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(svc string, profile *user.Profile, socket *websocket.Conn, handler Handler) *Connection

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) Read

func (c *Connection) Read() ([]byte, error)

func (*Connection) String

func (c *Connection) String() string

func (*Connection) ToStatus

func (c *Connection) ToStatus() *Status

func (*Connection) Username

func (c *Connection) Username() string

func (*Connection) Write

func (c *Connection) Write(b []byte) error

type Handler

type Handler func(ctx context.Context, s *Service, conn *Connection, svc string, cmd string, param []byte, logger util.Logger) error

type Message

type Message struct {
	From    *uuid.UUID      `json:"from,omitempty"`
	Channel string          `json:"channel,omitempty"`
	Cmd     string          `json:"cmd"`
	Param   json.RawMessage `json:"param"`
}

func NewMessage

func NewMessage(userID *uuid.UUID, ch string, cmd string, param any) *Message

func (*Message) String

func (m *Message) String() string

type OnlineUpdate

type OnlineUpdate struct {
	UserID    uuid.UUID `json:"userID"`
	Connected bool      `json:"connected"`
}

type Service

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

func NewService

func NewService(onOpen ConnectEvent, onClose ConnectEvent) *Service

func (*Service) Broadcast

func (s *Service) Broadcast(message *Message, logger util.Logger, except ...uuid.UUID) error

func (*Service) ChannelList

func (s *Service) ChannelList(params *filter.Params) []string

func (*Service) Close

func (s *Service) Close()

func (*Service) Count

func (s *Service) Count() int

func (*Service) Disconnect

func (s *Service) Disconnect(connID uuid.UUID, logger util.Logger) (bool, error)

func (*Service) GetAllMembers

func (s *Service) GetAllMembers(key string) []*Connection

func (*Service) GetByID

func (s *Service) GetByID(id uuid.UUID, logger util.Logger) *Status

func (*Service) GetChannel

func (s *Service) GetChannel(ch string) *Channel

func (*Service) GetConnection

func (s *Service) GetConnection(id uuid.UUID) *Connection

func (*Service) GetOnline

func (s *Service) GetOnline(key string) []uuid.UUID

func (*Service) Join

func (s *Service) Join(connID uuid.UUID, ch string, logger util.Logger) (bool, error)

func (*Service) Leave

func (s *Service) Leave(connID uuid.UUID, ch string, logger util.Logger) (bool, error)

func (*Service) ReadLoop

func (s *Service) ReadLoop(ctx context.Context, connID uuid.UUID, logger util.Logger) error

func (*Service) Register

func (s *Service) Register(profile *user.Profile, c *websocket.Conn, h Handler, logger util.Logger) (*Connection, error)

func (*Service) RegisterTap

func (s *Service) RegisterTap(w http.ResponseWriter, r *http.Request, logger util.Logger) (uuid.UUID, error)

func (*Service) RemoveTap

func (s *Service) RemoveTap(connID uuid.UUID, logger util.Logger)

func (*Service) ReplaceHandlers

func (s *Service) ReplaceHandlers(onOpen ConnectEvent, onClose ConnectEvent)

func (*Service) Status

func (s *Service) Status() ([]string, []*Connection, []uuid.UUID)

func (*Service) Terminal

func (s *Service) Terminal(ch string, logger util.Logger) func(_ string, b []byte) error

func (*Service) Upgrade

func (s *Service) Upgrade(
	ctx context.Context, w http.ResponseWriter, r *http.Request, channel string,
	profile *user.Profile, handler Handler, logger util.Logger,
) (uuid.UUID, error)

func (*Service) UserList

func (s *Service) UserList(params *filter.Params) Statuses

func (*Service) WriteChannel

func (s *Service) WriteChannel(message *Message, logger util.Logger, except ...uuid.UUID) error

func (*Service) WriteCloseRequest

func (s *Service) WriteCloseRequest(connID uuid.UUID, logger util.Logger) error

func (*Service) WriteMessage

func (s *Service) WriteMessage(connID uuid.UUID, message *Message, logger util.Logger) error

func (*Service) WriteTap

func (s *Service) WriteTap(message *Message, logger util.Logger)

type Status

type Status struct {
	ID       uuid.UUID `json:"id"`
	Username string    `json:"username"`
	Channels []string  `json:"channels"`
}

type Statuses

type Statuses = []*Status

type UpdateMemberParams

type UpdateMemberParams struct {
	ID   uuid.UUID `json:"id"`
	Role string    `json:"role"`
}