eoka-server 0.4.0

Shared browser runtime and sidecar process for eoka browser automation
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
99
100
101
102
103
104
105
106

use serde_json::Value;

use crate::methods::{browser, page};
use crate::protocol::ServerError;
use crate::state::AppState;

pub async fn dispatch(
    state: &mut AppState,
    method: &str,
    params: Value,
) -> Result<Value, ServerError> {
    if matches!(method, "agent.observe" | "agent.step") {
        let browser = state.browser()?.clone();
        let page = state
            .page(
                params["pageId"]
                    .as_str()
                    .ok_or_else(|| ServerError::invalid_params("pageId required"))?,
            )?
            .clone();
        let mut args = params;
        if let Some(object) = args.as_object_mut() {
            object.remove("pageId");
        }
        let result = if method == "agent.observe" {
            serde_json::to_value(
                state
                    .agent
                    .observe(
                        &browser,
                        &page,
                        serde_json::from_value(args)
                            .map_err(|e| ServerError::invalid_params(e.to_string()))?,
                    )
                    .await
                    .map_err(|e| ServerError::internal(format!("{e:#}")))?,
            )
        } else {
            serde_json::to_value(
                state
                    .agent
                    .step(
                        &browser,
                        &page,
                        &state.operations,
                        serde_json::from_value(args)
                            .map_err(|e| ServerError::invalid_params(e.to_string()))?,
                    )
                    .await
                    .map_err(|e| ServerError::internal(format!("{e:#}")))?,
            )
        };
        return result.map_err(|e| ServerError::internal(e.to_string()));
    }
    if let Some(result) = crate::operations::sidecar::dispatch(state, method, &params).await {
        return result;
    }
    if matches!(method, "browser.close" | "browser.close_tab" | "page.close") {
        state.operations.stop().await;
    }
    match method {
        "browser.launch" => browser::launch(state, params).await,
        "browser.new_page" => browser::new_page(state, params).await,
        "browser.tabs" => browser::tabs(state, params).await,
        "browser.close_tab" => browser::close_tab(state, params).await,
        "browser.close" => browser::close(state, params).await,

        "page.goto" => page::goto(state, params).await,
        "page.click" => page::click(state, params).await,
        "page.click_text" => page::click_text(state, params).await,
        "page.human_click" => page::human_click(state, params).await,
        "page.human_click_text" => page::human_click_text(state, params).await,
        "page.fill" => page::fill(state, params).await,
        "page.human_fill" => page::human_fill(state, params).await,
        "page.type_into" => page::type_into(state, params).await,
        "page.text" => page::text(state, params).await,
        "page.content" => page::content(state, params).await,
        "page.title" => page::title(state, params).await,
        "page.url" => page::url(state, params).await,
        "page.get_text" => page::get_text(state, params).await,
        "page.get_attribute" => page::get_attribute(state, params).await,
        "page.exists" => page::exists(state, params).await,
        "page.wait_for" => page::wait_for(state, params).await,
        "page.wait_for_visible" => page::wait_for_visible(state, params).await,
        "page.wait_for_text" => page::wait_for_text(state, params).await,
        "page.evaluate" => page::evaluate(state, params).await,
        "page.execute" => page::execute(state, params).await,
        "page.fetch" => page::fetch(state, params).await,
        "page.capture_state" => page::capture_state(state, params).await,
        "page.restore_state" => page::restore_state(state, params).await,
        "page.screenshot" => page::screenshot(state, params).await,
        "page.select" => page::select(state, params).await,
        "page.hover" => page::hover(state, params).await,
        "page.press_key" => page::press_key(state, params).await,
        "page.mouse_down" => page::mouse_down(state, params).await,
        "page.mouse_move" => page::mouse_move(state, params).await,
        "page.mouse_up" => page::mouse_up(state, params).await,
        "page.key_down" => page::key_down(state, params).await,
        "page.key_up" => page::key_up(state, params).await,
        "page.release_all_inputs" => page::release_all_inputs(state, params).await,
        "page.solve_captcha" => page::solve_captcha(state, params).await,
        "page.close" => page::close(state, params).await,

        _ => Err(ServerError::unknown_method(method)),
    }
}