anttp 0.26.0

AntTP is an HTTP server for the Autonomi Network
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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121

#![cfg_attr(test, warn(unused_imports, unused_variables, dead_code))]
use crate::service::command_service::CommandService;
use crate::service::chunk_service::ChunkService;
use crate::service::public_data_service::PublicDataService;
/*use crate::service::pnr_service::PnrService;
use crate::service::pointer_service::PointerService;
use crate::service::register_service::RegisterService;
use crate::service::graph_service::GraphService;
use crate::service::public_archive_service::PublicArchiveService;
use crate::service::scratchpad_service::ScratchpadService;*/
use crate::service::archive_service::ArchiveService;
use crate::service::tarchive_service::TarchiveService;
use crate::service::resolver_service::ResolverService;
/*use crate::service::key_value_service::KeyValueService;*/
use crate::service::crypto_service::CryptoService;
use actix_web::web::Data;
use ant_core::data::Wallet;
use rmcp::handler::server::tool::ToolRouter;
use rmcp::model::{ServerCapabilities, ServerInfo};
use rmcp::{tool_handler, ServerHandler};


pub mod archive_tool;
pub mod pnr_tool;
pub mod chunk_tool;
pub mod command_tool;
pub mod public_data_tool;
pub mod pointer_tool;
pub mod register_tool;
pub mod graph_tool;
pub mod public_archive_tool;
pub mod public_scratchpad_tool;
pub mod private_scratchpad_tool;
pub mod tarchive_tool;
pub mod resolver_tool;
pub mod key_value_tool;
pub mod crypto_tool;

#[derive(Clone)]
pub struct McpTool {
    command_service: Data<CommandService>,
    chunk_service: Data<ChunkService>,
    /*pnr_service: Data<PnrService>,*/
    public_data_service: Data<PublicDataService>,
    /*pointer_service: Data<PointerService>,
    register_service: Data<RegisterService>,
    graph_service: Data<GraphService>,
    public_archive_service: Data<PublicArchiveService>,*/
    archive_service: Data<ArchiveService>,
    /*scratchpad_service: Data<ScratchpadService>,*/
    tarchive_service: Data<TarchiveService>,
    resolver_service: Data<ResolverService>,
    /*key_value_service: Data<KeyValueService>,*/
    crypto_service: Data<CryptoService>,
    evm_wallet: Data<Wallet>,
    tool_router: ToolRouter<Self>,
}

impl McpTool {
    pub fn new(
        command_service: Data<CommandService>,
        chunk_service: Data<ChunkService>,
        /*pnr_service: Data<PnrService>,*/
        public_data_service: Data<PublicDataService>,
        /*pointer_service: Data<PointerService>,
        register_service: Data<RegisterService>,
        graph_service: Data<GraphService>,
        public_archive_service: Data<PublicArchiveService>,*/
        archive_service: Data<ArchiveService>,
        /*scratchpad_service: Data<ScratchpadService>,*/
        tarchive_service: Data<TarchiveService>,
        resolver_service: Data<ResolverService>,
        /*key_value_service: Data<KeyValueService>,*/
        crypto_service: Data<CryptoService>,
        evm_wallet: Data<Wallet>
    ) -> Self {
        Self {
            command_service,
            chunk_service,
            /*pnr_service,*/
            public_data_service,
            /*pointer_service,
            register_service,
            graph_service,
            public_archive_service,*/
            archive_service,
            /*scratchpad_service,*/
            tarchive_service,
            resolver_service,
            /*key_value_service,*/
            crypto_service,
            evm_wallet,
            tool_router: Self::chunk_tool_router()
                /*+ Self::pnr_tool_router()*/
                + Self::command_tool_router()
                + Self::public_data_tool_router()
                /*+ Self::pointer_tool_router()
                + Self::register_tool_router()
                + Self::graph_tool_router()
                + Self::public_archive_tool_router()*/
                + Self::archive_tool_router()
                /*+ Self::public_scratchpad_tool_router()
                + Self::private_scratchpad_tool_router()*/
                + Self::tarchive_tool_router()
                + Self::resolver_tool_router()
                /*+ Self::key_value_tool_router()*/
                + Self::crypto_tool_router()
        }
    }
}

#[tool_handler]
impl ServerHandler for McpTool {
    fn get_info(&self) -> ServerInfo {
        ServerInfo {
            instructions: Some("AntTP tools for creating and retrieving data on Autonomi Network".into()),
            capabilities: ServerCapabilities::builder().enable_tools().build(),
            ..Default::default()
        }
    }
}