API reference

use std::sync::Arc;
use meerkat_core::types::HandlingMode;
use meerkat_mob::{
    FlowId, MeerkatId, MobBuilder, MobDefinition, MobSessionService, MobStorage, ProfileName,
};

async fn orchestrate(
    definition_toml: &str,
    session_service: Arc<dyn MobSessionService>,
) -> Result<(), Box<dyn std::error::Error>> {
    let definition = MobDefinition::from_toml(definition_toml)?;
    let storage = MobStorage::redb("./mob.redb")?;

    let handle = MobBuilder::new(definition, storage)
        .with_session_service(session_service)
        .create()
        .await?;

    handle
        .spawn(ProfileName::from("lead"), MeerkatId::from("lead-1"), None)
        .await?;
    handle
        .spawn(ProfileName::from("worker"), MeerkatId::from("worker-1"), None)
        .await?;
    handle
        .wire(MeerkatId::from("lead-1"), MeerkatId::from("worker-1"))
        .await?;
    let lead = handle.member(&MeerkatId::from("lead-1")).await?;
    lead.send("Coordinate work.", HandlingMode::Queue, None).await?;

    let run_id = handle
        .run_flow(FlowId::from("release_flow"), serde_json::json!({"severity":"critical"}))
        .await?;
    let _run = handle.flow_status(run_id).await?;
    Ok(())
}

use std::sync::Arc;
use meerkat_core::service::SessionBuildOptions;
use meerkat_core::AgentToolDispatcher;
use meerkat_mob::MobSessionService;
use meerkat_mob_mcp::{MobMcpDispatcher, MobMcpState};

fn with_mob_tools(session_service: Arc<dyn MobSessionService>) -> SessionBuildOptions {
    let state = Arc::new(MobMcpState::new(session_service));
    let tools: Arc<dyn AgentToolDispatcher> = Arc::new(MobMcpDispatcher::new(state));
    SessionBuildOptions {
        external_tools: Some(tools),
        ..Default::default()
    }
}