codetether-agent 4.5.7

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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

use crate::provenance::ClaimProvenance;
use serde::Deserialize;

#[derive(Debug, Deserialize)]
pub struct TaskClaimResponse {
    pub task_id: String,
    pub worker_id: String,
    pub run_id: Option<String>,
    pub attempt_id: Option<String>,
    pub tenant_id: Option<String>,
    pub user_id: Option<String>,
    pub agent_identity_id: Option<String>,
}

impl TaskClaimResponse {
    pub fn into_provenance(self) -> ClaimProvenance {
        ClaimProvenance {
            worker_id: self.worker_id,
            task_id: self.task_id,
            run_id: self.run_id,
            attempt_id: self.attempt_id,
            tenant_id: self.tenant_id,
            agent_identity_id: self
                .agent_identity_id
                .or_else(|| self.user_id.map(|user_id| format!("user:{user_id}"))),
        }
    }
}

#[cfg(test)]
mod tests {
    use super::TaskClaimResponse;

    #[test]
    fn maps_user_id_into_agent_identity() {
        let provenance = TaskClaimResponse {
            task_id: "task-1".to_string(),
            worker_id: "worker-1".to_string(),
            run_id: Some("run-1".to_string()),
            attempt_id: Some("run-1:attempt:2".to_string()),
            tenant_id: Some("tenant-1".to_string()),
            user_id: Some("user-1".to_string()),
            agent_identity_id: None,
        }
        .into_provenance();
        assert_eq!(provenance.agent_identity_id.as_deref(), Some("user:user-1"));
    }
}