storage

type Direction string

type HealthChecker interface {
	// Ping checks if the store is healthy and reachable.
	Ping(ctx context.Context) error
}

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

type Namer interface {
	Name() string
}

type RedisOption func(*RedisStore)

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

type SessionMetrics struct {
	// TurnCount is the total number of conversational turns.
	TurnCount int `json:"turn_count"`

	// InterruptionCount is how many times the user interrupted the agent.
	InterruptionCount int `json:"interruption_count"`

	// UserSpeechDurationMs is total user speech time in milliseconds.
	UserSpeechDurationMs int `json:"user_speech_duration_ms"`

	// AgentSpeechDurationMs is total agent speech time in milliseconds.
	AgentSpeechDurationMs int `json:"agent_speech_duration_ms"`

	// FirstResponseMs is latency to first agent response in milliseconds.
	FirstResponseMs int `json:"first_response_ms,omitempty"`

	// AverageResponseMs is average agent response latency in milliseconds.
	AverageResponseMs int `json:"average_response_ms,omitempty"`
}

type SessionState struct {
	// ID uniquely identifies this session.
	ID string `json:"id"`

	// CreatedAt is when the session was first created.
	CreatedAt time.Time `json:"created_at"`

	// UpdatedAt is when the session was last modified.
	UpdatedAt time.Time `json:"updated_at"`

	// Call metadata
	CallID    string        `json:"call_id,omitempty"`
	Provider  string        `json:"provider"`
	Direction Direction     `json:"direction"`
	From      string        `json:"from"`
	To        string        `json:"to"`
	Status    SessionStatus `json:"status"`

	// Conversation history
	History []Turn `json:"history"`

	// Metrics for the session
	Metrics SessionMetrics `json:"metrics"`

	// RecoveryData holds provider-specific data needed to recover a session.
	RecoveryData map[string]any `json:"recovery_data,omitempty"`
}

type SessionStatus string

type SessionStore interface {
	// Save persists or updates a session state.
	// If the session already exists, it will be overwritten.
	Save(ctx context.Context, session *SessionState) error

	// Load retrieves a session state by ID.
	// Returns ErrNotFound if the session does not exist.
	Load(ctx context.Context, sessionID string) (*SessionState, error)

	// Delete removes a session state.
	// Returns ErrNotFound if the session does not exist.
	Delete(ctx context.Context, sessionID string) error

	// ListActive returns IDs of all active sessions.
	// A session is considered active if its status is not StatusEnded.
	ListActive(ctx context.Context) ([]string, error)

	// UpdateHeartbeat updates the session's timestamp to indicate activity.
	// This is used to track session liveness and enable cleanup of stale sessions.
	UpdateHeartbeat(ctx context.Context, sessionID string) error

	// Close releases any resources held by the store.
	Close() error
}

type Turn struct {
	// Role is the speaker: "user" or "agent".
	Role string `json:"role"`

	// Content is the transcript of what was said.
	Content string `json:"content"`

	// Timestamp is when this turn occurred.
	Timestamp time.Time `json:"timestamp"`

	// DurationMs is the speech duration in milliseconds.
	DurationMs int `json:"duration_ms"`
}