Method ensure_session

src/apps/cli/src/agent/core_adapter.rs:182–208

(&self, agent_type: &str)

#[async_trait::async_trait]
impl Agent for CoreAgentAdapter {
    async fn ensure_session(&self, agent_type: &str) -> Result<String> {
        let mut session_id_guard = self.session_id.lock().await;

        if let Some(ref id) = *session_id_guard {
            self.ensure_backend_session_alive(id, agent_type).await?;
            return Ok(id.clone());
        }

        let session = self
            .coordinator
            .create_session(
                Self::build_default_session_name(),
                agent_type.to_string(),
                SessionConfig {
                    workspace_path: Some(self.workspace_path_string()),
                    ..Default::default()
                },
            )
            .await?;

        let id = session.session_id.clone();

        *session_id_guard = Some(id.clone());
        tracing::info!("Created core session: {}", id);

        Ok(id)
    }

    async fn send_message(&self, message: String, agent_type: &str) -> Result<String> {
        let session_id = self.ensure_session(agent_type).await?;