codetether-agent 4.5.2

A2A-native AI coding agent for the CodeTether ecosystem
Documentation 
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

use axum::http::HeaderMap;
use codetether_agent::cloudevents::parse_cloud_event;
use serde_json::json;

#[test]
fn parses_structured_cloudevent() {
    let event = parse_cloud_event(
        &HeaderMap::new(),
        json!({"id":"evt-1","source":"codetether:a2a-server","type":"codetether.task.created","specversion":"1.0","data":{"task_id":"task-1"}}),
    )
    .expect("structured event should parse");
    assert_eq!(event.event_type, "codetether.task.created");
    assert_eq!(event.data["task_id"], "task-1");
}

#[test]
fn parses_binary_task_payload() {
    let mut headers = HeaderMap::new();
    headers.insert("ce-id", "evt-2".parse().unwrap());
    headers.insert("ce-source", "codetether:a2a-server".parse().unwrap());
    headers.insert("ce-type", "codetether.task.created".parse().unwrap());
    let event = parse_cloud_event(&headers, json!({"task_id":"task-2"}))
        .expect("binary event should parse");
    assert_eq!(event.id, "evt-2");
    assert_eq!(event.data["task_id"], "task-2");
}