Struct ConversationStore 

pub struct ConversationStore { /* private fields */ }

Shared, mutable conversation state plus a bus publisher. The supervisor holds one clone and calls ConversationStore::apply; the ai-conversation mode reads ConversationStore::snapshot on each ConversationUpdated.

Implementations

impl ConversationStore

pub fn new(publish: Arc<dyn Fn(ConversationUpdated) + Send + Sync>) -> Self

Build a store whose mutations publish ConversationUpdated via publish.

pub fn apply(&self, session: &SessionKey, update: &SessionUpdate)

Fold update into the conversation for session, then publish.

pub fn push_user_text(&self, session: &SessionKey, text: &str)

AU‑3: fold a locally-composed user prompt into the conversation as a User turn, then publish. ACP agents don’t echo the user’s prompt back, so the supervisor calls this when it sends a prompt to make the user’s turn appear in the transcript immediately.

pub fn push_permission_request( &self, session: &SessionKey, id: String, title: String, description: Option<String>, options: Vec<PermissionOption>, responder: Sender<PermissionOptionId>, )

AUX‑1: push a permission block and register its oneshot responder. The supervisor calls this when classify_permission returns AskUser; the receiver is awaited in handle_permission.

pub fn resolve_permission(&self, id: &str, option_id: PermissionOptionId)

PU-B.2: resolve a pending permission request by the agent’s chosen option_id. Derives the inline block status from that option’s kind, updates the block, and sends the option_id through the oneshot the supervisor is parked on (which answers ACP with Selected(option_id)), then publishes. No-op when id is unknown (already resolved, deferred and re-resolved, or never registered).

pub fn oldest_pending_permission(&self) -> Option<PendingPermissionView>

PU-B.2b: the oldest still-Pending permission request, projected for the popup menu (ai-permission-mode reads it in on_activate). Turns and blocks are in wire order, so the first Pending block is the oldest.

pub fn oldest_pending_permission_where( &self, keep: impl Fn(&str) -> bool, ) -> Option<PendingPermissionView>

PU-B.3: the oldest Pending request whose id satisfies keep. The auto-open tick callback passes |id| !deferred(id) so an Esc-deferred request is skipped (the queue advances past it) without re-opening it.

pub fn set_status(&self, session: &SessionKey, status: SessionStatus)

AUX‑3: set the global processing status and publish a ConversationUpdated so the headerline re-renders.

pub fn snapshot(&self) -> Conversation

Cheap-ish clone of the current conversation for projection.

Trait Implementations

impl Clone for ConversationStore

fn clone(&self) -> ConversationStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.