Method inject_response_node

atomic-agent/src/turn/orchestrator/provenance.rs:266–301

Inject an LLM response node into the ProvenanceAccumulator. The agent's closing message for the turn — what it *concluded*, as opposed to the tool-derived nodes that capture what it *did*. Sources, in priority order: 1. The stop payload, when the agent sends the response there (`last_assistant_message` for codex/grok, `prompt_response` for gemini-cli, `response` for plugins that supply it). 2. T

(
        &mut self,
        session_id: &str,
        session: &AgentSession,
        event: &TurnEvent,
    )

    ///
    /// Agents with neither source available get no node.
    pub(crate) fn inject_response_node(
        &mut self,
        session_id: &str,
        session: &AgentSession,
        event: &TurnEvent,
    ) {
        let raw = event.raw_json.as_ref();
        let from_payload = |key: &str| -> Option<String> {
            raw.and_then(|r| r.get(key))
                .and_then(|v| v.as_str())
                .map(|s| s.trim().to_string())
                .filter(|s| !s.is_empty())
        };

        let response = from_payload("last_assistant_message")
            .or_else(|| from_payload("prompt_response"))
            .or_else(|| from_payload("response"))
            .or_else(|| {
                let path = session.transcript_path.as_ref()?;
                let data = std::fs::read(path).ok()?;
                transcript::last_assistant_text(
                    &data,
                    transcript::format_for_agent(&session.agent_name),
                )
            });

        let Some(response) = response else {
            return;
        };

        let timestamp = event.timestamp.timestamp();
        self.with_accumulator(session_id, |acc| {
            acc.append_llm_response(&response, timestamp);
            true
        });
    }

    /// OpenCode: recover transcript, reasoning, and response from
    /// OpenCode's local SQLite store and fold them into the session and