DatabaseConversationStore

Create a new conversation store instance.

Get the participant's most recent conversation ID with the given agent.

Determine whether the given conversation was stored for the given participant.

Store a new conversation and return its ID.

Store a new user message for the given conversation and return its ID.

Store the assistant turn for the given conversation, folding a resumed run into the row it paused on.

Commit the conversation and both sides of a turn with one activity update.

Get the turn whose transaction owns these writes.

Determine the status the turn is stored under, given how it ended.

Build the meta the turn is stored under, carrying the error it died with.

Find the row the given resume paused on, matching the turn its decisions name.

Append the steps a resumed run made to the row its turn paused on.

Keep the citations the paused half of the turn collected, under the resuming provider and model.

Serialize the turn's steps, one entry per model round-trip.

Pair a step's tool calls with the results they were answered by, marking those awaiting approval with their reason.

Drop the raw provider blocks of the paused rows a now-completed turn resumed from.

Drop the raw provider blocks from the given steps.

Get the reasons a response paused on, keyed by tool call ID.

Decode a stored JSON column.

Get the tool-call IDs a stored row is still awaiting a decision on.

Get the IDs of a stored row's tool calls that were gated behind an approval.

Rebuild the approvals a stored row is still awaiting a decision on.

Update the conversation's activity timestamp.

Build the message row attributes.

Get the latest messages for the given conversation.

Rebuild a stored user turn.

Rebuild a stored assistant turn step by step, so every tool result answers the message that made its call.

Build the result a failed turn's unanswered call replays with.

Decode a stored row's steps.

Paginate the given conversation's messages, newest first.

Get the tool calls the given conversation's newest turn is still waiting on.

Rehydrate attachments from their stored JSON representation.

Claim the paused turn matching the complete pending call set before any tools execute.

Record one tool outcome while its claim still owns the paused turn.

Durably record resolved approval results on the paused turn before the run continues.

Merge results into their original calls without overwriting recorded outcomes.

Query the conversation's assistant rows, newest first.

Get a query builder for the given table using the configured connection.

Stamp raw store inserts with the current partition.

Allow specialized stores to reject writes without restricting reads.

Resolve the conversations table name from config.

Resolve the messages table name from config.