Function serve_agent_dir

core/src/serve/daemon.rs:65–91

Serve an agent directory's schedules until `cancel` fires. Builds one durable session per enabled schedule (`schedule: `), injecting the agent dir's `prompt_slots`, `skill_dirs`, and `tools/`. `extra` merges into each schedule session's [`SessionOptions`] (model, `llm_client`, `session_store`, …); a host-set `prompt_slots` is honored, but `session_id` is always derived per schedule.

(
    agent: &Agent,
    agent_dir: &AgentDir,
    workspace: impl Into<String> + Clone,
    extra: Option<SessionOptions>,
    cancel: CancellationToken,
)

/// `session_store`, …); a host-set `prompt_slots` is honored, but `session_id` is
/// always derived per schedule.
pub async fn serve_agent_dir(
    agent: &Agent,
    agent_dir: &AgentDir,
    workspace: impl Into<String> + Clone,
    extra: Option<SessionOptions>,
    cancel: CancellationToken,
) -> Result<()> {
    let extra = extra.unwrap_or_default();

    let mut sessions = HashMap::new();
    for spec in agent_dir.schedules.iter().filter(|s| s.enabled) {
        let session = build_session(
            agent,
            agent_dir,
            format!("schedule:{}", spec.name),
            workspace.clone(),
            &extra,
        )
        .await?;
        sessions.insert(spec.name.clone(), Arc::new(session));
    }

    let scheduler = Scheduler::new(agent_dir.schedules.clone())?;
    let sink: Arc<dyn ScheduleSink> = Arc::new(SessionScheduleSink { sessions });
    scheduler.run(sink, cancel).await;
    Ok(())
}

/// Build one durable serve session under the explicit `session_id`
/// (`schedule:<name>`), injecting the agent dir's prompt slots, skills, and