mirror of
https://github.com/harivansh-afk/sandbox-agent.git
synced 2026-04-15 09:01:17 +00:00
e3c030f66d
* chore: remove inspect.sandboxagent.dev in favor of /ui/ * chore: add 404 page * fix: correct inspector package name in Dockerfiles and add .dockerignore - Change @anthropic-ai/sdk-inspector to @sandbox-agent/inspector in all Dockerfiles - Add .dockerignore to exclude target/, node_modules/, etc from Docker context The wrong package name caused pnpm install --filter to match nothing, so the inspector frontend was never built, resulting in binaries without the /ui/ endpoint. * chore: cargo fmt * chore(release): update version to 0.1.4-rc.7
67 lines
2.4 KiB
Rust
67 lines
2.4 KiB
Rust
#[path = "../common/mod.rs"]
|
|
mod common;
|
|
|
|
use axum::http::Method;
|
|
use common::*;
|
|
use sandbox_agent_agent_management::testing::test_agents_from_env;
|
|
use serde_json::json;
|
|
use std::time::Duration;
|
|
|
|
#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
|
|
async fn agent_question_flow() {
|
|
let configs = test_agents_from_env().expect("configure SANDBOX_TEST_AGENTS or install agents");
|
|
let app = TestApp::new();
|
|
let capabilities = fetch_capabilities(&app.app).await;
|
|
|
|
for config in &configs {
|
|
let caps = capabilities
|
|
.get(config.agent.as_str())
|
|
.expect("capabilities missing");
|
|
if !caps.questions {
|
|
continue;
|
|
}
|
|
|
|
let _guard = apply_credentials(&config.credentials);
|
|
install_agent(&app.app, config.agent).await;
|
|
|
|
let session_id = format!("question-{}", config.agent.as_str());
|
|
create_session_with_mode(&app.app, config.agent, &session_id, "plan", "plan").await;
|
|
send_message(&app.app, &session_id, QUESTION_PROMPT).await;
|
|
|
|
let events = poll_events_until(&app.app, &session_id, Duration::from_secs(120), |events| {
|
|
find_question_id(events).is_some() || has_event_type(events, "error")
|
|
})
|
|
.await;
|
|
|
|
let question_id = find_question_id(&events).expect("question.requested missing");
|
|
let answers = find_first_answer(&events).unwrap_or_else(|| vec![vec![]]);
|
|
let status = send_status(
|
|
&app.app,
|
|
Method::POST,
|
|
&format!("/v1/sessions/{session_id}/questions/{question_id}/reply"),
|
|
Some(json!({ "answers": answers })),
|
|
)
|
|
.await;
|
|
assert_eq!(status, axum::http::StatusCode::NO_CONTENT, "question reply");
|
|
|
|
let resolved =
|
|
poll_events_until(&app.app, &session_id, Duration::from_secs(120), |events| {
|
|
events.iter().any(|event| {
|
|
event.get("type").and_then(serde_json::Value::as_str)
|
|
== Some("question.resolved")
|
|
})
|
|
})
|
|
.await;
|
|
|
|
assert!(
|
|
resolved.iter().any(|event| {
|
|
event.get("type").and_then(serde_json::Value::as_str) == Some("question.resolved")
|
|
&& event
|
|
.get("synthetic")
|
|
.and_then(serde_json::Value::as_bool)
|
|
.unwrap_or(false)
|
|
}),
|
|
"question.resolved should be synthetic"
|
|
);
|
|
}
|
|
}
|