store

type AudioAsset struct {
	StorageKind AudioStorageKind `json:"storageKind"`
	Path        string           `json:"-"`
	MimeType    string           `json:"mimeType"`
	SizeBytes   int64            `json:"sizeBytes"`
	DurationMs  int64            `json:"durationMs"`
}

type AudioAssetInput struct {
	Data       []byte
	MimeType   string
	Extension  string
	DurationMs int64
}

type AudioAssetStore interface {
	GetAudioAsset(ctx context.Context, ownerKind string, ownerID int64) (*AudioAsset, error)
}

type AudioStorageKind string

type BackendFactory func(cfg StoreConfig) (Store, error)

type CustomizationListOpts = speechcustomize.ListOptions

type CustomizationReplaceOpts = speechcustomize.ReplaceOptions

type CustomizationSourceStore interface {
	ReplaceWordsWithOptions(ctx context.Context, opts CustomizationReplaceOpts, words []speechcustomize.Word) error
	ReplaceReplacementsWithOptions(ctx context.Context, opts CustomizationReplaceOpts, replacements []speechcustomize.Replacement) error
	ReplaceLexiconsWithOptions(ctx context.Context, opts CustomizationReplaceOpts, lexicons []speechcustomize.Lexicon) error
	ReplaceRulesetsWithOptions(ctx context.Context, opts CustomizationReplaceOpts, rulesets []speechcustomize.Ruleset) error
}

type CustomizationStore interface {
	WordStore
	ReplacementStore
	LexiconStore
	RulesetStore
}

type CustomizationVocabularyStore interface {
	ReplaceVocabularyWithOptions(ctx context.Context, opts CustomizationReplaceOpts, words []speechcustomize.Word, extras []speechcustomize.Replacement) error
}

type DeleteResult struct {
	RowsDeleted    int      `json:"rows_deleted"`
	AudioFilePaths []string `json:"audio_file_paths"`
}

type LexiconStore interface {
	ReplaceLexicons(ctx context.Context, language string, lexicons []speechcustomize.Lexicon) error
	ListLexicons(ctx context.Context, opts CustomizationListOpts) ([]speechcustomize.Lexicon, error)
}

type ListOpts struct {
	Limit            int
	Offset           int
	Language         string
	After            time.Time
	OwnerUserID      string
	OwnerOrgID       string
	IncludeOwnerless bool
	IncludeAllOwners bool
	// Kind filters recording sessions by normalized kind ("meeting",
	// "dictation"); empty means all kinds. Only list queries over recording
	// sessions honor it.
	Kind string
}

type MeetingSummaryBatch struct {
	ID                int64                     `json:"id"`
	SessionID         int64                     `json:"sessionId"`
	BatchKey          string                    `json:"batchKey"`
	Level             int                       `json:"level"`
	StartSegmentID    int64                     `json:"startSegmentId"`
	EndSegmentID      int64                     `json:"endSegmentId"`
	SourceFingerprint string                    `json:"sourceFingerprint"`
	Status            MeetingSummaryBatchStatus `json:"status"`
	DigestJSON        string                    `json:"digestJson,omitempty"`
	Provider          string                    `json:"provider,omitempty"`
	Model             string                    `json:"model,omitempty"`
	ErrorKind         string                    `json:"errorKind,omitempty"`
	CreatedAt         time.Time                 `json:"createdAt"`
	UpdatedAt         time.Time                 `json:"updatedAt"`
}

type MeetingSummaryBatchStatus string

type MeetingSummaryBatchStore interface {
	UpsertMeetingSummaryBatch(ctx context.Context, batch MeetingSummaryBatch) (MeetingSummaryBatch, error)
	ListMeetingSummaryBatches(ctx context.Context, sessionID int64) ([]MeetingSummaryBatch, error)
}

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

type QuickNote struct {
	ID         int64
	Text       string
	Language   string
	Provider   string
	DurationMs int64
	LatencyMs  int64
	AudioPath  string
	Audio      *AudioAsset
	Pinned     bool
	CreatedAt  time.Time
	UpdatedAt  time.Time
}

type RecordOwner struct {
	UserID string
	OrgID  string
	Source string
}

