Run executes one embed cycle. Safe to call from cron or as a post-sync hook. Returns immediately when vector search has no pending work (no active and

Close releases any resources held by the client.

DB returns the underlying *sql.DB for consumers that need to pass the raw handle elsewhere (e.g. the DuckDB engine's sqlite_scan wrapper). The wrapper

New creates a Fixture with a fresh test database, one source ("test@example.com") and one default conversation.

QueryRowContext logs and delegates.

GetOrCreateSource gets or creates a source by type and identifier. Concurrent first-inserts converge via INSERT ... ON CONFLICT DO UPDATE RETURNING: t

Open opens or creates the database at the given path. If dbPath is a postgres:// or postgresql:// URL, opens a PostgreSQL connection. Otherwise, opens

Date sets the Date header.

InitSchema initializes the database schema. This creates all tables if they don't exist.

Add records one batch sample. Samples with non-positive elapsed are silently skipped: they would either divide by zero (elapsed == 0) or contribute ne

Header sets an arbitrary header. If the key already exists, its value is overwritten (last-write-wins); otherwise the header is appended.

Next returns the next message from the MBOX stream. Returns io.EOF when there are no more messages.

unitVec returns a unit vector of the given dimension with 1.0 at position axis and 0.0 elsewhere.

unitVec returns a unit vector of the given dimension with 1.0 at position axis and 0.0 elsewhere — the building block for similarity assertions where

asModel asserts that a tea.Model is the concrete Model type, failing the test otherwise. Centralizes the checked type assertion used across the TUI te

CreateGeneration starts (or resumes) a building generation. fingerprint is stored verbatim on the row; pass Config.GenerationFingerprint() so a later

Rebind converts ? placeholders to the driver's native form. No-op for SQLite; converts to $1, $2, ... for PostgreSQL.

Bytes builds the complete MIME message.

NewTestStore creates a temporary database for testing. The database is automatically cleaned up when the test completes. Backend selection via MSGVAU

Router returns the chi router for testing.

Execute merges every duplicate group: unions labels onto the survivor, soft-deletes the pruned duplicates, and — when DeleteDupsFromSourceServer is en

writeError writes an error response.

newTestEnv creates a test environment with an in-memory SQLite database and test data.

DefaultAggregateOptions returns sensible defaults.

Aggregate performs grouping based on the provided ViewType (Sender, Domain, etc.)

----------------------------------------------------------------------------- Key Event Helpers - reduce verbosity of tea.KeyMsg construction --------

AddMessage adds a message and returns its ID.

newTestRootCmd creates a fresh root command for testing, avoiding mutation of the global rootCmd which could cause race conditions in parallel tests.

assertLevel checks that the model is at the expected view level.

Update implements tea.Model.

Message queries

LiveMessagesWhere returns the SQL predicate that selects live messages. Dedup-hidden rows (deleted_at IS NOT NULL) are filtered always — they must not

Now returns the SQL expression for the current timestamp. SQLite: "datetime('now')" PostgreSQL: "NOW()"

UpsertMessage inserts or updates a message.

QueryContext returns a *loggedRows whose Close emits the real wall-clock duration of prepare + scan. The immediate post-Query log line is emitted only

CreateMessage inserts a minimal message and returns its internal ID.

Parse is a convenience function that parses using default settings.

ActivateGeneration atomically retires the current active generation (if any, deleting its embeddings on backends that share an index graph) and promot

Parse parses a Gmail-like search query string into a Query object. Supported operators: - from:, to:, cc:, bcc: - address filters - subject: - subjec

Body sets the message body text.

AddAccountIdentity confirms an identifier for one source. Behavior: - If (source_id, address) does not exist: insert with the given signal and confir

DatabaseDSN returns the database connection string or file path.

Next delegates to the embedded *sql.Rows but, on the first false return, runs the timing finalizer so duration_ms is captured at end-of-scan rather th

ReplaceMessageRecipients replaces all recipients for a message atomically.

Subject sets the Subject header. Use NoSubject() to omit it entirely.

applyAggregateKey sends a key through handleAggregateKeys and returns the concrete Model.

assertSummary checks SyncSummary fields against expected values. Only non-nil fields in want are checked.

AddMessage adds a message to the mock store.

Close releases any resources held by the engine.

keyEnter returns a KeyMsg for the Enter key.

newParquetEngine creates a DuckDBEngine backed by the standard Parquet test data. It registers cleanup via t.Cleanup so callers don't need defer.

NewMessage creates a MessageBuilder with sensible defaults.

StartSync creates a new sync run record and returns its ID. The supersede UPDATE and the INSERT run inside a writer-locked transaction so concurrent S

EnsureConversation gets or creates a conversation (thread) for a message. Concurrent first-inserts converge via INSERT ... ON CONFLICT DO UPDATE RETUR

runFullSync runs a full sync and fails the test on error.

AddParticipant adds a participant and returns its ID.

makeMessages creates n MessageSummary values with sequential IDs and subjects.

NewWorker constructs a Worker, applying defaults for BatchSize (32), StaleThreshold (auto-derived; see derivedStaleThreshold), MaxConsecutiveFailures

testLogger returns a logger for tests that discards output.

newBackendForTest opens a per-test database with one live message and returns a Backend ready for assertions.

ListAccountIdentities returns all identities for one source, ordered by address.

usageErr re-enables the usage block for cmd and returns err. Use inside RunE for validation that's semantically part of the invocation contract (mutua

From sets the From header.