SeedStandardDataSet inserts the standard test data set: 1 source (test@gmail.com), 3 participants (Alice, Bob, Carol), 1 conversation, 5 messages, 3 l

SetEmbedEnqueuer wires up the optional vector-search enqueuer. Safe to call with nil to disable.

SimulateDeleteError injects a delete error for a specific message ID.

SimulateNotFound injects a 404 not-found error for a specific message ID.

Start begins listening for HTTP requests. Returns an error if the security posture is invalid.

VectorTableName returns the dimension-specific vec0 table name.

applyAggregateKeyWithCmd sends a key through handleAggregateKeys and returns Model and Cmd.

applySearchResultsWithStats simulates search results that include aggregate stats.

assertAttachmentCount checks the attachment count in the store.

assertSearchCount runs a search and verifies the number of results.

buildWhereClause builds WHERE conditions for Parquet queries. Column references use msg. prefix to be explicit since aggregate queries join multiple C

buildSearchConditions builds WHERE conditions for search queries. Shared by SearchFast and SearchFastCount. Note: These conditions reference msg and m

Search performs a Gmail-style search query. buildSearchQueryParts builds the WHERE conditions, args, and FTS join for a search query. This is shared b

computeMessageID computes a deterministic 16-char hex ID from the given parts.

countEmbeddingRowsPG returns the number of embedding rows for a generation in a live PG database. Used by the CLI delete-on-retire regression tests.

createMessagesForSource inserts count messages under srcID/convID and returns their IDs.

errOAuthNotConfigured returns a helpful error when OAuth client secrets are missing. It also searches for client_secret*.json files in common location

findDetailMatches finds all lines matching the detail search query.

---- test helpers ---- findLogLine returns the first record whose msg is exactly "sql".

float32SliceBlob converts a float32 slice to the little-endian byte representation that sqlite-vec expects.

genStateSV reads index_generations.state for a generation.

handleGlobalKeys handles keys common to all views (quit, help, mode toggle). Returns (model, cmd, true) if the key was handled, or (model, nil, false)

hasSQLite returns true if DuckDB's sqlite_scanner extension is loaded, allowing sqlite_db.* queries. On Windows this is always false.

hashFile computes the SHA-256 hash of a file on disk.

highlightTerms applies highlight styling to all occurrences of search terms in text. Terms are extracted from a search query string using search.Parse

installBinaryTo performs the actual binary installation with backup/restore logic. This is separated from installBinary for testability. On Windows,

isMediaType returns true if the WhatsApp message_type represents media.

nolint:unparam // rebind is a no-op here (no ? placeholders) but kept for signature symmetry with the other embedding-generation query helpers and the

loadSearch executes the search query based on current mode.

loadStats fetches total statistics.

loadTokenFile loads the full token file including scope metadata.

looksLikeEmail returns true for tokens that have the shape of an email address. Emails are matched case-insensitively in the identity store; other ide

mcpShouldUseParquet reports whether the MCP server should use the DuckDB/Parquet engine. This is the SQLite-only branch of the engine selection: Postg

newParquetBuilder creates a new builder for Parquet test fixtures.

newPendingDB returns an in-memory SQLite handle with just the pending_embeddings table the activation gate counts against.

openEmbeddingsMetadataDB opens the database that holds embedding generation metadata and returns a handle, a rebind function for SQL placeholders, a c

openPGEnqueueDB stands up a per-test schema on MSGVAULT_TEST_DB with the pgvector schema (index_generations + pending_embeddings). The Enqueuer only r

openServePGSchema creates an isolated per-test schema on MSGVAULT_TEST_DB and returns a pgx *sql.DB scoped to it plus the schema-scoped DSN string. se

openVectorsDBForEnqueue opens a vectors.db with the schema applied but NO generations. Useful for Enqueuer tests that insert their own generations.

parseAddressList parses an address header using enmime's AddressList method.

parseTextHTML parses a Google Voice text/SMS conversation HTML file. Returns the individual messages, group participant phones (if any), and any error

parseViewType parses a view type string into query.ViewType.

probeColumns checks which columns exist in a Parquet file. Returns a set of column names present in the schema. On any error, returns an empty map (ca

resolveParticipant resolves a handle ID to a participant ID in the store, creating the participant if needed.

sanitizeHeaderValue strips CR and LF characters to prevent header injection.

saveToken saves a token for the given email with the specified scopes.

searchFast is a test helper that parses a query string and calls SearchFast.

----------------------------------------------------------------------------- Key Application Helpers - remove handleXKeys casting boilerplate -------

setupExportAttachmentsTest creates a temp directory with a SQLite database containing a message with attachments and corresponding content-addressed f

setupTestSQLiteEmpty creates a test SQLite database with schema and metadata (sources, labels, participants) but zero messages. This simulates a fresh

snippet returns the first snippetMaxLen characters of s, suitable for message preview.

textContent returns the concatenated text content of a node and its children.

timeExpr returns the SQL expression for time grouping based on granularity.

truncateBytesRuneSafe returns s truncated to at most maxFTSBodyBytes bytes without splitting a multibyte UTF-8 rune. If s already fits it is returned

truncateTestString truncates a string to 60 characters for test output display.

vectorLiteral formats a float32 slice as pgvector's text input format, e.g. "[1.0,2.5,-3.14]". Bound via $N::vector this works without the pgvector-go

============================================================================ Helper Functions ========================================================

withAttachmentsDir creates a syncer with an attachments directory and returns the dir path.

AddAccountsFromConfig adds all enabled accounts from the config. Returns the number of accounts scheduled and any errors encountered.

AddSourceWithType adds a source with a specific type and returns its ID.

AddSourcesToCollection attaches sources to a collection. Idempotent. Rejects mutations of the auto-managed default collection.

Addr returns the "host:port" string.

AssertBatchDeleteCalls verifies the number of BatchDeleteMessages calls.

AssertDeleteCalls verifies the number of DeleteMessage calls.

AssertInProgressCount verifies the number of in-progress manifests.

AssertMessageNotDeleted asserts that a message has NOT been marked as deleted.

AssertResult verifies the final success and failure counts.

AssertTrashCalls verifies the number of TrashMessage calls.

AttachmentsToDir exports attachments as individual files into outputDir. It reads attachment content from attachmentsDir using content-hash based path

Available returns the current number of available tokens.

Begin returns a *loggedTx that inherits the rebind function, so statements issued inside the transaction are also rebound before reaching the driver.

Boundary sets the multipart boundary string.

Close logs out and disconnects from the IMAP server.