opencrabs 0.3.58

The autonomous, self-improving AI agent. Single Rust binary. Every channel. Install with: cargo install opencrabs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use crate::a2a::handler::*;
use crate::a2a::types::JsonRpcRequest;
// tasks/get and tasks/cancel tests don't need AgentService
#[tokio::test]
async fn test_get_task_not_found() {
    let store = new_task_store();
    let req = JsonRpcRequest {
        jsonrpc: "2.0".to_string(),
        method: "tasks/get".to_string(),
        params: serde_json::json!({"id": "nonexistent"}),
        id: serde_json::json!(2),
    };
    let resp = tasks::handle_get_task(req.id, req.params, store).await;
    assert!(resp.error.is_some());
    assert_eq!(resp.error.as_ref().expect("err").code, -32001);
}

#[tokio::test]
async fn test_unknown_method() {
    use crate::a2a::test_helpers::helpers;

    let store = new_task_store();
    let cancel_store = new_cancel_store();
    let agent = helpers::placeholder_agent_service().await;
    let ctx = helpers::placeholder_service_context().await;
    let req = JsonRpcRequest {
        jsonrpc: "2.0".to_string(),
        method: "unknown/method".to_string(),
        params: serde_json::json!({}),
        id: serde_json::json!(99),
    };
    let resp = dispatch(req, store, cancel_store, agent, ctx).await;
    assert!(resp.error.is_some());
    assert_eq!(resp.error.as_ref().expect("err").code, -32601);
}