websocket

type AuthFunc func(*EventConn, Envelope) error

type AuthorizeFunc func(*EventConn, string, string, string) error

type BroadcastOptions struct {
	SkipClientID      string
	OnlyClientID      string
	RequireSubscribed bool
}

type ClientIDFunc func(fh.Ctx, map[string]string) string

type Clock func() time.Time

type CloseError struct {
	Code   uint16
	Reason string
}

type Config struct {
	MaxMessageSize int
	MaxFrameSize   int
	MaxFragments   int

	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	PingInterval time.Duration
	PongTimeout  time.Duration

	MaxMessagesPerSecond int

	// Secure default:
	// - If CheckOrigin is nil and AllowedOrigins is empty:
	//   browser requests with Origin are rejected, non-browser requests without Origin are allowed.
	// - Set AllowAllOrigins=true only for trusted/internal/dev use.
	AllowAllOrigins bool
	AllowedOrigins  []string
	CheckOrigin     func(fh.Ctx) bool

	Subprotocols []string

	EnableHeartbeat bool

	Manager *Manager

	OnOpen    func(*Conn)
	OnClose   func(*Conn, error)
	OnError   func(*Conn, error)
	OnMessage func(*Conn, byte, int64)
}

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

type Context = HandlerContext

type Envelope struct {
	Type      string          `json:"type,omitempty"`
	ID        string          `json:"id,omitempty"`
	ReplyTo   string          `json:"replyTo,omitempty"`
	Event     string          `json:"event,omitempty"`
	Topic     string          `json:"topic,omitempty"`
	Channel   string          `json:"channel,omitempty"`
	Payload   json.RawMessage `json:"payload,omitempty"`
	Error     string          `json:"error,omitempty"`
	Code      string          `json:"code,omitempty"`
	Timestamp int64           `json:"ts,omitempty"`
}

type EventConn struct {
	ID     string            `json:"id"`
	Hub    *EventHub         `json:"-"`
	Conn   *Conn             `json:"-"`
	Writer *Writer           `json:"-"`
	Meta   map[string]string `json:"meta,omitempty"`
	// contains filtered or unexported fields
}

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

type EventHubConfig struct {
	WriterQueueSize int

	// MaxEnvelopeBytes limits the entire incoming JSON envelope.
	MaxEnvelopeBytes int

	// MaxPayloadBytes limits the payload JSON field after decode.
	MaxPayloadBytes int

	AckTimeout        time.Duration
	ClientIdleTimeout time.Duration
	CleanupInterval   time.Duration

	// MaxSubscriptions is per connection.
	MaxSubscriptions int

	// MaxPendingRequests is per connection for server-side request/ack tracking.
	MaxPendingRequests int

	// If false, client messages with Event=server.broadcast/server.notify are rejected.
	AllowClientBroadcast bool
	AllowClientNotify    bool

	// CloseSlowClient closes a connection when the writer queue is full. If false,
	// the message is dropped and Send returns ErrEventSlowClient.
	CloseSlowClient bool

	// EnablePresence emits presence messages to topic/channel subscribers.
	EnablePresence bool

	// SendHello sends an initial hello envelope after upgrade.
	SendHello bool

	// Debug adds debug fields to metrics/log callbacks only; it does not print.
	Debug bool

	Auth      AuthFunc
	Authorize AuthorizeFunc
	ClientID  ClientIDFunc
	Now       Clock

	OnError       func(*EventConn, error)
	OnConnect     func(*EventConn)
	OnDisconnect  func(*EventConn, error)
	OnSubscribe   func(*EventConn, string, string)
	OnUnsubscribe func(*EventConn, string, string)
}

type EventStats struct {
	ConnectedClients   int64 `json:"connectedClients"`
	TotalConnections   int64 `json:"totalConnections"`
	TotalDisconnects   int64 `json:"totalDisconnects"`
	IncomingEnvelopes  int64 `json:"incomingEnvelopes"`
	OutgoingEnvelopes  int64 `json:"outgoingEnvelopes"`
	HandledEvents      int64 `json:"handledEvents"`
	HandlerErrors      int64 `json:"handlerErrors"`
	DroppedEnvelopes   int64 `json:"droppedEnvelopes"`
	Subscriptions      int64 `json:"subscriptions"`
	PublishedEnvelopes int64 `json:"publishedEnvelopes"`
	AckTimeouts        int64 `json:"ackTimeouts"`
}

type Handler func(*HandlerContext) (any, error)

type HandlerContext struct {
	context.Context
	Hub      *EventHub
	Conn     *EventConn
	Envelope Envelope
	Payload  json.RawMessage
}

type Manager struct {
	MaxConnections int
	// contains filtered or unexported fields
}

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

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

type MetadataFunc func(fh.Ctx) map[string]string

type Middleware func(Handler) Handler

type OutboundMessage struct {
	Opcode  byte
	Payload []byte
}

type PresencePayload struct {
	Action    string `json:"action"`
	ClientID  string `json:"clientId"`
	Topic     string `json:"topic,omitempty"`
	Channel   string `json:"channel,omitempty"`
	Timestamp int64  `json:"ts"`
}

type Subscription struct {
	Topic     string    `json:"topic"`
	Channel   string    `json:"channel"`
	CreatedAt time.Time `json:"createdAt"`
}

type Writer struct {
	Conn  *Conn
	Queue chan OutboundMessage
	Done  chan struct{}
	// contains filtered or unexported fields
}