daemon

Apr 19, 2026

Changes in this version

+ type RESTHandler struct

+ func NewRESTHandler(store domain.Store, hub *Hub, bus domain.EventBus) *RESTHandler

type WebhookEvent

+ Body string

+ ChannelID int64

+ FromType string

+ Metadata *string

type WebhookPayload

+ Body string

+ ChannelID int64

+ ChannelName string

+ FromType string

+ Metadata *string

Mar 17, 2026

Changes in this version

type PresenceHandler

+ func (h *PresenceHandler) IsOnline(username string) bool

+ func (h *PresenceHandler) SendNotification(username string, data []byte) error

Mar 11, 2026

Changes in this version

+ type PresenceNotifier struct

+ func NewPresenceNotifier(bus domain.EventBus, sessions *SessionManager, store domain.Store) *PresenceNotifier

+ func (pn *PresenceNotifier) Close()

type SessionManager

+ func (sm *SessionManager) PresenceWrite(token string, messageType int, data []byte) error

+ func (sm *SessionManager) SendNotification(username string, data []byte) error

+ type WebhookSubscriber struct

+ func NewWebhookSubscriber(bus domain.EventBus, store domain.Store) *WebhookSubscriber

+ func (ws *WebhookSubscriber) Close()

Mar 6, 2026

Changes in this version

type Server

+ func (s *Server) Store() domain.Store

Mar 6, 2026

Changes in this version

type Hub

+ func (h *Hub) BroadcastToRole(role string, data []byte, database *db.DB)

+ func (h *Hub) ClearState(username string)

+ func (h *Hub) GetState(username string) string

+ func (h *Hub) SetState(username, state string)

type Server

+ func (s *Server) DB() *db.DB

Mar 5, 2026

Changes in this version

+ type Hub struct

+ func NewHub() *Hub

+ func (h *Hub) BroadcastMessage(channelID int64, channelName string, channelType string, msg db.Message, ...)

+ func (h *Hub) BroadcastPresence(username string, online bool)

+ func (h *Hub) ClientCount() int

+ func (h *Hub) Register(client *WSClient)

+ func (h *Hub) Unregister(client *WSClient)

+ type IdentityToken struct

+ CreatedAt time.Time

+ HasPresence bool

+ Identified bool

+ MCPSessionID string

+ PresenceDone chan struct{}

+ Token string

+ Username string

+ type MCPSession struct

+ ID string

+ TokenID string

+ Username string

+ type PresenceHandler struct

+ func NewPresenceHandler(sessions *SessionManager, hub *Hub, pongTimeout time.Duration) *PresenceHandler

+ func (h *PresenceHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Server struct

+ func NewServer(addr, dbPath string, allowChannelCreation bool, pongTimeout time.Duration, ...) (*Server, error)

+ func (s *Server) Shutdown(ctx context.Context) error

+ func (s *Server) Start() error

+ type SessionManager struct

+ func NewSessionManager(database *db.DB) *SessionManager

+ func (sm *SessionManager) AttachPresence(token string) (<-chan struct{}, error)

+ func (sm *SessionManager) CreateIdentityToken() string

+ func (sm *SessionManager) DisconnectPresence(token string)

+ func (sm *SessionManager) GetSession(mcpSessionID string) (*MCPSession, error)

+ func (sm *SessionManager) Identify(token, username, password string) (string, error)

+ func (sm *SessionManager) IsUserOnline(username string) bool

+ func (sm *SessionManager) Register(token, username, password string) (string, error)

+ type SharkfinMCP struct

+ func NewSharkfinMCP(sm *SessionManager, database *db.DB, hub *Hub) *SharkfinMCP

+ func (s *SharkfinMCP) Server() *server.MCPServer

+ type WSClient struct

+ type WSHandler struct

+ func NewWSHandler(sessions *SessionManager, database *db.DB, hub *Hub, pongTimeout time.Duration) *WSHandler

+ func (h *WSHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type WebhookEvent struct

+ ChannelName string

+ ChannelType string

+ From string

+ MessageID int64

+ Recipients []string

+ SentAt time.Time

+ type WebhookPayload struct

+ Channel string

+ ChannelType string

+ Event string

+ From string

+ MessageID int64

+ Recipient string

+ SentAt string