wrapOAuthError wraps an oauth/client-secrets error with setup instructions if the root cause is a missing or unreadable secrets file.

AddPhoneParticipant adds a phone-only participant (no email/domain) and returns its ID. Mirrors the iMessage/SMS shape: phone_number set, email_addres

Address returns a deterministic synthetic mime.Address for the given Facebook display name. The name is preserved verbatim; the email local-part is Sl

AssertCompletedCount verifies the number of completed manifests.

Build serializes the error to JSON bytes.

CountMessagesForSource returns the count of messages for a specific source (account).

CreateZip creates a zip archive at path containing the given entries.

DisplayName returns a human-readable label for the scope.

EffectiveAuthMethod returns the auth method, defaulting to password when the field is empty (backward compatibility with existing configs).

EncodedSamples returns a fresh copy of all encoded byte samples, safe for mutation by individual tests without cross-test coupling. MAINTAINER NOTE:

EnqueueMessages adds the given IDs to pending_embeddings for every generation not in state 'retired'. Duplicate IDs are silently ignored via INSERT OR

Fingerprint returns a stable, debuggable identifier for the effective preprocessing policy. Format: "p<ver>-<flags>" where ver is the preprocessVersio

GetEncodingByName returns an encoding for the given IANA charset name.

GetSourcesByIdentifierOrDisplayName returns all sources whose identifier or display_name matches the given value. This is the preferred single-query l

ListPending returns all pending deletion manifests.

MakeSet builds a map[T]bool from the given items. Useful for constructing selection sets in tests.

MarkMessageDeletedByGmailID marks a message as deleted by its Gmail ID. This is used by the deletion executor which only has the Gmail message ID. Whe

MessageExistsWithRawBatch checks which message IDs already exist in the database and have raw MIME data stored. Returns a map of source_message_id ->

MustNotExist fails the test if the path exists or if there's an error other than "not exist" (e.g., permission denied).

NewEnqueuer returns an Enqueuer backed by the embeddings database (vectors.db on SQLite, the shared main DB on PostgreSQL). rebind and insertOrIgnore

NewGmailError starts building a Gmail API error with the given HTTP status code.

NewMessage creates a builder with sensible defaults. NewMessage creates a builder with sensible defaults. It uses a global counter to generate unique

Offset reports the current logical read offset (bytes consumed) within the underlying stream, accounting for buffered data.

ParseHTMLThread parses a DYI HTML thread directory and returns a Thread.

Samples returns the number of valid entries currently in the window. Useful for the printer's "(last K)" annotation when the run hasn't yet emitted en

SearchFastCount returns the total count of messages matching a search query. This is used for pagination UI to show "N of M results".

SimulateBatchDeleteError sets the batch delete operation to fail.

Start begins executing scheduled jobs.

WhereClause renders an equality predicate of the form "LOWER(<column>) = LOWER(?)" for email-shaped identifiers and "<column> = ?" for everything else

WithPageSizeRaw sets pageSize without clamping, allowing zero/negative values for edge-case testing.

assertAggRows verifies that aggregate rows contain the expected key/count pairs in the exact order given. This ensures both correctness and default so

assertDeletedFromSource checks whether a message has deleted_from_source_at set.

assertListCount calls a list function and asserts the returned slice length.

assertSelectionCount checks the number of selected items.

callToolDirect invokes a handler directly with the given arguments and returns the raw result.

createTestManifest creates a manifest via the manager with default IDs.

doRequest performs an authenticated HTTP GET request against the background context. The remote API is read-only, so every request is a body-less GET.

doRequestWithContext performs an authenticated, body-less HTTP GET request with context support.

escapeSQLiteLike escapes LIKE wildcard characters (%, _, \) with \.

fetchChats returns all non-hidden chats from the WhatsApp database. Joins with the jid table to get JID details for each chat. Handles old WhatsApp sc

findLogLineByMsg is like findLogLine but returns nil rather than failing so callers can assert absence.

footerView renders the footer with keybindings.

installFromArchiveTo verifies the checksum, extracts the archive, and installs the binary to dstPath. It handles both .zip and .tar.gz archives. If pr

