ws

package

Go to main page

Versions in this module

v0

v0.5.0

Apr 6, 2026

Changes in this version

type Client

+ ClientIP string

+ WebAccessUser any

type PadMessageHandler

+ func (p *PadMessageHandler) BroadcastSocketEvent(event string, payload interface{})

+ func (p *PadMessageHandler) BroadcastSystemChatToRoom(padId string, message map[string]any)

v0.0.5

Feb 24, 2026

Changes in this version

type AdminMessageHandler

+ App *fiber.App

type PadMessageHandler

+ func (p *PadMessageHandler) GetPadUsers(padId string) []PadUserInfo

+ func (p *PadMessageHandler) GetPadUsersCount(padId string) int

+ type PadUserInfo struct

+ AuthorId string

+ ColorId string

+ Name string

+ type SessionStat struct

+ ActivePads int

+ ActiveUsers int

type SessionStore

+ func (s *SessionStore) GetPadSessions(padId string) []PadUserInfo

+ func (s *SessionStore) GetPadSessionsCount(padId string) int

+ func (s *SessionStore) GetStats() (SessionStat, error)

v0.0.4

Jan 26, 2026

Changes in this version

type Hub

+ ClientsRWMutex sync.RWMutex

type PadMessageHandler

+ func (p *PadMessageHandler) HandleSavedRevisionMessage(foundPad *pad2.Pad, author string)

+ type SavedRevision struct

+ Data SavedRevisionData

+ Event string

+ type SavedRevisionData struct

+ Component string

+ Data SavedRevisionDataData

+ Type string

+ type SavedRevisionDataData struct

+ Type string

v0.0.3

Jan 13, 2026

v0.0.2

Jan 12, 2026

Changes in this version

+ func ServeAdminWs(w http.ResponseWriter, r *http.Request, fiber *fiber.Ctx, ...)

+ type AdminMessageHandler struct

+ Logger *zap.SugaredLogger

+ func NewAdminMessageHandler(store db.DataStore, h *hooks.Hook, m *pad.Manager, ...) AdminMessageHandler

+ func (h AdminMessageHandler) DeleteRevisions(padId string, keepRevisions int) error

+ func (h AdminMessageHandler) HandleMessage(message admin.EventMessage, retrievedSettings *settings.Settings, c *Client)

+ type ChangesetInfo struct

+ APool apool.APool

+ ActualEndNum int

+ BackwardsChangesets []string

+ ForwardsChangesets []string

+ Granularity int

+ RequestId int

+ Start int

+ TimeDeltas []int64

+ type ChangesetResponse struct

+ Data ChangesetInfo

+ Type string

type Client

+ Conn WebSocketConn

+ Ctx *fiber.Ctx

+ Handler *PadMessageHandler

+ Hub *Hub

+ func (c *Client) SafeSend(message []byte) (sent bool)

+ type ClientReconnectData struct

+ APool apool.APool

+ Author string

+ Changeset string

+ CurrentTime int64

+ HeadRev int

+ NewRev int

+ NoChanges bool

+ Type string

+ type ClientReconnectMessage struct

+ Data ClientReconnectData

+ Type string

type Hub

+ Clients map[*Client]bool

+ type LineChange struct

+ Alines []string

+ TextLines []string

+ type MockWebSocketConn struct

+ Data []WebSocketConnData

+ func NewActualMockWebSocketconn() *MockWebSocketConn

+ func (m *MockWebSocketConn) Close() error

+ func (m *MockWebSocketConn) NextWriter(messageType int) (io.WriteCloser, error)

+ func (m *MockWebSocketConn) ReadMessage() (messageType int, p []byte, err error)

+ func (m *MockWebSocketConn) RemoteAddr() net.Addr

+ func (m *MockWebSocketConn) SetPongHandler(h func(appData string) error)

+ func (m *MockWebSocketConn) SetReadDeadline(t time.Time) error

+ func (m *MockWebSocketConn) SetReadLimit(size int64)

+ func (m *MockWebSocketConn) SetWriteDeadline(t time.Time) error

+ func (m *MockWebSocketConn) WriteControl(messageType int, data []byte, deadline time.Time) error

+ func (m *MockWebSocketConn) WriteMessage(messageType int, data []byte) error

+ type PadMessageHandler struct

+ Logger *zap.SugaredLogger

+ SessionStore *SessionStore

+ func NewPadMessageHandler(db db2.DataStore, hooks *hooks.Hook, padManager *pad.Manager, ...) *PadMessageHandler

+ func (p *PadMessageHandler) ComposePadChangesets(retrievedPad *pad2.Pad, startNum int, endNum int) (string, error)

+ func (p *PadMessageHandler) DeletePad(padId string) error

+ func (p *PadMessageHandler) GetRoomSockets(padID string) []Client

+ func (p *PadMessageHandler) HandleChangesetRequest(socket *Client, message ws.ChangesetReq)

+ func (p *PadMessageHandler) HandleClientReadyMessage(ready ws.ClientReady, client *Client, thisSession *ws.Session, ...)

