agentic-vision-mcp 0.3.0

MCP server for AgenticVision — universal LLM access to persistent visual memory
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

//! Resource registration and dispatch.

use std::sync::Arc;
use tokio::sync::Mutex;

use crate::session::VisionSessionManager;
use crate::types::{
    McpError, McpResult, ReadResourceResult, ResourceDefinition, ResourceTemplateDefinition,
};

use super::{capture, session, similar, stats, templates, timeline};

pub struct ResourceRegistry;

impl ResourceRegistry {
    pub fn list_templates() -> Vec<ResourceTemplateDefinition> {
        templates::list_templates()
    }

    pub fn list_resources() -> Vec<ResourceDefinition> {
        templates::list_resources()
    }

    pub async fn read(
        uri: &str,
        session: &Arc<Mutex<VisionSessionManager>>,
    ) -> McpResult<ReadResourceResult> {
        if let Some(id_str) = uri.strip_prefix("avis://capture/") {
            let id: u64 = id_str
                .parse()
                .map_err(|_| McpError::InvalidParams(format!("Invalid capture ID: {id_str}")))?;
            capture::read_capture(id, session).await
        } else if let Some(id_str) = uri.strip_prefix("avis://session/") {
            let id: u32 = id_str
                .parse()
                .map_err(|_| McpError::InvalidParams(format!("Invalid session ID: {id_str}")))?;
            session::read_session(id, session).await
        } else if let Some(rest) = uri.strip_prefix("avis://timeline/") {
            let parts: Vec<&str> = rest.split('/').collect();
            if parts.len() != 2 {
                return Err(McpError::InvalidParams(
                    "Timeline URI must be avis://timeline/{start}/{end}".to_string(),
                ));
            }
            let start: u64 = parts[0]
                .parse()
                .map_err(|_| McpError::InvalidParams("Invalid start timestamp".to_string()))?;
            let end: u64 = parts[1]
                .parse()
                .map_err(|_| McpError::InvalidParams("Invalid end timestamp".to_string()))?;
            timeline::read_timeline(start, end, session).await
        } else if let Some(id_str) = uri.strip_prefix("avis://similar/") {
            let id: u64 = id_str
                .parse()
                .map_err(|_| McpError::InvalidParams(format!("Invalid capture ID: {id_str}")))?;
            similar::read_similar(id, session).await
        } else if uri == "avis://stats" {
            stats::read_stats(session).await
        } else if uri == "avis://recent" {
            stats::read_recent(session).await
        } else {
            Err(McpError::ResourceNotFound(uri.to_string()))
        }
    }
}