type RecordingSession struct {
	ID               int64                         `json:"id"`
	ExternalID       string                        `json:"externalId,omitempty"`
	Kind             RecordingSessionKind          `json:"kind"`
	Status           RecordingSessionStatus        `json:"status"`
	CaptureStatus    RecordingSessionCaptureStatus `json:"captureStatus"`
	SummaryStatus    RecordingSessionSummaryStatus `json:"summaryStatus"`
	SummaryError     string                        `json:"summaryError,omitempty"`
	Title            string                        `json:"title,omitempty"`
	Language         string                        `json:"language"`
	Provider         string                        `json:"provider,omitempty"`
	Model            string                        `json:"model,omitempty"`
	InputSource      string                        `json:"inputSource,omitempty"`
	ProcessingMode   string                        `json:"processingMode,omitempty"`
	Summary          string                        `json:"summary,omitempty"`
	StartedAt        time.Time                     `json:"startedAt"`
	EndedAt          time.Time                     `json:"endedAt,omitempty"`
	CaptureStartedAt time.Time                     `json:"captureStartedAt,omitempty"`
	CapturePausedAt  time.Time                     `json:"capturePausedAt,omitempty"`
	CaptureStoppedAt time.Time                     `json:"captureStoppedAt,omitempty"`
	SummaryUpdatedAt time.Time                     `json:"summaryUpdatedAt,omitempty"`
	CreatedAt        time.Time                     `json:"createdAt"`
	UpdatedAt        time.Time                     `json:"updatedAt"`
	OwnerUserID      string                        `json:"ownerUserId,omitempty"`
	OwnerOrgID       string                        `json:"ownerOrgId,omitempty"`
	OwnerSource      string                        `json:"ownerSource,omitempty"`
	Segments         []RecordingSessionSegment     `json:"segments,omitempty"`
	// Notes are the user's own notes for this meeting. Only loaded where they
	// matter — the session detail and subject exports — not in list responses.
	Notes *RecordingSessionNotes `json:"notes,omitempty"`
	// Snapshots are the screen captures taken during this meeting. Loaded like
	// Notes only on the session detail, not in list responses.
	Snapshots []RecordingSessionSnapshot `json:"snapshots,omitempty"`
	// RetentionPinned keeps this meeting even once it is past the retention
	// window.
	RetentionPinned bool `json:"retentionPinned,omitempty"`
}

type RecordingSessionCaptureStatus string

type RecordingSessionEnhancement struct {
	ID           int64  `json:"id"`
	SessionID    int64  `json:"sessionId"`
	TemplateSlug string `json:"templateSlug"`
	// TemplateSnapshot is the template as it was when this write-up ran, so an
	// old result stays explicable after the template's wording changes.
	TemplateSnapshot string                            `json:"templateSnapshot,omitempty"`
	Status           RecordingSessionEnhancementStatus `json:"status"`
	Error            string                            `json:"error,omitempty"`
	Provider         string                            `json:"provider,omitempty"`
	Model            string                            `json:"model,omitempty"`
	Stage            string                            `json:"stage,omitempty"`
	Progress         int                               `json:"progress"`
	Attempt          int                               `json:"attempt"`
	InputFingerprint string                            `json:"inputFingerprint,omitempty"`
	ErrorKind        string                            `json:"errorKind,omitempty"`
	Retryable        bool                              `json:"retryable"`
	ConsentVersion   int                               `json:"consentVersion,omitempty"`
	// Structured is false when the model could not produce citable structure
	// and the notes are prose. Callers surface that rather than implying the
	// bullets can be traced back to the transcript.
	Structured bool `json:"structured"`
	// ContentJSON is the structured document; ContentMD is it rendered for
	// reading, copying and export.
	ContentJSON string    `json:"contentJson,omitempty"`
	ContentMD   string    `json:"contentMd,omitempty"`
	CreatedAt   time.Time `json:"createdAt"`
	UpdatedAt   time.Time `json:"updatedAt"`
}

type RecordingSessionEnhancementStatus string

type RecordingSessionEnhancementStore interface {
	CreateRecordingSessionEnhancement(ctx context.Context, sessionID int64, enhancement RecordingSessionEnhancement) (int64, error)
	UpdateRecordingSessionEnhancement(ctx context.Context, id int64, enhancement RecordingSessionEnhancement) error
	ListRecordingSessionEnhancements(ctx context.Context, sessionID int64) ([]RecordingSessionEnhancement, error)
}

