codetether-agent 4.6.0

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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

//! `session_task` [`Tool`] implementation — the agent-facing entrypoint.

use super::handlers::{clear_goal, list, reaffirm, set_goal, task_add, task_status};
use super::params::Params;
use crate::session::tasks::TaskLog;
use crate::tool::{Tool, ToolResult};
use anyhow::{Result, anyhow};
use async_trait::async_trait;
use serde_json::{Value, json};

pub struct SessionTaskTool;

impl Default for SessionTaskTool {
    fn default() -> Self {
        Self
    }
}

impl SessionTaskTool {
    pub fn new() -> Self {
        Self
    }
}

#[async_trait]
impl Tool for SessionTaskTool {
    fn id(&self) -> &str {
        "session_task"
    }
    fn name(&self) -> &str {
        "Session Task & Goal"
    }
    fn description(&self) -> &str {
        "Manage the session's goal and task list. Actions: \
         `set_goal` (objective, success_criteria?, forbidden?), \
         `reaffirm` (progress_note), \
         `clear_goal` (reason?), \
         `task_add` (content, id?, parent_id?), \
         `task_status` (id, status: pending|in_progress|done|blocked|cancelled, note?), \
         `list`. Events are appended to the session's .tasks.jsonl."
    }
    fn parameters(&self) -> Value {
        json!({
            "type": "object",
            "properties": {
                "action": {"type": "string", "enum": [
                    "set_goal", "reaffirm", "clear_goal",
                    "task_add", "task_status", "list"
                ]},
                "objective": {"type": "string"},
                "success_criteria": {"type": "array", "items": {"type": "string"}},
                "forbidden": {"type": "array", "items": {"type": "string"}},
                "progress_note": {"type": "string"},
                "reason": {"type": "string"},
                "id": {"type": "string"},
                "content": {"type": "string"},
                "parent_id": {"type": "string"},
                "status": {"type": "string",
                    "enum": ["pending", "in_progress", "done", "blocked", "cancelled"]},
                "note": {"type": "string"}
            },
            "required": ["action"]
        })
    }

    async fn execute(&self, params: Value) -> Result<ToolResult> {
        let p: Params = serde_json::from_value(params)?;
        let sid = p
            .ct_session_id
            .clone()
            .or_else(|| std::env::var("CODETETHER_SESSION_ID").ok())
            .ok_or_else(|| anyhow!("session id not available; cannot locate task log"))?;
        let log = TaskLog::for_session(&sid)?;
        match p.action.as_str() {
            "set_goal" => set_goal(&log, p).await,
            "reaffirm" => reaffirm(&log, p).await,
            "clear_goal" => clear_goal(&log, p).await,
            "task_add" => task_add(&log, p).await,
            "task_status" => task_status(&log, p).await,
            "list" => list(&log).await,
            other => Ok(ToolResult::error(format!("unknown action: {other}"))),
        }
    }
}