m1nd-mcp 0.8.0

MCP Server for m1nd. Stop letting AI grep your codebase. Neuro-symbolic connectome for AI agents.
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

// === m1nd-mcp/src/persist_handlers.rs ===
// Persist/load handler with optional binary snapshots.

use crate::session::SessionState;
use m1nd_core::error::M1ndResult;
use serde::Deserialize;
use std::path::PathBuf;
use std::sync::Arc;

#[derive(Debug, Deserialize)]
pub struct PersistInput {
    pub agent_id: String,
    pub action: String, // save | load | checkpoint | status
    #[serde(default)]
    pub format: Option<String>, // json | bin (default json)
    #[serde(default)]
    pub path: Option<String>, // override snapshot path
}

pub fn handle_persist(
    state: &mut SessionState,
    input: PersistInput,
) -> M1ndResult<serde_json::Value> {
    let fmt = input.format.as_deref().unwrap_or("json");
    let is_bin = fmt.eq_ignore_ascii_case("bin");

    // Default path: graph_path (json) or graph_path with .bin extension
    let default_path = if is_bin {
        state.graph_path.with_extension("bin")
    } else {
        state.graph_path.clone()
    };
    let path: PathBuf = input
        .path
        .as_ref()
        .map(PathBuf::from)
        .unwrap_or(default_path.clone());

    match input.action.as_str() {
        "status" => {
            let g = state.graph.read();
            let result = serde_json::json!({
                "status": "ok",
                "nodes": g.num_nodes(),
                "edges": g.num_edges(),
                "queries_processed": state.queries_processed,
                "graph_path": state.graph_path.to_string_lossy(),
                "plasticity_path": state.plasticity_path.to_string_lossy(),
                "snapshot_path": path.to_string_lossy(),
                "format_supported": ["json", "bin"],
            });
            Ok(result)
        }
        "checkpoint" | "save" => {
            if is_bin {
                // Save graph to binary snapshot + keep JSON/plasticity as today
                let g = state.graph.read();
                m1nd_core::snapshot_bin::save_graph(&g, &path)?;
                // Plasticity stays JSON for readability
                if let Ok(states) = state.plasticity.export_state(&g) {
                    let _ =
                        m1nd_core::snapshot::save_plasticity_state(&states, &state.plasticity_path);
                }
            } else {
                // Existing JSON path (graph + plasticity + antibodies)
                let _ = state.persist();
            }
            state.track_agent(&input.agent_id);
            Ok(serde_json::json!({
                "status": "saved",
                "graph_path": state.graph_path.to_string_lossy(),
                "plasticity_path": state.plasticity_path.to_string_lossy(),
                "bin_path": if is_bin { Some(path.to_string_lossy().to_string()) } else { None }
            }))
        }
        "load" => {
            // Load either JSON or BIN snapshot
            let graph = if is_bin {
                m1nd_core::snapshot_bin::load_graph(&path)?
            } else {
                m1nd_core::snapshot::load_graph(&path)?
            };

            // Swap graph and rebuild engines
            state.graph = Arc::new(parking_lot::RwLock::new(graph));
            state.rebuild_engines()?;
            state.bump_graph_generation();
            state.track_agent(&input.agent_id);

            let g = state.graph.read();
            Ok(serde_json::json!({
                "status": "loaded",
                "format": if is_bin { "bin" } else { "json" },
                "snapshot_path": path.to_string_lossy(),
                "nodes": g.num_nodes(),
                "edges": g.num_edges(),
            }))
        }
        other => Ok(serde_json::json!({
            "status": "error",
            "message": format!("Unknown action: {}", other)
        })),
    }
}