synapse-core 0.8.5

A neuro-symbolic semantic engine for OpenClaw, combining graph databases with vector operations.
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

use std::env;
use std::sync::Arc;
use synapse_core::server::{
    proto::semantic_engine_server::SemanticEngineServer, run_mcp_stdio, MySemanticEngine,
};
use tonic::transport::Server;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let args: Vec<String> = env::args().collect();
    let is_mcp = args.contains(&"--mcp".to_string());

    // Get storage path from env or default
    let storage_path = env::var("GRAPH_STORAGE_PATH").unwrap_or_else(|_| "data/graphs".to_string());

    let engine = MySemanticEngine::new(&storage_path);

    // Ensure 'core' scenario is installed on startup (backgrounded for MCP performance)
    let engine_init = engine.clone();
    tokio::spawn(async move {
        match engine_init.install_scenario("core", "default").await {
            Ok(msg) => eprintln!("{}", msg),
            Err(e) => eprintln!("Failed to load core scenario: {}", e),
        }
    });

    if is_mcp {
        // MCP mode: no stdout messages, only JSON-RPC
        eprintln!("Synapse-MCP starting (stdio mode)...");
        run_mcp_stdio(Arc::new(engine)).await?;
    } else {
        println!(
            r#"

  _________.__. ____ _____  ______  ______ ____
 /  ___<   |  |/    \\__  \ \____ \/  ___// __ \
 \___ \ \___  |   |  \/ __ \|  |_> >___ \\  ___/
/____  >/ ____|___|  (____  /   __/____  >\___  >
     \/ \/         \/     \/|__|       \/     \/
"#
        );
        let addr = "[::1]:50051".parse()?;
        println!("🚀 Synapse (ex-Grafoso) listening on {}", addr);
        println!("Storage Path: {}", storage_path);

        let engine_clone = engine.clone();

        Server::builder()
            .add_service(SemanticEngineServer::with_interceptor(
                engine,
                synapse_core::server::auth_interceptor,
            ))
            .serve_with_shutdown(addr, async move {
                if tokio::signal::ctrl_c().await.is_ok() {
                    println!("\nShutting down Synapse...");
                }
                engine_clone.shutdown().await;
            })
            .await?;
    }

    Ok(())
}