fs-mcp-rs 1.2.4

A fast, configurable filesystem MCP server with explicit root isolation and bounded I/O
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
66
67
68
69
70
71
72
73

//! Application state context shared across handlers and transports.

use crate::oauth::OAuthStore;
use anyhow::Result;
use fs_mcp_rs::{
    filesystem::Filesystem, search::Searcher, security::Policy, settings::Settings,
    terminal::Terminal, tree::TreeLister,
};
use std::sync::Arc;
use tokio::sync::Semaphore;

#[derive(Clone)]
/// Shared services and concurrency gates for HTTP and STDIO request handlers.
pub(crate) struct App {
    pub(crate) fs: Filesystem,
    pub(crate) search: Searcher,
    pub(crate) tree: TreeLister,
    pub(crate) settings: Arc<Settings>,
    pub(crate) terminal: Terminal,
    pub(crate) oauth: OAuthStore,
    pub(crate) permits: Arc<Semaphore>,
    pub(crate) io_permits: Arc<Semaphore>,
    pub(crate) search_permits: Arc<Semaphore>,
}

impl App {
    pub(crate) fn new(settings: Settings) -> Result<Self> {
        let policy = Policy::new(
            settings.filesystem.roots.clone(),
            settings.filesystem.read_only,
            settings.filesystem.follow_links,
        )?;
        Ok(Self {
            tree: TreeLister::new(
                policy.clone(),
                settings.filesystem.tree_max_depth,
                settings.filesystem.tree_max_entries,
                settings.filesystem.tree_max_warnings,
                settings.search.include_hidden,
                settings.search.respect_gitignore,
                settings.filesystem.follow_links,
            ),
            fs: Filesystem::new(
                policy.clone(),
                settings.filesystem.max_read_bytes,
                settings.filesystem.max_write_bytes,
            ),
            search: Searcher::new(
                policy,
                settings.search.max_results,
                settings.search.worker_threads,
                settings.search.regex_cache_capacity,
                settings.search.include_hidden,
                settings.search.respect_gitignore,
            ),
            terminal: Terminal::new(
                settings.terminal.enabled,
                settings.terminal.max_concurrency,
                settings.terminal.default_timeout_ms,
                settings.terminal.max_timeout_ms,
                settings.terminal.max_output_bytes,
                settings.terminal.max_read_bytes,
                settings.terminal.max_wait_ms,
                settings.terminal.session_retention_ms,
            ),
            oauth: OAuthStore::new(),
            permits: Arc::new(Semaphore::new(settings.server.max_concurrency)),
            io_permits: Arc::new(Semaphore::new(settings.server.max_io_concurrency)),
            search_permits: Arc::new(Semaphore::new(settings.search.max_concurrency)),
            settings: Arc::new(settings),
        })
    }
}