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

use super::{BrowserSession, SessionMode, SessionRuntime};
use crate::browser::BrowserError;
use chromiumoxide::cdp::browser_protocol::target::TargetId;
use chromiumoxide::{browser::Browser, page::Page};
use std::sync::Arc;
use tokio::sync::Mutex;

pub(super) struct RuntimeAccess {
    pub browser: Arc<Mutex<Browser>>,
    pub current_page: Arc<Mutex<Option<Page>>>,
    pub mode: SessionMode,
    pub tab_order: Arc<Mutex<Vec<TargetId>>>,
}

pub(super) async fn current_page(session: &BrowserSession) -> Result<Page, BrowserError> {
    runtime(session)
        .await?
        .current_page
        .lock()
        .await
        .clone()
        .ok_or(BrowserError::TabClosed)
}

pub(super) async fn runtime(session: &BrowserSession) -> Result<RuntimeAccess, BrowserError> {
    let slot = session.inner.runtime.lock().await;
    let runtime = slot.as_ref().ok_or(BrowserError::SessionNotStarted)?;
    if !runtime.is_alive() {
        return Err(BrowserError::BrowserCrashed);
    }
    Ok(RuntimeAccess::from(runtime))
}

impl From<&SessionRuntime> for RuntimeAccess {
    fn from(runtime: &SessionRuntime) -> Self {
        Self {
            browser: Arc::clone(&runtime.browser),
            current_page: Arc::clone(&runtime.current_page),
            mode: runtime.mode,
            tab_order: Arc::clone(&runtime.tab_order),
        }
    }
}