escapeILIKE escapes ILIKE wildcard characters (% and _) in user input.

keyEsc returns a KeyMsg for the Escape key.

loadData fetches aggregate data based on current view settings.

truncateRunes truncates a string to fit within maxWidth terminal cells. Uses runewidth to correctly handle full-width characters (CJK, emoji, etc.) th

CreateCollection inserts a new collection with the given name, description, and member source IDs.

CreateSourceWithHistory creates a source and sets its sync cursor for incremental sync tests. The returned Source has SyncCursor populated so it can b

NewManifest creates a new deletion manifest.

NewTestContext creates a new test context with all dependencies initialized.

UpsertFTS inserts or updates the FTS index for a message. No-op if FTS is not available.

handleAggregateKeys handles keys in the aggregate and sub-aggregate views.

runIncrementalSync runs an incremental sync and fails the test on error. Looks up the Gmail source for testEmail (all sync tests use "gmail" type).

seedMessages sets the profile totals/historyID and adds messages to the mock.

AttachmentsDir returns the path to the attachments directory.

BackfillFTS populates the FTS table from existing message data. Processes in batches to avoid blocking for minutes on large archives. The progress cal

DiscoverMailboxes walks an Apple Mail directory tree and returns all mailbox directories that contain .emlx files. If rootDir itself is a mailbox dir

GenerationFingerprint returns the full identifier used to compare an index generation against the configured policy. Format: "<model>:<dimension>:<pre

Stats

Release returns claimed rows to the pool so another worker can pick them up (for embedding failures). Only rows whose claim_token matches token are re

Stop gracefully stops the scheduler, cancels running sync jobs, and waits for them to finish. Returns a context that is done when all work completes.

UpdateSourceDisplayName updates the display name for a source.

assertPending asserts the number of pending rows for gen.

newTestHandlers creates a handlers instance with the given mock engine.

parquetCTEs returns common CTEs for reading all Parquet tables. This is used by aggregate queries that need to join across tables. parquetCTEs returns

setupTestSQLite creates a test SQLite database with realistic email data.

--------------------------------------------------------------------------- SQL generation -----------------------------------------------------------

ConfigFilePath returns the path to the config file. If a config was loaded (including via --config), returns the actual path used. Otherwise returns t

Save writes the current configuration to disk atomically. Uses temp file + rename to prevent partial writes on crash. Enforces 0600 permissions regard

Scan finds all duplicate groups that dedup would prune. AccountSourceIDs must be non-empty to prevent accidental cross-account grouping; the CLI ensur

SearchFast searches message metadata only (no body text). This is much faster for large archives as it queries Parquet files directly. Searches: subje

captureStdout redirects os.Stdout to a pipe and returns a function that restores the original stdout and returns captured output. The pipe is drained

confirmDefaultIdentity writes one confirmed identifier to a freshly created source's identity. Best-effort: any error is logged and swallowed so a par

seedThree wires up a 3-message corpus with distinct vectors and distinct keyword content so each test below can mix-and-match signal/filter combinatio

CompleteSync marks a sync as successfully completed.

EnsureConversationWithType gets or creates a conversation with an explicit conversation_type. Unlike EnsureConversation (which hardcodes 'email_thread

IsPostgresURL returns true if the path looks like a PostgreSQL connection URL. Exported so cmd-side helpers can decide whether to skip SQLite-only cod

MustGetTotalStats calls GetTotalStats and fails the test on error.

NewDuckDBEngine creates a new DuckDB-backed query engine. analyticsDir should point to ~/.msgvault/analytics/ sqlitePath should point to ~/.msgvault/m

Open verifies the database is reachable, applies the embedding schema (creating the vector extension if necessary), and returns a Backend. The DB hand

Reset clears all state and call tracking.

SetEmptyTarget adds the given ViewType to EmptyValueTargets. Initializes the map if nil.

addEmptyTable adds an empty table (schema only, no rows) to be written as Parquet.

assertSearchQuery checks the model's searchQuery field.

buildGenWithVectors creates a fresh building generation, upserts one chunk per supplied (message_id -> vector), clears pending, and returns the gen id

hasClass checks if an HTML element has the given class.

hasDrillFilter returns true if drillFilter has any filter criteria set.

History event builders — construct gmail.HistoryRecord values succinctly.

newTestModelWithRows creates a test model pre-populated with aggregate rows. The model is returned with loading=false since data is present. Use NewBu

HTML parsing helpers walkNodes recursively walks the HTML node tree, calling fn for each node. If fn returns true, the children of that node are skipp

AddLabel adds a label and returns its ID. Name must be non-empty.

CreateMessages inserts count messages with IDs "msg-0" .. "msg-(count-1)".

GetMessageRaw returns the decompressed raw MIME data for a message. Returns nil, nil if no raw data is stored for the given ID.

HintRepairEncoding wraps err with a user-facing hint suggesting `msgvault repair-encoding` when the error is an encoding error. If err is nil or unrel

NewSQLiteEngine creates a new SQLite-backed query engine.

NewServerWithOptions creates a new API server with full options including query engine.

Parse parses an .emlx file from its raw bytes.

ReplaceMessageLabels replaces all labels for a message atomically.

SkipIfPostgres skips the calling test when MSGVAULT_TEST_DB targets PostgreSQL. Use this for tests that exercise SQLite-only constructs (FTS5 MATCH, P

appendSourceFilter returns conditions/args updated with a source-id filter drawn from either SourceIDs (multi) or SourceID (single). SourceIDs takes p

assertCmd checks whether a command is nil or non-nil as expected.

assertMessageHasLabel checks that a message has a specific label (by source_label_id).

createAttachmentFile creates a file in the content-addressed storage layout (root/<hash[:2]>/<hash>) and returns the SHA-256 hex hash of the content.

handleErrorResponse reads an error response and returns an appropriate error.

isSQLiteError checks if err is a sqlite3.Error with a message containing substr. This is more robust than strings.Contains on err.Error() because it f

keyTab returns a KeyMsg for the Tab key.

openPGQueueDB stands up a per-test schema seeded with n pending rows and returns the *sql.DB. Thin wrapper over newPGQueueSchema for the common single

openVectorsDBWithPending opens a fresh vectors.db with one generation (id=1) and n pending rows for that generation. The database is closed automatica

resizeModel sends a WindowSizeMsg and returns the updated model.

runPostSourceCreateMigrations re-runs startup migrations after the caller has just created a source. The legacy identity migration defers when no sour

seedAndEmbed inserts any missing message rows, creates a building generation sized to the first vector, upserts every supplied vector as a chunk, and

ensureThreadCursorVisible adjusts scroll offset to keep cursor visible in thread view. navigateDetailPrev navigates to the previous message in list/th

testManager creates a Manager in a temp directory for testing.

withTx executes fn within a database transaction. If fn returns an error, the transaction is rolled back; otherwise it is committed. The callback rece

CreateSource creates a source without setting a sync cursor (for full sync tests).