use crate::error::{BrowserError, Result};
use crate::tools::{Tool, ToolContext, ToolResult};
use schemars::JsonSchema;
use serde::{Deserialize, Serialize};
#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
pub struct ScrollParams {
#[serde(skip_serializing_if = "Option::is_none")]
pub amount: Option<i32>,
}
#[derive(Default)]
pub struct ScrollTool;
const SCROLL_JS: &str = include_str!("scroll.js");
#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
#[serde(rename_all = "camelCase")]
pub struct ScrollOutput {
pub scrolled: i64,
pub is_at_bottom: bool,
pub message: String,
}
impl Tool for ScrollTool {
type Params = ScrollParams;
type Output = ScrollOutput;
fn name(&self) -> &str {
"scroll"
}
fn execute_typed(&self, params: ScrollParams, context: &mut ToolContext) -> Result<ToolResult> {
let config = serde_json::json!({
"amount": params.amount
});
let scroll_js = SCROLL_JS.replace("__SCROLL_CONFIG__", &config.to_string());
let result = context
.session
.tab()?
.evaluate(&scroll_js, true)
.map_err(|e| BrowserError::ToolExecutionFailed {
tool: "scroll".to_string(),
reason: e.to_string(),
})?;
Ok(ToolResult::success_with(parse_scroll_output(result.value)))
}
}
fn parse_scroll_output(value: Option<serde_json::Value>) -> ScrollOutput {
let result_json: serde_json::Value = if let Some(serde_json::Value::String(json_str)) = value {
serde_json::from_str(&json_str)
.unwrap_or(serde_json::json!({"actualScroll": 0, "isAtBottom": false}))
} else {
value.unwrap_or(serde_json::json!({"actualScroll": 0, "isAtBottom": false}))
};
let actual_scroll = result_json["actualScroll"].as_i64().unwrap_or(0);
let is_at_bottom = result_json["isAtBottom"].as_bool().unwrap_or(false);
let message = if is_at_bottom {
format!(
"Scrolled {} pixels. Reached the bottom of the page.",
actual_scroll
)
} else {
format!(
"Scrolled {} pixels. Did not reach the bottom of the page.",
actual_scroll
)
};
ScrollOutput {
scrolled: actual_scroll,
is_at_bottom,
message,
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_scroll_params_with_amount() {
let json = serde_json::json!({
"amount": 500
});
let params: ScrollParams = serde_json::from_value(json).unwrap();
assert_eq!(params.amount, Some(500));
}
#[test]
fn test_scroll_params_negative_amount() {
let json = serde_json::json!({
"amount": -300
});
let params: ScrollParams = serde_json::from_value(json).unwrap();
assert_eq!(params.amount, Some(-300));
}
#[test]
fn test_scroll_params_no_amount() {
let json = serde_json::json!({});
let params: ScrollParams = serde_json::from_value(json).unwrap();
assert_eq!(params.amount, None);
}
#[test]
fn test_parse_scroll_output_from_string_payload() {
let output = parse_scroll_output(Some(serde_json::Value::String(
r#"{"actualScroll":420,"isAtBottom":true}"#.to_string(),
)));
assert_eq!(output.scrolled, 420);
assert!(output.is_at_bottom);
assert!(output.message.contains("Reached the bottom"));
}
#[test]
fn test_parse_scroll_output_falls_back_for_invalid_payload() {
let output = parse_scroll_output(Some(serde_json::Value::String("not json".to_string())));
assert_eq!(output.scrolled, 0);
assert!(!output.is_at_bottom);
assert!(output.message.contains("Did not reach the bottom"));
}
}