Discover walks a DYI export root and returns one ThreadDir per thread directory found, sorted by (Section, Name). Absolute and relative root inputs yi

ExecuteBatch runs the batch executor.

GetCollectionByName returns the collection with the given name and its member source IDs.

GetManifest loads a manifest by ID from any status directory.

Incremental performs an incremental sync using the Gmail History API. Falls back to full sync if history is too old (404 error). The caller must reso

InsertOrIgnore rewrites a complete INSERT statement to silently ignore conflicts. SQLite: INSERT OR IGNORE INTO ... PostgreSQL: INSERT INTO ... ON CO

MigrateLegacyIdentityConfig migrates a list of legacy global identity addresses into per-account confirmed records. It runs at most once: subsequent c

NewMessageSummary creates a builder with sensible defaults.

ParseJSONThread parses every message_*.json file in a DYI thread directory and returns a populated Thread. rootDir is the DYI export root; threadDir i

ResolveAccountFlag resolves the value of an --account flag. It rejects collection names with a hint to use --collection.

SetEmbedJob registers the embed job on a cron schedule. If schedule is empty, no cron entry is created (the job can still fire via the post-sync hook

SourceIDs returns the source IDs that this scope expands to.

UpdateSourceOAuthApp updates the OAuth app binding for a source. Pass a null NullString to clear the binding (use default app).

applyMessageListKeyWithCmd sends a key through handleMessageListKeys and returns Model and Cmd.

applySearchResults simulates the arrival of search results via Update.

assertContextStats checks contextStats fields. Use -1 for size or attachments to skip that check.

captureSlog installs a JSON handler over buf as the default slog logger at debug level for the duration of a test. Returns a cleanup closure that rest

----------------------------------------------------------------------------- View Fit Helpers - centralize line counting and resize logic -----------

createTestSourceDB creates a source database with schema and test data. Returns the path to the database.

export validates inputs, reads the local token, uploads it to the remote server, and registers the account.

keyDown returns a KeyMsg for the Down arrow key.

makeIDToken builds a minimal unsigned JWT with the given claims. Used in tests with verifyIDTokenFn to bypass OIDC signature validation.

mkMailboxDir creates an Apple Mail mailbox directory with .emlx files.

newTestStore creates a Store pointing at the given httptest server.

pickEmbedGeneration resolves which generation this embed run should target. Returns (gen, rebuildInProgress, err): - FullRebuild: prompt for confirma

rebuildCacheAfterWrite rebuilds the analytics cache after a write operation. Uses the staleness check to determine whether a full rebuild (deletions/m

renderInfoLine renders the info/notification line with optional right-aligned loading spinner. Used on the second-to-last line of table views (before

ActiveGeneration returns the current active generation, or ErrNoActiveGeneration if none exists.

AddMessageLabels adds labels to a message without removing existing ones. Uses INSERT OR IGNORE to skip labels that already exist.

AnalyticsDir returns the path to the Parquet analytics directory.

Close releases DuckDB resources, including any cached search temp table.

128 MiB ImportPst imports all email messages from a PST file into the msgvault database. Folder structure is preserved as labels. Non-email items (ca

SaveManifest saves a manifest to the appropriate directory based on status.

ServiceAccountKeyFor returns the service account key path for the given app name. Empty name returns the default. Non-empty name looks up Apps[name].

assertModal checks that the model is in the expected modal state.

confirmDestructive prompts on the provided writer and reads a single line of input from the provided reader. Returns (true, nil) on confirmation, (fal

countAvailable returns the number of rows for gen whose claimed_at IS NULL (i.e. available to be claimed).

countPendingRows returns the number of pending_embeddings rows belonging to a generation. Used by the retire-cleans-pending tests (cr2-2/cr2-3/cr2-4).

detailPageSize returns the page size for detail view (2 more than table views).

expandPath expands ~ to the user's home directory. Only expands paths that are exactly "~" or start with "~/". It also strips surrounding single or do

formatBytes formats a byte count as a human-readable string (e.g., "1.5 KB").

hasFTSTable checks if the FTS index is available for this dialect. Result is cached after first successful check. Errors cause retries on next call. T

openStderrSink returns a *os.File pointing at /dev/null so pickEmbedGeneration's status prints do not clutter test output.

safeCmdWithPanic wraps an async operation with panic recovery. The errMsg function converts a panic value into the appropriate message type. This elim

ClientSecretsFor returns the client secrets path for the given app name. Empty name returns the default. Non-empty name looks up Apps[name].

CollectStats assembles a StatsView for the stats endpoints. Returns (nil, nil) when the backend is nil (vector search disabled); callers can attach th

DatabasePath returns the on-disk SQLite filesystem path for backup operations (VACUUM INTO, copies). It accepts the plain filesystem path and the SQLi

EnsureLabelsBatch ensures all labels exist and returns a map of source_label_id -> internal ID. Runs in a single transaction with a two-phase rename t

Identifier returns a canonical string like "imaps://user@host:port". The scheme encodes the transport mode: imaps (TLS), imap+starttls (STARTTLS), or

MergeFilterIntoQuery combines a MessageFilter context with a search.Query. Context filters are appended to existing query filters. Note on semantics:

Migrate runs the baseline schema and ensures a vec0 virtual table for `defaultDim` exists. Safe to run on every startup. PRAGMA foreign_keys is appli

NeedsFTSBackfill reports whether the FTS index needs to be populated.

New creates a new remote store.

New creates a new Syncer.

NewReader creates a new MBOX reader.

NormalizePhone normalizes a phone number to E.164 format. Returns an error for inputs that are not phone numbers (emails, short codes, system identifi

RecomputeConversationStats updates the denormalized stats columns on all conversations belonging to the given source. It recomputes message_count, par

RegisterExtension reports that sqlite-vec is unavailable in this build.

ResolveActiveForFingerprint returns the active generation if its fingerprint matches the supplied one. Production callers pass Config.GenerationFinger

ResolveCollectionFlag resolves the value of a --collection flag. It rejects account identifiers with a hint to use --account.

Save writes the manifest to a JSON file.

SecureMkdirAll creates a directory path and all parents that do not yet exist.

SetEmptyAttachments marks the attachments table as empty (schema only).

Throttle temporarily reduces the rate when we hit API rate limits. This provides adaptive back-pressure when Gmail returns 429/403 quota errors.

TrashMessage moves a message to trash (recoverable for 30 days).

clampDetailScroll ensures detailScroll stays within valid bounds.

genState returns the index_generations.state for a generation.

getDateArg extracts an optional date (YYYY-MM-DD) from the arguments map.

headerView renders a two-level header: Line 1: msgvault [version] - account Line 2: breadcrumb | stats.

newTestModelAtLevel creates a test model at the specified navigation level. This helper uses the TestModelBuilder internally for consistency.

openTestBackend opens a fresh in-memory-ish sqlitevec backend with a single pre-seeded message so CreateGeneration has something to enqueue.

parquetPath returns the path pattern for a specific Parquet table.

queryRowContext runs QueryRowContext with dialect-aware placeholder rebinding.

recordCall records a call to the sequence log. Must be called with mutex held.

renderView renders the current view based on the active level. Separated from View() so transitions can capture the current output before changing sta

runMaintenance runs fn inside a single transaction with the per-statement execution timeout disabled (finding S1). It is the one chokepoint for mainte

selectMailbox selects a mailbox if not already selected. Caller must hold mu.