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
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
85
86
87
88
89
90
91
92
93
94
95
96

use super::text::role_label;
use crate::provider::{ContentPart, Message};

pub fn messages_to_rlm_context(messages: &[Message]) -> String {
    let mut out = String::new();
    for (idx, m) in messages.iter().enumerate() {
        out.push_str(&format!("[{} {}]\n", idx, role_label(m.role)));

        for part in &m.content {
            match part {
                ContentPart::Text { text } => {
                    out.push_str(text);
                    out.push('\n');
                }
                ContentPart::Thinking { text } => {
                    if !text.trim().is_empty() {
                        out.push_str("[Thinking]\n");
                        out.push_str(text);
                        out.push('\n');
                    }
                }
                ContentPart::ToolCall {
                    id,
                    name,
                    arguments,
                    ..
                } => {
                    out.push_str(&format!(
                        "[ToolCall id={id} name={name}]\nargs: {arguments}\n"
                    ));
                }
                ContentPart::ToolResult {
                    tool_call_id,
                    content,
                } => {
                    out.push_str(&format!("[ToolResult id={tool_call_id}]\n"));
                    out.push_str(content);
                    out.push('\n');
                }
                ContentPart::Image { mime_type, url } => {
                    out.push_str(&format!(
                        "[Image mime_type={} url_len={}]\n",
                        mime_type.clone().unwrap_or_else(|| "unknown".to_string()),
                        url.len()
                    ));
                }
                ContentPart::File { path, mime_type } => {
                    out.push_str(&format!(
                        "[File path={} mime_type={}]\n",
                        path,
                        mime_type.clone().unwrap_or_else(|| "unknown".to_string())
                    ));
                }
            }
        }

        out.push_str("\n---\n\n");
    }
    out
}

pub fn is_prompt_too_long_error(err: &anyhow::Error) -> bool {
    let msg = err.to_string().to_ascii_lowercase();
    msg.contains("prompt is too long")
        || msg.contains("context length")
        || msg.contains("maximum context")
        || (msg.contains("tokens") && msg.contains("maximum") && msg.contains("prompt"))
}

pub fn is_retryable_upstream_error(err: &anyhow::Error) -> bool {
    let msg = err.to_string().to_ascii_lowercase();
    [
        " 500 ",
        " 504 ",
        " 502 ",
        " 429 ",
        "status code 500",
        "status code 504",
        "status code 502",
        "status code 429",
        "internal server error",
        "gateway timeout",
        "upstream request timeout",
        "server error: 500",
        "server error: 504",
        "network error",
        "connection reset",
        "connection refused",
        "timed out",
        "timeout",
        "broken pipe",
        "unexpected eof",
    ]
    .iter()
    .any(|needle| msg.contains(needle))
}