type RecordingSessionKind string

type RecordingSessionNoteBlock struct {
	// ID is stable for the lifetime of the note so an enhanced bullet can
	// point back at the note it came from.
	ID   string `json:"id"`
	Text string `json:"text"`
	// TsMs is when the note was written, relative to the meeting's start.
	TsMs int64 `json:"tsMs"`
}

type RecordingSessionNotes struct {
	SessionID int64 `json:"sessionId"`
	// ContentMD is the note pane as the user last left it.
	ContentMD string `json:"contentMd"`
	// Blocks splits that text into the individual notes, each stamped with the
	// point in the meeting it was written at. The enhancement uses those
	// timestamps to find the part of the conversation a note was about.
	Blocks    []RecordingSessionNoteBlock `json:"blocks"`
	CreatedAt time.Time                   `json:"createdAt,omitempty"`
	UpdatedAt time.Time                   `json:"updatedAt,omitempty"`
}

type RecordingSessionNotesStore interface {
	SaveRecordingSessionNotes(ctx context.Context, sessionID int64, notes RecordingSessionNotes) error
	GetRecordingSessionNotes(ctx context.Context, sessionID int64) (*RecordingSessionNotes, error)
}

type RecordingSessionSegment struct {
	ID        int64 `json:"id"`
	SessionID int64 `json:"sessionId"`
	// SegmentIndex orders segments within one session. Pass a negative value
	// to AppendRecordingSessionSegment to have the store allocate the next
	// free index, which is what concurrent capture channels need; an explicit
	// index upserts the row at that position (the segment-edit path).
	SegmentIndex    int    `json:"segmentIndex"`
	TranscriptionID int64  `json:"transcriptionId,omitempty"`
	ProviderItemID  string `json:"providerItemId,omitempty"`
	Text            string `json:"text"`
	IsFinal         bool   `json:"isFinal"`
	// Channel names the capture source this segment was transcribed from
	// (see speechkit.CaptureChannel*). Empty for single-source sessions.
	Channel string `json:"channel,omitempty"`
	// Speaker labels who spoke, derived from Channel today.
	Speaker   string    `json:"speaker,omitempty"`
	StartedMs int64     `json:"startedMs"`
	EndedMs   int64     `json:"endedMs"`
	CreatedAt time.Time `json:"createdAt"`
}

type RecordingSessionSnapshot struct {
	ID         int64 `json:"id"`
	SessionID  int64 `json:"sessionId"`
	CapturedMs int64 `json:"capturedMs"`
	// Path is the absolute local file path; images are served by ID, so the
	// path stays out of API payloads.
	Path      string `json:"-"`
	MimeType  string `json:"mimeType"`
	SizeBytes int64  `json:"sizeBytes"`
	Width     int    `json:"width"`
	Height    int    `json:"height"`
	Monitor   string `json:"monitor,omitempty"`
	Note      string `json:"note,omitempty"`
	// Description is filled by the optional vision enrichment (V2).
	Description string    `json:"description,omitempty"`
	CreatedAt   time.Time `json:"createdAt"`
}

type RecordingSessionSnapshotInput struct {
	// CapturedMs is the offset on the meeting's transcript timeline:
	// wall-clock milliseconds since the capture epoch, the same time base
	// segment StartedMs/EndedMs are stamped with (see Runtime.ElapsedMs).
	CapturedMs int64
	// Data is the encoded image; MimeType defaults to image/png.
	Data     []byte
	MimeType string
	Width    int
	Height   int
	Monitor  string
	Note     string
}

type RecordingSessionSnapshotStore interface {
	SaveRecordingSessionSnapshot(ctx context.Context, sessionID int64, input RecordingSessionSnapshotInput) (*RecordingSessionSnapshot, error)
	GetRecordingSessionSnapshot(ctx context.Context, id int64) (*RecordingSessionSnapshot, error)
	ListRecordingSessionSnapshots(ctx context.Context, sessionID int64) ([]RecordingSessionSnapshot, error)
	DeleteRecordingSessionSnapshot(ctx context.Context, id int64) error
}

type RecordingSessionStatus string

