// Package domain holds Tapir's core entities. It depends on nothing outside // the standard library — no providers, no storage, no AI. See docs/data-model.md. package domain import ( "errors" "fmt" "time" ) // ErrVideoNotFound is returned when a video id resolves to no video (deleted, // private, or a typo'd paste). Defined in domain so adapters and the web layer // share one sentinel without coupling to each other. var ErrVideoNotFound = errors.New("video not found") // ErrChannelUnavailable is returned by a VideoSource when a channel's upload // playlist returns HTTP 404 — the channel was deleted or made private. The runner // stores these so the account page can surface them to the user. type ErrChannelUnavailable struct { ChannelID string ChannelTitle string } func (e *ErrChannelUnavailable) Error() string { return fmt.Sprintf("channel %q (%s) unavailable: playlist not found", e.ChannelTitle, e.ChannelID) } // Provider identifies a video platform. type Provider string const ( ProviderYouTube Provider = "youtube" ProviderVimeo Provider = "vimeo" ) // TranscriptSource records how a transcript was obtained (or that there was none). type TranscriptSource string const ( SourceCaptions TranscriptSource = "captions" SourceNone TranscriptSource = "none" // SourceRateLimited records that the caption endpoint returned HTTP 429. // Unlike SourceNone (a permanent absence), this is a transient "retry later": // the IP is rate-limited, not the video caption-less. It carries no text // (HasText is false), so the engine degrades the same as SourceNone, but the // runner persists it distinctly to retry after a backoff window. SourceRateLimited TranscriptSource = "rate_limited" ) // User is the Tapir-side profile. At Stage 0 there is exactly one. type User struct { ID string DisplayName string CreatedAt time.Time } // Subscription is a watched channel on a connected account. type Subscription struct { ID string UserID string ConnectionID string ChannelID string ChannelTitle string Active bool } // Video is a single video seen for a user (per-user, not globally deduped — // see docs/data-model.md and DECISIONS.md "Rejected alternatives"). type Video struct { ID string UserID string SubscriptionID string Provider Provider ProviderVideoID string Title string ChannelTitle string URL string PublishedAt time.Time SeenAt time.Time // DurationSeconds is the video length in seconds, when known (fetched by the // ADR-023 videos.list enrichment at discovery). 0 means unknown — the store // preserves a previously-known value rather than overwriting it with 0, and // the onboarding burst (ADR-028) treats unknown as degrade-open (kept). DurationSeconds int } // Transcript is the text of a video (or a record that none was available). type Transcript struct { VideoID string UserID string Source TranscriptSource Language string Content string // empty when Source == SourceNone } // HasText reports whether the transcript carries usable text. func (t Transcript) HasText() bool { return t.Source != SourceNone && t.Content != "" } // Summary is the produced output for a video. type Summary struct { ID string UserID string VideoID string Summary string Highlights []string Takeaways []string AIProvider string // "local" | "anthropic" | "openai" | "gemini" AIModel string FallbackUsed bool CreatedAt time.Time } // Segment is one timed span of a transcription. Times are seconds from the start // of the audio. type Segment struct { Start float64 `json:"start"` End float64 `json:"end"` Text string `json:"text"` } // Transcription is the result of transcribing user-supplied audio (ADR-033): // the full text, its timed segments, which backend served it, and how long the // audio was. Endpoint is recorded because the backends differ in timestamp // granularity — which one served a transcript is a quality fact. type Transcription struct { Text string Segments []Segment Endpoint string AudioSeconds float64 } // UploadStatus is the state of an uploaded-audio transcription job. type UploadStatus string const ( UploadQueued UploadStatus = "queued" UploadTranscribing UploadStatus = "transcribing" UploadDone UploadStatus = "done" UploadFailed UploadStatus = "failed" ) // UploadErrorKind is the typed reason an upload failed. It is deliberately NOT a // provider's error string: the whisper server's "failed to process audio" has had // at least five distinct causes, so nothing may branch on it (ADR-033). type UploadErrorKind string const ( // UploadErrInterrupted: the process restarted mid-job. The audio is not // retained, so the job cannot resume; the user re-uploads. UploadErrInterrupted UploadErrorKind = "interrupted" // UploadErrTranscriptionFailed: every configured transcription endpoint failed. UploadErrTranscriptionFailed UploadErrorKind = "transcription_failed" ) // UploadedTranscript is a user's PRIVATE transcript of audio they uploaded. It is // never stored in, or merged with, the shared public-caption Transcript (ADR-021). // Content and Segments are empty until Status is UploadDone. type UploadedTranscript struct { ID string UserID string Title string Status UploadStatus Content string Segments []Segment Endpoint string AudioSeconds float64 ErrorKind UploadErrorKind CreatedAt time.Time FinishedAt time.Time // zero until the job reaches done or failed }