mnemes 0.1.0

Multi-device memory control plane — device/actor provenance, bitemporal lineage, semantic shard routing, idempotent operation envelopes, and replication for local-first AI agents
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

use mnemes::server::{build_memory_store, build_router};
use std::env;
use std::net::SocketAddr;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    if env::args().any(|value| value == "--help" || value == "-h") {
        eprintln!("usage: mnemes-server [PORT] [DATA_DIR]");
        eprintln!("       PORT defaults to 3000, DATA_DIR defaults to ./data/mnemes");
        return Ok(());
    }

    let args: Vec<String> = env::args().skip(1).collect();
    let port = args
        .first()
        .and_then(|value| value.parse::<u16>().ok())
        .unwrap_or(3000);

    let cli_base_dir = args.get(1).cloned().unwrap_or_default();
    let env_base_dir = env::var("MNEMES_DATA_DIR").unwrap_or_default();
    let base_dir = if !env_base_dir.is_empty() {
        env_base_dir
    } else if !cli_base_dir.is_empty() {
        cli_base_dir
    } else {
        "./data/mnemes".to_string()
    };

    let store = build_memory_store(&base_dir)?;

    let app = build_router(store);
    let listener = tokio::net::TcpListener::bind(SocketAddr::from(([127, 0, 0, 1], port))).await?;
    let local_addr = listener.local_addr()?;

    println!("mnemes server listening on http://{local_addr}/v1");
    axum::serve(listener, app).await?;
    Ok(())
}