websocket

type ClientConfig struct {
	InBufSize  int
	OutBufSize int
}

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

type ConnTransport struct {

	// WriteMessageFunc, when non-nil, is used instead of conn.WriteMessage in writeOne (e.g. for tests to count or capture writes). When nil, conn.WriteMessage is used.
	WriteMessageFunc func(messageType int, data []byte) error
	// contains filtered or unexported fields
}

type ConnTransportOptions struct {
	// WriteCoalesceMs when > 0 enables write coalescing (drain up to WriteCoalesceMaxFrames within this many ms).
	WriteCoalesceMs int
	// WriteCoalesceMaxFrames is the max frames per coalesced batch; 0 means default 10.
	WriteCoalesceMaxFrames int

	// MaxDurationAfterFirstAudio when > 0 starts a one-shot timer on the
	// first inbound *frames.AudioRawFrame and invokes OnMaxDurationTimeout
	// when the duration elapses.
	MaxDurationAfterFirstAudio time.Duration
	OnMaxDurationTimeout       func()
}

type ReportErrorFunc func(*frames.ErrorFrame)

type Server struct {
	Host string
	Port int
	// SessionTimeout controls how long a connection may remain idle before
	// it is closed. If zero or negative, no inactivity timeout is enforced.
	SessionTimeout time.Duration
	// OnConn is called for each new connection; it receives the transport which should be linked to a pipeline.
	OnConn func(ctx context.Context, tr *ConnTransport)
	// RegisterHandlers, if non-nil, is called with the HTTP mux before the server
	// starts to allow registration of additional HTTP handlers (e.g. WebRTC signaling).
	RegisterHandlers func(mux *http.ServeMux)
	// ReadHeaderTimeout, ReadTimeout, WriteTimeout, IdleTimeout, MaxHeaderBytes, ShutdownTimeout set HTTP server timeouts.
	// Zero values use package defaults (10s, 30s, 30s, 60s, 1MiB, 30s).
	ReadHeaderTimeout time.Duration
	ReadTimeout       time.Duration
	WriteTimeout      time.Duration
	IdleTimeout       time.Duration
	MaxHeaderBytes    int
	ShutdownTimeout   time.Duration
	// TLS: when both are non-empty, ListenAndServe uses ListenAndServeTLS(certFile, keyFile).
	TLSCertFile string
	TLSKeyFile  string
	// CheckAuth if non-nil is called before upgrading to WebSocket. If it returns false, the handler returns (caller should have written 401).
	CheckAuth func(http.ResponseWriter, *http.Request) bool
	// GetSerializer if non-nil is called per request to choose the frame serializer (e.g. RTVI when query has rtvi=1).
	GetSerializer func(r *http.Request) serialize.Serializer
	// WriteCoalesceMs when > 0 enables write coalescing on each ConnTransport (drain up to WriteCoalesceMaxFrames within this many ms).
	WriteCoalesceMs        int
	WriteCoalesceMaxFrames int

	// MaxDurationAfterFirstAudio when > 0 starts a one-shot max-duration
	// timer on each connection after the first inbound *frames.AudioRawFrame.
	// When the timer fires, the per-connection context is canceled, which
	// terminates the transport and associated pipeline session.
	MaxDurationAfterFirstAudio time.Duration
}

type WebSocketConnector interface {
	// Conn returns the current WebSocket connection (may be nil).
	Conn() *websocket.Conn
	// SetConn sets the current connection (after Connect or reconnect).
	SetConn(conn *websocket.Conn)
	// Connect establishes a new connection and sets it via SetConn.
	Connect(ctx context.Context) error
	// Disconnect closes the current connection and clears it.
	Disconnect() error
	// ReceiveMessages runs the receive loop until error or connection close.
	// Called repeatedly by ReceiveLoop when reconnection is enabled.
	ReceiveMessages(ctx context.Context) error
}

type WebsocketServiceBase struct {
	Connector        WebSocketConnector
	ReconnectOnError bool
	// contains filtered or unexported fields
}