wssession

type Identity struct {
	UserID string
	OrgID  string
	Plan   string
	Role   string
}

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

type ManagedSession struct {
	ID          string
	Owner       Identity
	CreatedAt   time.Time
	State       State
	HasWSClient bool // true once the client has upgraded

	// BridgeCredential is the opaque per-session credential the fronting
	// proxy forwarded at session creation (see middleware
	// EdgeOboSubjectTokenFromContext). The Voice Agent surface sets it at
	// upgrade time to authorize that session's calls to the external tool
	// bridge; the streaming-Dictation surface leaves it empty. MEMORY-ONLY
	// SECRET: it is never minted into tickets, never serialized to the wire
	// (listedSession and createSessionResponse deliberately exclude it),
	// never persisted, and MUST never appear in slog attributes.
	BridgeCredential string

	// VoicePrefs carries the edge-resolved user voice preferences captured at
	// session-mint time (see middleware.VoicePrefsFromContext). Mode adapters
	// use them as defaults when the client's start frame omits an explicit
	// provider or persona; explicit start-frame values always win. Non-secret
	// names only — safe to log, never keys.
	VoicePrefs VoicePrefs
}

type Options struct {
	// TicketSecret signs the one-time WS upgrade tickets. Must be at least
	// 16 bytes; when empty, the manager generates a random secret at
	// construction time (acceptable only for single-process deployments).
	TicketSecret []byte
	// TicketTTL limits how long a minted ticket remains valid. Defaults to
	// 90 seconds.
	TicketTTL time.Duration
	// MaxGlobalSessions caps concurrent sessions across all callers.
	// Defaults to 100.
	MaxGlobalSessions int
	// MaxPerIdentitySessions caps concurrent sessions per caller.
	// Defaults to 3.
	MaxPerIdentitySessions int
	// Clock is a time source; nil means time.Now. Tests can override.
	Clock func() time.Time
}

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

type SessionStats struct {
	TotalSessions          int `json:"total_sessions"`
	ActiveSessions         int `json:"active_sessions"`
	PendingSessions        int `json:"pending_sessions"`
	IdentitySessions       int `json:"identity_sessions,omitempty"`
	MaxGlobalSessions      int `json:"max_global_sessions"`
	MaxPerIdentitySessions int `json:"max_per_identity_sessions"`
}

type State string

type VoicePrefs struct {
	STTPrimary   string
	STTSecondary string
	VAProvider   string
	VAPersona    string
}