messageDetailView renders the full message.

mkEmlx creates an .emlx file with the given MIME bytes.

multibyteOversizedBody builds a body of MANY DISTINCT 2-byte multibyte tokens whose to_tsvector (before any truncation) exceeds PostgreSQL's 1MB tsvec

newTestEnvWithEmptyBuckets creates a test DB with messages that have empty senders, recipients, domains, and labels for testing MatchEmpty* filters.

newTestExporter creates a tokenExporter backed by the given httptest server.

normalizeAddr normalizes an address filter value. If it looks like a bare domain (e.g. "example.com"), it is prefixed with "@" so downstream engines t

normalizeRawMIME strips transport/export-specific headers before hashing.

openStoreAndInitForIngest is the ingest-command variant of openStoreAndInit. It uses runStartupMigrationsForIngest so that, on a fresh install with [i

parseCallHTML parses a Google Voice call log HTML file.

parseEmail combines makeRawEmail and mustParse into a single test helper.

parseMessageFilter extracts filter parameters from query parameters.

parseRetryAfter parses an HTTP Retry-After header (RFC 7231 §7.1.3), which may be either a non-negative delta-seconds integer or an HTTP-date. Returns

parseTime parses RFC3339 time string.

probeParquetColumns checks which columns exist in a Parquet table's files. Delegates to the standalone probeColumns in views.go.

pstArchiveFingerprint returns a short stable identifier for a PST file, derived from a SHA-256 over its first 4 KiB. The PST header in that range embe

renderExportAttachmentsModal renders the export attachments modal content.

repairOtherStrings repairs other string fields that could have encoding issues.

requireNullTime extracts a non-NULL time.Time from a sql.NullTime, with a clear error mentioning the field name. Required timestamps (created_at, upda

resetColumnCache clears the cached column info (for testing).

resolveLidSender resolves a "lid" JID sender to a phone number via the jid_map lookup table. Only activates when the sender's server is "lid". Returns

restrictToCurrentUser sets a DACL on path that grants GENERIC_ALL only to the current user and blocks inherited ACEs. For directories, the DACL includ

runScheduledSync performs a sync for a scheduled account. The dispatch is by source_type: Gmail accounts run an incremental sync using the Gmail Histo

sanitizeEmail sanitizes an email for use in a filename.

scanMessageRows scans the standard 9-column message row set (id, conversation_id, subject, message_type, from_email, sent_at, snippet, has_attachments

scopesForEmail returns the OAuth scopes appropriate for the given email. Personal Microsoft accounts use a different IMAP resource than org accounts.

seedAttachmentFile creates a file under attachmentsDir at relPath and returns its absolute path. Intermediate directories are created as needed.

seedPending inserts one pending_embeddings row per live message in the main schema. Uses ON CONFLICT DO NOTHING for idempotency on retries and to dedu

shellQuote returns a shell-safe quoted string using single quotes. Handles embedded single quotes by ending the quoted string, adding an escaped singl

spinnerIndicator returns the current spinner frame string.

testMIMEWithAttachment returns a MIME message with a binary attachment. Returns a fresh byte slice on each call to prevent cross-test mutation.

textRowCount returns the number of rows in the current text view.

toMessageSummary converts an APIMessage to a MessageSummary for API responses.

toUTC converts a time to UTC. If the original had a numeric offset, perform proper timezone conversion. Otherwise (named timezone only), keep the same

windowsFiletimeToTime converts a Windows FILETIME value (100-nanosecond intervals since 1601-01-01 UTC) to a time.Time. Returns zero time if ft == 0.

withRequestID sets the aggregate request ID for testing stale response handling.

withConn runs fn with the active connection, connecting if necessary. It holds the mutex for the duration of fn. If fn returns a network error the dea

withSearchQuery sets a search query on the model.

APIKey resolves the API key from the env var named in APIKeyEnv. Returns "" if APIKeyEnv is empty or the variable is unset.

AddConversation inserts a conversation and returns its ID.

AddRecipient adds a message_recipients row.

AssertIsScopeError verifies that the error is an insufficient scope error.

AssertManifestLastProcessedIndex verifies the persisted LastProcessedIndex.

AssertMessageDeleted asserts that a message has been marked as deleted.

AssertMessageHasLabel asserts that a message is linked to a specific label ID.

AssertNoActiveSync asserts there is no active sync for the fixture's source.

Attachments exports the given attachments into a zip file. It reads attachment content from attachmentsDir using content-hash based paths.

Build generates Parquet files from the accumulated data and returns the analytics directory path and a cleanup function.

BuildFTSTerm converts a slice of user-supplied search terms into a SQL expression and a single argument string. Both SQLite FTS5 and PostgreSQL tsquer

CORSMiddleware returns a middleware that handles CORS headers.

Cc sets the Cc header.

Cost returns the quota cost for an operation.

CountMessagesWithRaw returns the count of messages that have raw MIME stored.

CreateTarGz creates a tar.gz archive at path containing the given entries.

CredentialsPath returns the path to the credentials file for the given identifier.

DefaultExecuteOptions returns sensible defaults.

DeleteToken removes the token file for the given email.

EnableFTS creates the FTS5 table, populates it, and re-creates the engine to clear cached FTS state.

EnsureHomeDir creates the msgvault home directory if it doesn't exist.

EnsureVectorTable creates vectors_vec_dN for the given dimension if it does not already exist. The PARTITION KEY scopes rows by generation; the PRIMAR

Execute performs the deletion for a manifest.

ExecuteContext runs the root command with the given context, enabling graceful shutdown when the context is cancelled. Installs a panic recovery and c

FailNext forces the next n Embed calls to return an error.

FormatBytesLong formats bytes with full precision for export results.

FormatExportResult formats ExportStats into a human-readable string for display.

FormatMethodology returns a detailed explanation of how dedup works.

FormatReport renders a human-readable report of the scan results.

GetBatchDeleteCall safely retrieves a batch delete call by index.

GetIdentitiesForScope returns the union of confirmed identifier addresses across the given source IDs. Empty input returns an empty map — no global de

GetMessageFields returns selected fields of a message by ID.

InProgressDir returns the path to the in_progress directory.

InspectDisplayName returns the display name for a recipient of a message.

IsTransientNetwork reports whether err (or anything it wraps) indicates a transient network problem rather than a logical or auth failure. It catches

IsUUID returns true if s matches UUID format (8-4-4-4-12 hex).

LabelFromPath derives a human-readable label from a mailbox path relative to the root directory. Rules: - Strip root prefix - Strip known containers:

LastMessageID returns the ID of the most recently added message.

ListConversationMessages returns messages within a conversation.

ListConversations returns conversations matching the filter.