Method publish_agent_event

core/src/ahp/executor.rs:504–540

Publish durable AHP contract events derived from runtime AgentEvents.

(&self, event: &AgentEvent, run_id: &str, session_id: &str)

    /// Publish durable AHP contract events derived from runtime AgentEvents.
    pub async fn publish_agent_event(&self, event: &AgentEvent, run_id: &str, session_id: &str) {
        self.record_event();
        self.record_runtime_agent_event(event, run_id);

        let mut events = crate::ahp::agent_event_to_ahp_events(
            event,
            run_id,
            session_id,
            &self.agent_id,
            self.depth,
        );
        if events.is_empty() {
            return;
        }
        let context = self.build_context();
        for event in &mut events {
            event.context = context.clone();
        }

        let should_flush = matches!(event, AgentEvent::End { .. } | AgentEvent::Error { .. });

        if self.batch_enabled {
            for event in events {
                self.add_to_batch(event).await;
            }
            if should_flush {
                self.flush_batch().await;
            }
            return;
        }

        for event in events {
            if let Err(e) = self.client.send_event_full(&event).await {
                warn!("AHP runtime contract event failed: {}", e);
            }
        }
    }

    /// Publish an explicit run cancellation lifecycle event.
    pub async fn publish_run_cancelled(