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

//! Replay HTTP requests via raw `XMLHttpRequest`.
//!
//! Matches the app's own XHR wire bytes including `Sec-Fetch-*`
//! headers, cookie handling, and service-worker routing.

use super::super::{BrowserSession, access};
use crate::browser::{BrowserError, BrowserOutput, request::XhrRequest};
use std::time::Duration;

const EVAL_TIMEOUT: Duration = Duration::from_secs(60);

/// Replay via raw `XMLHttpRequest` so `Sec-Fetch-*`, cookies, and
/// service-worker routing match the app's own XHR save path.
///
/// # Arguments
///
/// * `session` — active browser session with a current page
/// * `request` — URL, method, headers, body, with_credentials flag
///
/// # Errors
///
/// Returns [`BrowserError::EvaluationTimeout`] if the XHR exceeds 60 s,
/// or propagates CDP / serialization errors.
pub async fn xhr(
    session: &BrowserSession,
    request: XhrRequest,
) -> Result<BrowserOutput, BrowserError> {
    let page = access::current_page(session).await?;
    let script = super::xhr_tmpl::build_script(request)?;
    let result = tokio::time::timeout(EVAL_TIMEOUT, page.evaluate_expression(script))
        .await
        .map_err(|_| BrowserError::EvaluationTimeout)??;
    let value = result
        .object()
        .value
        .clone()
        .unwrap_or(serde_json::json!({"ok": false, "status": 0, "error": "no value"}));
    Ok(BrowserOutput::Json(value))
}