sendMsg sends any tea.Msg through Update and returns the concrete Model.

sourceOAuthApp extracts the oauth app name from a Source, returning "" for the default app.

Helper functions.

AttachmentPathsUniqueToSource returns storage_path values for attachments belonging to sourceID whose content_hash is not shared with any other source

EnsureLabels creates labels and returns a map of sourceLabelID → internal ID.

EnsureParticipantsBatch gets or creates participants in batch. Returns a map of email -> participant ID.

Fuse combines two ranked lists via Reciprocal Rank Fusion. - rrfK: standard RRF constant (60 is typical). - boost: >=1.0 multiplier appl

HasAnyConfig returns true if any OAuth configuration exists (default or named apps).

IsAttachmentPathReferenced returns true if any attachment record still points to the given storage_path. Use this immediately before deleting a file t

IsMigrationApplied reports whether the named one-time data migration has already run.

IsRemoteMode returns true if commands should use remote server. Resolution order: 1. --local flag → always local 2. [remote].url set in config → use r

Migrate enables the pgvector extension and applies the embedding schema. Safe to run on every startup: every statement uses IF NOT EXISTS or its equiv

MustLookupParticipant returns the ID of the participant with the given email, failing the test if not found.

NewMessageDetail creates a builder with sensible defaults.

NewRateLimiter creates a rate limiter with the specified QPS. A qps of 5 is the default safe rate for Gmail API. QPS is clamped to a minimum of MinQPS

NewServiceAccountManager creates a manager from a service account JSON key file.

ParseFile reads a .vcf file and returns parsed contacts. Handles vCard 2.1 and 3.0 formats, including RFC 2425 line folding and QUOTED-PRINTABLE encod

PendingDir returns the path to the pending directory.

TokenSource returns a function that provides fresh access tokens. Suitable for passing to imap.WithTokenSource. The returned function is safe for conc

UpdateSourceSyncCursor updates the sync cursor (historyId) for a source.

WithAttachment adds an attachment to the message.

WithLogger sets the logger.

assertAggregateCounts verifies that every key in want exists in got with the expected count, and that there are no extra rows.

assertSelected checks that the given key is selected.

cacheNeedsBuild checks if the analytics cache needs to be built or updated. Collects all staleness signals before returning so that e.g. a mixed add+d

escapeLike escapes SQL LIKE special characters (%, _) so they are matched literally. The escaped string should be used with ESCAPE '\'.

hasCol returns true if the named column exists in the Parquet schema for the given table.

inlineURL builds the inline endpoint URL for a given message ID and CID, URL-encoding the CID so values with reserved characters (including `/`) round

insertPGGeneration inserts an index_generations row with an explicit id and state so the test can control which generations are non-retired.

limitArg extracts a non-negative integer limit from a map, with a default. JSON numbers arrive as float64. Clamps to maxLimit to prevent excessive res

loadToken loads a saved token for the given email.

mkMailbox creates a mock legacy Apple Mail mailbox structure with a direct Messages/ subdirectory.

normalizePhone normalizes a WhatsApp JID user+server to an E.164 phone number. Input: user="447700900000", server="s.whatsapp.net" Output: "+447700900

openLoggedMem opens an in-memory sqlite DB wrapped by loggedDB.

openPGTestDB connects to MSGVAULT_TEST_DB on its own per-test schema and applies the minimum main-schema scaffolding the backend's SELECT/JOIN paths e

requireAggregateRow finds an AggregateRow by key or fails the test.

resolveTokenEmail verifies the ID token and validates the authenticated email matches the expected address. Uses OIDC signature/issuer/audience valida

saveCheckpoint persists the current execution progress to disk.

setupVectorFeatures builds the vector backend, hybrid engine, embed worker, and enqueuer used by the serve daemon and the MCP command. The backend is

standardStats returns a fresh stats object (1000 msgs, ~5MB, 50 attachments) for each call, preventing cross-test state leakage.

viewTypePrefix returns a short prefix for drill-down breadcrumbs (e.g., "S:" for Sender).

writeEmbeddings writes an OpenAI-compatible embeddings response using the provided vectors. It panics on encoding failure; that never happens for fixe