type RecordingSessionStore interface {
	SaveRecordingSession(ctx context.Context, session RecordingSession) (int64, error)
	ListRecordingSessions(ctx context.Context, opts ListOpts) ([]RecordingSession, error)
	AppendRecordingSessionSegment(ctx context.Context, sessionID int64, segment RecordingSessionSegment) (int64, error)
	UpdateRecordingSessionSummary(ctx context.Context, id int64, summary string) error
	UpdateRecordingSessionCaptureStatus(ctx context.Context, id int64, status RecordingSessionCaptureStatus, at time.Time) error
	UpdateRecordingSessionSummaryStatus(ctx context.Context, id int64, status RecordingSessionSummaryStatus, message string, at time.Time) error
	FinishRecordingSession(ctx context.Context, id int64, summary string, endedAt time.Time) error
	GetRecordingSession(ctx context.Context, id int64) (*RecordingSession, error)
	DeleteRecordingSession(ctx context.Context, id int64) error
	// SetRecordingSessionPinned keeps one meeting out of the retention sweep.
	SetRecordingSessionPinned(ctx context.Context, id int64, pinned bool) error
}

type RecordingSessionSummaryStatus string

type ReplacementStore interface {
	ReplaceReplacements(ctx context.Context, language string, replacements []speechcustomize.Replacement) error
	ListReplacements(ctx context.Context, opts CustomizationListOpts) ([]speechcustomize.Replacement, error)
	RecordReplacementUsage(ctx context.Context, id string) error
}

type RulesetStore interface {
	ReplaceRulesets(ctx context.Context, language string, rulesets []speechcustomize.Ruleset) error
	ListRulesets(ctx context.Context, opts CustomizationListOpts) ([]speechcustomize.Ruleset, error)
}

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

type Scope = speechstorage.Scope

type ScopeExport struct {
	Scope              Scope                 `json:"scope"`
	Transcriptions     []Transcription       `json:"transcriptions"`
	QuickNotes         []QuickNote           `json:"quick_notes"`
	VoiceAgentSessions []VoiceAgentSession   `json:"voice_agent_sessions"`
	RecordingSessions  []RecordingSession    `json:"recording_sessions,omitempty"`
	DictionaryEntries  []UserDictionaryEntry `json:"dictionary_entries,omitempty"`
	AudioAssetPaths    []string              `json:"audio_asset_paths"`
}

type ScopePrivacyStore interface {
	// ExportScope returns all user-owned records for the given scope. The
	// returned ScopeExport includes audio asset paths; the caller is
	// responsible for streaming the raw audio bytes if needed.
	ExportScope(ctx context.Context, scope Scope) (*ScopeExport, error)

	// DeleteScope removes all user-owned DB rows for the given scope across
	// every scoped table. Returns a DeleteResult with the total row count and
	// the distinct audio file paths that were associated with those rows.
	// The caller must unlink AudioFilePaths from disk; the store does not.
	DeleteScope(ctx context.Context, scope Scope) (DeleteResult, error)
}

type SemanticCapabilities struct {
	Provider     SemanticProvider `json:"provider"`
	FullText     bool             `json:"fullText"`
	Embeddings   bool             `json:"embeddings"`
	VectorSearch bool             `json:"vectorSearch"`
}

type SemanticCapabilityProvider interface {
	SemanticCapabilities(ctx context.Context) SemanticCapabilities
}

type SemanticProvider string

type Stats struct {
	Transcriptions        int
	QuickNotes            int
	TotalWords            int
	TotalAudioDurationMs  int64
	AverageWordsPerMinute float64
	AverageLatencyMs      int64
}

type Store interface {
	// Transcriptions
	SaveTranscription(ctx context.Context, text, language, provider, model string, durationMs, latencyMs int64, audioData []byte) error
	GetTranscription(ctx context.Context, id int64) (*Transcription, error)
	ListTranscriptions(ctx context.Context, opts ListOpts) ([]Transcription, error)
	TranscriptionCount(ctx context.Context) (int, error)

	// Quick Notes
	SaveQuickNote(ctx context.Context, text, language, provider string, durationMs, latencyMs int64, audioData []byte) (int64, error)
	GetQuickNote(ctx context.Context, id int64) (*QuickNote, error)
	ListQuickNotes(ctx context.Context, opts ListOpts) ([]QuickNote, error)
	UpdateQuickNote(ctx context.Context, id int64, text string) error
	UpdateQuickNoteCapture(ctx context.Context, id int64, text, provider string, durationMs, latencyMs int64, audioData []byte) error
	PinQuickNote(ctx context.Context, id int64, pinned bool) error
	DeleteQuickNote(ctx context.Context, id int64) error
	QuickNoteCount(ctx context.Context) (int, error)
	Stats(ctx context.Context) (Stats, error)

	// Lifecycle
	Close() error
}

