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
97
98

//! Network inspection & replay browserctl actions.

use super::super::helpers::require_string;
use super::super::input::BrowserCtlInput;
use crate::browser::{
    BrowserCommand,
    request::{AxiosRequest, DiagnoseRequest, FetchRequest, NetworkLogRequest, XhrRequest},
};

pub(in crate::tool::browserctl) async fn network_log(
    input: &BrowserCtlInput,
) -> Result<crate::browser::BrowserOutput, crate::browser::BrowserError> {
    let request = NetworkLogRequest {
        limit: input.limit,
        url_contains: input
            .url_contains
            .as_deref()
            .filter(|v| !v.trim().is_empty())
            .map(str::to_string),
        method: input
            .method
            .as_deref()
            .filter(|v| !v.trim().is_empty())
            .map(str::to_string),
    };
    super::execute(input, BrowserCommand::NetworkLog(request)).await
}

pub(in crate::tool::browserctl) async fn fetch(
    input: &BrowserCtlInput,
) -> Result<crate::browser::BrowserOutput, crate::browser::BrowserError> {
    let url = require_string(&input.url, "url")
        .map_err(|e| crate::browser::BrowserError::OperationFailed(e.to_string()))?
        .to_string();
    let method = input
        .method
        .clone()
        .unwrap_or_else(|| "GET".to_string());
    let request = FetchRequest {
        method,
        url,
        headers: input.headers.clone(),
        body: input.body.clone(),
        credentials: input.credentials.clone(),
    };
    super::execute(input, BrowserCommand::Fetch(request)).await
}

pub(in crate::tool::browserctl) async fn axios(
    input: &BrowserCtlInput,
) -> Result<crate::browser::BrowserOutput, crate::browser::BrowserError> {
    let url = require_string(&input.url, "url")
        .map_err(|e| crate::browser::BrowserError::OperationFailed(e.to_string()))?
        .to_string();
    let method = input
        .method
        .clone()
        .unwrap_or_else(|| "GET".to_string());
    // Prefer `json_body` (parsed object) but accept `body` (JSON string) so
    // the same payload captured by network_log can be replayed verbatim.
    let body = input.json_body.clone().or_else(|| {
        input
            .body
            .as_deref()
            .and_then(|s| serde_json::from_str::<serde_json::Value>(s).ok())
    });
    let request = AxiosRequest {
        method,
        url,
        headers: input.headers.clone(),
        body,
        axios_path: input.axios_path.clone(),
    };
    super::execute(input, BrowserCommand::Axios(request)).await
}

pub(in crate::tool::browserctl) async fn diagnose(
    input: &BrowserCtlInput,
) -> Result<crate::browser::BrowserOutput, crate::browser::BrowserError> {
    super::execute(input, BrowserCommand::Diagnose(DiagnoseRequest {})).await
}

pub(in crate::tool::browserctl) async fn xhr(
    input: &BrowserCtlInput,
) -> Result<crate::browser::BrowserOutput, crate::browser::BrowserError> {
    let url = require_string(&input.url, "url")
        .map_err(|e| crate::browser::BrowserError::OperationFailed(e.to_string()))?
        .to_string();
    let method = input.method.clone().unwrap_or_else(|| "GET".to_string());
    let request = XhrRequest {
        method,
        url,
        headers: input.headers.clone(),
        body: input.body.clone(),
        with_credentials: input.with_credentials,
    };
    super::execute(input, BrowserCommand::Xhr(request)).await
}