isNetworkError reports whether err indicates the underlying TCP connection was closed or timed out, meaning the IMAP session must be re-established.

loadTextData dispatches the appropriate load command based on the current navigation level. Checking level (not just viewType) is necessary because dr

newEmptyBucketsEngine creates a DuckDBEngine backed by Parquet test data that includes messages with empty senders, recipients, domains, and labels.

newMockEngine creates a querytest.MockEngine configured for TUI testing. The messages slice is returned from ListMessages, Search, SearchFast, and Sea

normalizeStmt collapses whitespace in a SQL statement and truncates it to maxChars (measured in runes, not bytes, so multi-byte UTF-8 in literals or c

resolveRelative makes a relative path absolute by joining it with base. Absolute paths and empty strings are returned unchanged.

runTool invokes a handler, asserts no error, and unmarshals the JSON result into T.

setupScopeFixture creates a store with one source and one collection for resolver tests. Returns the store, source identifier, and collection name.

skipUnlessPostgres skips the calling test unless MSGVAULT_TEST_DB points at PostgreSQL. The tsvector 1MB limit and its body cap are PostgreSQL-only —

startSpinner returns a spinnerTick command if the spinner isn't already active, and marks it as active. Call this when loading begins.

writeQP writes s as quoted-printable text to dst. Lines longer than 76 characters are soft-wrapped with "=\r\n". Trailing whitespace before line break

writeSyncState writes a _last_sync.json file to the analytics directory.

writeTestToken writes a fake token file for the test account.

AddAttachment adds an attachment row and sets HasAttachments on the related message.

BindValue returns the value to bind for the placeholder in WhereClause. Equal to the raw input — case-folding happens in SQL via LOWER, not in Go, so

Build returns the constructed Message.

BuildRFC5322 constructs raw RFC 5322/MIME bytes from a MessageEntry and its attachments. Strategy: 1. If TransportHeaders is non-empty, use those ver

Clone returns a deep copy of the MessageFilter. This is necessary because EmptyValueTargets is a map, and a simple struct copy would share the underly

Close checkpoints the WAL (unless read-only) and closes the database.

CollapseWhitespaceEnabled returns the effective collapse_whitespace setting. Defaults to true when the field is unset — HTML→text conversion routinely

CreateExclusiveFile atomically creates a file that doesn't already exist, trying path, path_1, path_2, etc. on conflict. Returns the open file and the

CreateManifest creates and saves a new manifest.

DefaultOptions returns sensible defaults.

EnsureDefaultCollection creates the auto-managed default collection if it doesn't exist and adds all current sources to it. Safe to call on every sche

Execute runs the executor with default options.

ExportAttachments performs the export logic.

Full performs a full synchronization.

HasCompleteParquetData checks that all required parquet tables exist. Use this instead of HasParquetData when enabling DuckDB, since DuckDB unconditio

IsBusyError reports whether err indicates write contention that a bounded retry loop should treat as "retry later". The SQLSTATEs covered: - 55P03 (l

MoveManifest moves a manifest from one status directory to another.

MustExist fails the test if the path does not exist or cannot be accessed.

NewDeletionMockAPI creates a new deletion mock with empty state.

NewExecutor creates a deletion executor.

NewTestDB creates an in-memory SQLite database with the production schema loaded. schemaPath is the path to schema.sql (e.g. "../store/schema.sql" fro

ParseFromSeparatorDateStrict parses the ctime-like date portion of an mbox "From " separator line, but only accepts numeric offsets or a small allowli

PersistMessage atomically stores a message plus its body, raw MIME, recipients, and labels in a single transaction. Returns the message ID.

RecordSyncRunItem records a per-item sync outcome for diagnostics.

RemoveSource deletes a source and all its associated data. FTS5 rows are cleaned up explicitly (no FK cascade for virtual tables). CASCADE handles con

RemoveSourceSerialized deletes a source while holding an exclusive write lock, and reports whether any sync was running at the moment the lock was acq

SanitizeFTSQuery builds a tsquery arg from a single user string using the allowlist tokenizer sqldialect.EscapeTSQueryTerm: the input is split on ever