type StoreConfig struct {
	Backend            string `toml:"backend"` // "sqlite" | "postgres" | registered name
	SQLitePath         string `toml:"sqlite_path"`
	PostgresDSN        string `toml:"postgres_dsn"`
	SaveAudio          bool   `toml:"save_audio"`
	AudioRetentionDays int    `toml:"audio_retention_days"`
	// MeetingRetentionDays discards finished meetings older than this. Zero
	// keeps them forever, which is the default: a meeting is work, not a
	// by-product, so nothing is thrown away unless the user asks for it.
	MeetingRetentionDays    int `toml:"meeting_retention_days"`
	MaxAudioStorageMB       int `toml:"max_audio_storage_mb"`
	TranscriptionModelHints map[string]string
	DefaultScope            speechstorage.Scope
	ScopePolicy             speechstorage.ScopePolicy
}

type Transcription struct {
	ID          int64                      `json:"id"`
	Text        string                     `json:"text"`
	Language    string                     `json:"language"`
	Provider    string                     `json:"provider"`
	Model       string                     `json:"model"`
	DurationMs  int64                      `json:"durationMs"`
	LatencyMs   int64                      `json:"latencyMs"`
	AudioPath   string                     `json:"audioPath,omitempty"`
	Audio       *AudioAsset                `json:"audio,omitempty"`
	CreatedAt   time.Time                  `json:"createdAt"`
	OwnerUserID string                     `json:"ownerUserId,omitempty"`
	OwnerOrgID  string                     `json:"ownerOrgId,omitempty"`
	OwnerSource string                     `json:"ownerSource,omitempty"`
	Speakers    *speaker.DiarizationResult `json:"speakers,omitempty"`
}

type TranscriptionAudioStore interface {
	SaveTranscriptionWithAudio(ctx context.Context, text, language, provider, model string, durationMs, latencyMs int64, audio AudioAssetInput) error
}

type TranscriptionSpeakerStore interface {
	SaveTranscriptionWithAudioAndSpeakers(ctx context.Context, text, language, provider, model string, durationMs, latencyMs int64, audio AudioAssetInput, speakers *speaker.DiarizationResult) error
}

type UserDictionaryEntry struct {
	ID         int64
	Spoken     string
	Canonical  string
	Language   string
	Source     string
	Enabled    bool
	UsageCount int
	CreatedAt  time.Time
	UpdatedAt  time.Time
}

type UserDictionaryStore interface {
	ReplaceUserDictionaryEntries(ctx context.Context, language string, entries []UserDictionaryEntry) error
	ListUserDictionaryEntries(ctx context.Context, language string) ([]UserDictionaryEntry, error)
	RecordUserDictionaryUsage(ctx context.Context, canonical, language string) error
}

type VoiceAgentSession struct {
	ID                int64                    `json:"id"`
	StartedAt         time.Time                `json:"startedAt"`
	EndedAt           time.Time                `json:"endedAt"`
	Language          string                   `json:"language"`
	ProviderProfileID string                   `json:"providerProfileId,omitempty"`
	RuntimeKind       string                   `json:"runtimeKind,omitempty"`
	Transcript        string                   `json:"transcript,omitempty"`
	Turns             []VoiceAgentTurn         `json:"turns,omitempty"`
	Summary           VoiceAgentSessionSummary `json:"summary"`
	CreatedAt         time.Time                `json:"createdAt"`
	OwnerUserID       string                   `json:"ownerUserId,omitempty"`
	OwnerOrgID        string                   `json:"ownerOrgId,omitempty"`
	OwnerSource       string                   `json:"ownerSource,omitempty"`
}