Advance moves the clock forward and fires any pending timers.

ApplyDefaults fills in sensible defaults for any zero-valued fields. Called after TOML decode, before Validate.

AssertRecipientCount asserts the number of recipients of a given type for a message.

Build returns the constructed Manifest.

BuildManifest starts building a Manifest with sensible defaults. If no IDs are provided, defaults to {"id1", "id2"}.

CancelManifest moves a pending or in-progress manifest to the cancelled directory and updates its inline Status field. Returns an error if the manifes

CreateManifest creates a manifest with the given name and Gmail IDs.

DeleteMessage permanently deletes a message.

GetBodyText returns the best available body text. Prefers plain text, falls back to stripped HTML.

GetSourcesByIdentifier returns all sources matching an identifier, regardless of source_type. Use this when the identifier may be shared across source

GetStatsForScope returns statistics scoped to the given source IDs. When sourceIDs is nil or empty, returns global counts. All message-derived counts

InspectMessage retrieves detailed message information for test assertions. This consolidates multiple schema-aware queries into a single method, keepi

IsEmpty reports whether the scope resolved to nothing.

Account queries

LoadManifest reads a manifest from a JSON file.

MarkDeletedByID marks a message as deleted by its internal ID.

MessageExistsBatch checks which message IDs already exist in the database. Returns a map of source_message_id -> internal message_id for existing mess

MkTempDir creates a temporary directory with fallback logic for restricted environments (e.g. Windows where %TEMP% may be inaccessible due to permissi

New creates a new TUI model with the given options.

Parse parses raw MIME data into a Message.

ParseE2EEJSONFile parses a single E2EE flat-export JSON file and returns a populated Thread. rootDir is the export root (used for resolving media path

Rate returns the message-weighted rate in messages per second. Returns 0 when the window is empty so callers can treat 0 as "no estimate yet" and fall

SearchFastWithStats performs a fast metadata search and returns paginated results, total count, and aggregate stats in a single operation. The DuckDB

SecureChmod changes the mode of the named file.

SetOptions replaces the Syncer with one configured by the given modifier function.

Slug normalizes a Facebook display name into a deterministic ASCII slug usable as the local-part of a synthetic email address. Diacritics are stripped

StageForDeletion is a test helper that calls the controller's StageForDeletion method with sensible defaults, failing the test on error.

WalkFolders walks all folders in the PST file recursively, building slash-separated folder paths. Search folders are skipped automatically. Returns th

assertNotSelected checks that the given key is not selected.

assertViewFitsHeight checks that the rendered view fits within the given height.

createFakeParquet creates fake parquet files for all required directories to simulate a complete existing cache.

getAttr returns the value of the named attribute, or empty string.

int64Array formats an int64 slice as the PostgreSQL array literal "{1,2,3}". Bound via $N::bigint[].

isPgError checks if err is a pgconn.PgError with the given SQLSTATE code.

joinRows maps each item to a SQL row string and joins them with commas.

loadMessages fetches messages based on current filter (first page).

logStmtWith is the explicit form that lets callers add extra structured attributes (used by Exec to report rows_affected). On WARN-level lines (slow

newRateWindow constructs a ring buffer of the given capacity. A non-positive cap is normalized to 1 so callers can always Add and Rate without checkin

normalizeMCPHTTPAddr canonicalises a --http argument and rejects values that would expose the unauthenticated MCP server on a non-loopback interface u

pendingCount returns the number of pending_embeddings rows for a generation.

pgCountAvailable returns the number of available (unclaimed) rows for the single building generation (id=1) that newPGQueueSchema seeds — the only gen

processBatch processes a single batch of messages from a list response.

request makes an HTTP request with rate limiting and retry logic. bodyBytes can be nil for requests without a body.

seedMessage inserts a message with the given subject and snippet, returning its ID. SentAt is left NULL so COALESCE returns NULL (avoids SQLite string

state returns a snapshot of the limiter's refill rate and throttle deadline under the mutex.

timeToAppleTimestamp converts a time.Time to an Apple epoch timestamp. If useNano is true, returns nanoseconds; otherwise returns seconds.