Struct WebScrapeExecutor 

pub struct WebScrapeExecutor { /* private fields */ }

Extracts data from web pages via CSS selectors.

Handles two invocation paths:

1. Legacy fenced blocks — detects ```scrape blocks in the LLM response, each containing a JSON scrape instruction object. Dispatched via ToolExecutor::execute.
2. Structured tool calls — dispatched via ToolExecutor::execute_tool_call for tool IDs "web_scrape" and "fetch".

Security

• Only HTTPS URLs are accepted. HTTP and other schemes return ToolError::InvalidParams.
• DNS is resolved synchronously and each resolved address is checked against is_private_ip. Private addresses are rejected to prevent SSRF.
• HTTP redirects are disabled (Policy::none()) to prevent open-redirect bypasses.
• Domain allowlists and denylists from config are enforced before DNS resolution.

Example

use zeph_tools::{WebScrapeExecutor, ToolExecutor, ToolCall, config::ScrapeConfig};
use zeph_common::ToolName;

let executor = WebScrapeExecutor::new(&ScrapeConfig::default());

let call = ToolCall {
    tool_id: ToolName::new("fetch"),
    params: {
        let mut m = serde_json::Map::new();
        m.insert("url".to_owned(), serde_json::json!("https://example.com"));
        m
    },
    caller_id: None,
};
let _ = executor.execute_tool_call(&call).await;

Implementations

impl WebScrapeExecutor

pub fn new(config: &ScrapeConfig) -> Self

Create a new WebScrapeExecutor from configuration.

No network connections are made at construction time.

pub fn with_audit(self, logger: Arc<AuditLogger>) -> Self

Attach an audit logger. Each tool invocation will emit an AuditEntry.

Trait Implementations

impl Debug for WebScrapeExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ToolExecutor for WebScrapeExecutor

fn tool_definitions(&self) -> Vec<ToolDef>

Return the tool definitions this executor can handle.

async fn execute(&self, response: &str) -> Result<Option<ToolOutput>, ToolError>

Parse response for fenced tool blocks and execute them.

async fn execute_tool_call( &self, call: &ToolCall, ) -> Result<Option<ToolOutput>, ToolError>

Execute a structured tool call. Returns Ok(None) if call.tool_id is not handled.

fn is_tool_retryable(&self, tool_id: &str) -> bool

Whether the executor can safely retry this tool call on a transient error.

fn execute_confirmed( &self, response: &str, ) -> impl Future<Output = Result<Option<ToolOutput>, ToolError>> + Send

Execute bypassing confirmation checks (called after user approves).

fn execute_tool_call_confirmed( &self, call: &ToolCall, ) -> impl Future<Output = Result<Option<ToolOutput>, ToolError>> + Send

Execute a structured tool call bypassing confirmation checks.

fn set_skill_env(&self, _env: Option<HashMap<String, String>>)

Inject environment variables for the currently active skill. No-op by default.

fn set_effective_trust(&self, _level: SkillTrustLevel)

Set the effective trust level for the currently active skill. No-op by default.