type VoiceAgentSessionStore interface {
	SaveVoiceAgentSession(ctx context.Context, session VoiceAgentSession) (int64, error)
	GetVoiceAgentSession(ctx context.Context, id int64) (*VoiceAgentSession, error)
	ListVoiceAgentSessions(ctx context.Context, opts ListOpts) ([]VoiceAgentSession, error)
}

type VoiceAgentSessionSummary struct {
	Title         string   `json:"title,omitempty"`
	Summary       string   `json:"summary"`
	Ideas         []string `json:"ideas,omitempty"`
	Decisions     []string `json:"decisions,omitempty"`
	OpenQuestions []string `json:"openQuestions,omitempty"`
	NextSteps     []string `json:"nextSteps,omitempty"`
	RawText       string   `json:"rawText,omitempty"`
}

type VoiceAgentTurn struct {
	Role      string    `json:"role"`
	Text      string    `json:"text"`
	CreatedAt time.Time `json:"createdAt,omitempty"`
}

type WakewordActivation struct {
	ID           string    `json:"id"`
	OwnerUserID  string    `json:"owner_user_id"`
	OwnerOrgID   string    `json:"owner_org_id"`
	PhraseID     string    `json:"phrase_id"`
	Phrase       string    `json:"phrase"`
	Backend      string    `json:"backend"`
	Score        float64   `json:"score"`
	CapturedAt   time.Time `json:"captured_at"`
	UploadedAt   time.Time `json:"uploaded_at"`
	Label        string    `json:"label,omitempty"`
	AudioPath    string    `json:"audio_path"`
	AudioBytes   int64     `json:"audio_bytes"`
	SampleRate   int       `json:"sample_rate"`
	PreRollMs    int       `json:"pre_roll_ms"`
	PostRollMs   int       `json:"post_roll_ms"`
	MetadataJSON string    `json:"metadata_json,omitempty"`
}

type WakewordActivationStore interface {
	// SaveWakewordActivation inserts a new activation row. Returns
	// the activation as stored (with uploaded_at populated by the
	// store). The ID field must be set by the caller (client-
	// generated ULIDs / sortable timestamps); empty ID is rejected.
	SaveWakewordActivation(ctx context.Context, a WakewordActivation) (*WakewordActivation, error)

	// GetWakewordActivation returns one activation by ID, scoped to
	// the supplied owner. Returns sql.ErrNoRows when the ID belongs
	// to a different scope so callers cannot leak existence info
	// across tenants.
	GetWakewordActivation(ctx context.Context, id, ownerUserID, ownerOrgID string) (*WakewordActivation, error)

	// ListWakewordActivations returns the caller's activations
	// (paginated newest-first). Use ListOpts.Limit + .Cursor for
	// pagination — the cursor is the captured_at timestamp of the
	// last item from the previous page.
	ListWakewordActivations(ctx context.Context, ownerUserID, ownerOrgID string, opts ListOpts) ([]WakewordActivation, error)

	// UpdateWakewordActivationLabel sets the label field (empty
	// string clears the label). Scoped to owner — returns
	// sql.ErrNoRows when the ID is in a different scope.
	UpdateWakewordActivationLabel(ctx context.Context, id, ownerUserID, ownerOrgID, label string) error

	// DeleteWakewordActivation removes the row + returns the
	// audio_path so the caller can unlink the file from disk. The
	// store itself does not touch the filesystem.
	DeleteWakewordActivation(ctx context.Context, id, ownerUserID, ownerOrgID string) (audioPath string, err error)

	// CountWakewordActivationsForUser returns the row count for one
	// owner. Used by quota enforcement (per_user_quota_bytes) and
	// the admin dashboard.
	CountWakewordActivationsForUser(ctx context.Context, ownerUserID, ownerOrgID string) (int64, error)

	// SumWakewordActivationBytesForUser returns the total audio_bytes
	// of all activations one owner has stored. Used by the quota
	// gate in the upload endpoint.
	SumWakewordActivationBytesForUser(ctx context.Context, ownerUserID, ownerOrgID string) (int64, error)
}

type WordStore interface {
	ReplaceWords(ctx context.Context, language string, words []speechcustomize.Word) error
	ListWords(ctx context.Context, opts CustomizationListOpts) ([]speechcustomize.Word, error)
	RecordWordUsage(ctx context.Context, term, language string) error
}