Mimics a single chunk in OpenRouter's streaming response.

Mimics the TranscriptChunk segment returned by the Supadata SDK.

Mimics a single chunk in OpenRouter's streaming response.

Captures calls to the patched async function.

Mock result where content is a plain string.

Async iterator over pre-scripted chunks.

A tool_call fragment as OpenRouter streams it.

Mock result where content is a list of TranscriptChunk segments.

Raised when a token is missing, malformed, expired, or signed with a bad secret.

Minimal connection mock that returns empty results.

Stream-safe stripper for ``[c:<chunk_id>]`` markers. Markers can straddle SSE token boundaries, so we hold back any tail that could plausibly

Plain sync object returned by client.youtube.channel.videos().

Raised by `check` when the caller should be rejected with 429.

Dual-purpose awaitable + async context manager.

Minimal connection mock for repository tests.

No-op connection for tests that go through the signup route. The real route opens `pool.acquire() → conn.transaction()` and passes the connec

Async iterator over pre-scripted chunks with optional delays between emits. Delays exercise the real-world timing where tool_call args stream

A tool_call fragment as OpenRouter streams it.

/me payload — user identity plus the current rate-limit counter. The counter is included on /me so the frontend can render the daily quota wi

Plain sync object returned by client.transcript(). The `text` parameter feeds `.content` (matching the real SDK's field name) — the name is a

Mock result where content is None (no transcript available).

Plain sync object returned when no transcript is available.

Result of parse_youtube_url().

Raised by `check_and_record` when the user is over the cap.

Snapshot of a user's rate-limit state — for the /me counter.

Raised when video ingest input is invalid (e.g., bad URL).

Dual-purpose awaitable + async context manager — matches asyncpg.pool.PoolAcquireContext.

Callable with settable side_effect for expansion tests.

A synchronous acquire context manager (not awaitable).

A PoolAcquireContext mock that explicitly CANNOT be awaited. This mimics the real asyncpg.pool.PoolAcquireContext behavior: - It has __aenter

Mimics a TranscriptChunk segment returned by the Supadata SDK.

Plain sync object whose .content is a list of TranscriptChunk segments.

The route wrapper in `routes/messages.py` stores every yielded chunk in `full_response` for refusal detection and SSE replay. Verify that `_ex

Verify that status events are NOT emitted when the per-turn cap is already reached.

Integration tests for chunk expansion in the SSE streaming path. Verifies the SSE output contains citation content when chunks are returned b