stygian-plugin 0.13.5

Visual data extraction fallback subsystem with CSS/XPath selectors, idempotent request handling, and composable transformation pipelines.
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

//! Shared server state injected into axum handlers.

use crate::config::Config;
use crate::error::{PluginError, Result as PluginResult};
use crate::mcp::{McpPluginServer, McpRequestHandler};
use std::sync::Arc;

/// Axum application state — cloned cheaply via `Arc` on every request.
#[derive(Clone)]
pub struct AppState {
    /// The JSON-RPC dispatcher (wraps `McpPluginServer`).
    pub handler: Arc<McpRequestHandler>,
}

impl AppState {
    /// Build application state from config, constructing the full handler chain.
    ///
    /// # Errors
    ///
    /// Returns [`PluginError`] if the template store cannot be initialized.
    pub fn new(config: Config) -> PluginResult<Self> {
        // Validate templates dir path up-front to surface bad config early
        if let Some(parent) = config.templates_dir.parent()
            && !parent.as_os_str().is_empty()
            && !parent.exists()
        {
            std::fs::create_dir_all(parent).map_err(|e| {
                PluginError::Other(format!(
                    "cannot create templates directory {}: {e}",
                    parent.display()
                ))
            })?;
        }

        let server = Arc::new(McpPluginServer::new_with_file_storage(
            config.templates_dir.clone(),
        ));
        let handler = Arc::new(McpRequestHandler::new(Arc::clone(&server), config));
        Ok(Self { handler })
    }
}