mermaid-cli 0.7.1

Open-source AI pair programmer with agentic capabilities. Local-first with Ollama, native tool calling, and beautiful TUI.
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

//! `scroll` — wheel scroll in "up" or "down" direction. Amount is
//! clamped to `[1, MAX_SCROLL_AMOUNT]` so a runaway model can't
//! request a million ticks (would blow ARG_MAX building xdotool's
//! argv on the X11 path).

use std::sync::Arc;
use std::time::Instant;

use async_trait::async_trait;
use serde_json::Value;

use crate::constants::MAX_SCROLL_AMOUNT;
use crate::domain::{ToolDefinition, ToolOutcome};
use crate::providers::ctx::ExecContext;

use super::super::ToolExecutor;
use super::computer_use_success;
use super::driver::ComputerUseDriver;

pub struct ScrollTool {
    driver: Arc<ComputerUseDriver>,
}

impl ScrollTool {
    pub fn new(driver: Arc<ComputerUseDriver>) -> Self {
        Self { driver }
    }
}

#[async_trait]
impl ToolExecutor for ScrollTool {
    fn name(&self) -> &'static str {
        "scroll"
    }

    fn schema(&self) -> ToolDefinition {
        ToolDefinition {
            name: "scroll".to_string(),
            description: "Scroll the focused window. `direction` is 'up' or 'down'; `amount` is \
                 clamped to 1..=100 wheel ticks. Scrolls in the currently-focused window; \
                 click on the scroll target first if it isn't focused."
                .to_string(),
            input_schema: serde_json::json!({
                "type": "object",
                "properties": {
                    "direction": { "type": "string", "enum": ["up", "down"] },
                    "amount": { "type": "integer", "minimum": 1, "maximum": MAX_SCROLL_AMOUNT }
                },
                "required": ["direction", "amount"]
            }),
        }
    }

    async fn execute(&self, args: Value, ctx: ExecContext) -> ToolOutcome {
        let started = Instant::now();
        if let Err(error) = self.driver.ensure_alive() {
            return ToolOutcome::error(error, started.elapsed().as_secs_f64());
        }

        let direction = args
            .get("direction")
            .and_then(|v| v.as_str())
            .unwrap_or("down")
            .to_string();
        if direction != "up" && direction != "down" {
            return ToolOutcome::error(
                format!(
                    "scroll: direction must be 'up' or 'down', got '{}'",
                    direction
                ),
                started.elapsed().as_secs_f64(),
            );
        }
        let requested = args
            .get("amount")
            .and_then(|v| v.as_i64())
            .map(|n| n as i32)
            .unwrap_or(3);
        let amount = requested.clamp(1, MAX_SCROLL_AMOUNT);

        let res = tokio::select! {
            biased;
            _ = ctx.token.cancelled() => return ToolOutcome::cancelled(),
            r = self.driver.scroll(&direction, amount, &ctx.token) => r,
        };
        if let Err(e) = res {
            return ToolOutcome::error(
                format!("scroll failed: {}", e),
                started.elapsed().as_secs_f64(),
            );
        }

        let clamp_note = if requested != amount {
            format!(" (clamped from {} to {})", requested, amount)
        } else {
            String::new()
        };
        computer_use_success(
            "scroll",
            args,
            format!("Scrolled {} by {}{}", direction, amount, clamp_note),
            started.elapsed().as_secs_f64(),
        )
    }
}