+ func (p *PadMessageHandler) HandleDisconnectOfPadClient(client *Client, settings *settings.Settings, logger *zap.SugaredLogger)

+ func (p *PadMessageHandler) HandleMessage(message any, client *Client, ctx *fiber.Ctx, ...)

+ func (p *PadMessageHandler) HandlePadDelete(client *Client, padDeleteMessage PadDelete)

+ func (p *PadMessageHandler) HandleUserInfoUpdate(userInfo UserInfoUpdate, client *Client)

+ func (p *PadMessageHandler) KickSessionsFromPad(padID string)

+ func (p *PadMessageHandler) SendChatMessageToPadClients(session *ws.Session, chatMessage ws.ChatMessageData)

+ func (p *PadMessageHandler) UpdatePadClients(pad *pad2.Pad)

type SessionStore

+ func (s *SessionStore) AddHandleClientInformationForTest(sessionId string, padId string, token string) *ws.Session

+ func (s *SessionStore) AddPadReadOnlyIdsForTest(sessionId, padId string, readOnlyPadId string, readOnly bool)

+ func (s *SessionStore) GetSessionForTest(sessionId string) *ws.Session

+ func (s *SessionStore) InitSessionForTest(sessionId string)

+ func (s *SessionStore) RemoveSessionForTest(sessionId string)

+ func (s *SessionStore) SetAuthorForTest(sessionId string, authorId string)

+ func (s *SessionStore) SetPadIdForTest(sessionId string, padId string)

+ func (s *SessionStore) SetReadOnlyForTest(sessionId string, readOnly bool)

+ func (s *SessionStore) SetRevisionForTest(sessionId string, revision int)

+ type WebSocketConn interface

+ Close func() error

+ NextWriter func(messageType int) (io.WriteCloser, error)

+ ReadMessage func() (messageType int, p []byte, err error)

+ RemoteAddr func() net.Addr

+ SetPongHandler func(h func(appData string) error)

+ SetReadDeadline func(t time.Time) error

+ SetReadLimit func(size int64)

+ SetWriteDeadline func(t time.Time) error

+ WriteControl func(messageType int, data []byte, deadline time.Time) error

+ WriteMessage func(messageType int, data []byte) error

+ func NewMockWebSocketConn() WebSocketConn

+ func NewWebSocketWrapper(conn *websocket.Conn) WebSocketConn

+ type WebSocketConnData struct

+ Data []byte

+ type WebSocketWrapper struct

v0.0.1

Nov 2, 2025

Changes in this version

+ var PadChannels = NewChannelOperator()

+ func HandleClientReadyMessage(ready ws.ClientReady, client *Client, thisSession *ws.Session)

+ func HandlePadDelete(client *Client, padDeleteMessage PadDelete)

+ func HandleUserInfoUpdate(userInfo UserInfoUpdate, client *Client)

+ func KickSessionsFromPad(padID string)

+ func ServeWs(hub *Hub, w http.ResponseWriter, r *http.Request, sessionStore *session.Store, ...)

+ func UpdatePadClients(pad *pad2.Pad)

+ type AcceptCommitData struct

+ NewRev int

+ Type string

+ type AcceptCommitMessage struct

+ Data AcceptCommitData

+ Type string

+ type AccessStatusMessage struct

+ AccessStatus string

+ type AuthSession struct

+ PadID string

+ ReadOnly bool

+ ReadOnlyPadId *string

+ Token string

+ type ChannelOperator struct

+ func NewChannelOperator() ChannelOperator

+ func (c *ChannelOperator) AddToQueue(ch string, t Task)

+ type Client struct

+ Room string

+ Send chan []byte

+ SessionId string

+ func GetRoomSockets(padID string) []Client

+ func (c *Client) Leave()

+ func (c *Client) SendPadDelete()

+ func (c *Client) SendUserDupMessage()

+ type Hub struct

+ Broadcast chan []byte

+ Register chan *Client

+ Unregister chan *Client

+ var HubGlob *Hub

+ func NewHub() *Hub

+ func (h *Hub) Run()

+ type Message struct

+ Data clientVars2.ClientVars

+ Type string

+ type NewChangesMessage struct

+ Data NewChangesMessageData

+ Type string

+ type NewChangesMessageData struct

+ APool apool.APool

+ Author string

+ Changeset string

+ CurrentTime int

+ NewRev int

+ TimeDelta int

+ Type string

+ type PadDelete struct

+ Data struct{ ... }

+ Type string

+ type PadDeleteMessage struct

+ Disconnect string

+ type SessionInfo struct

+ type SessionStore struct

+ var SessionStoreInstance SessionStore

+ func NewSessionStore(refresh *int) SessionStore

+ type Task struct

+ type UserDupMessage struct

+ Disconnect string

+ type UserInfoUpdate struct

+ Data struct{ ... }

+ Type string

+ type UserInfoUpdateWrapper struct

+ Data UserInfoUpdate

+ Event string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL