meshlet-server 0.1.0

Sync relay server for meshlet: CRDT peer that stores and forwards bookmark updates
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

use std::net::SocketAddr;
use std::path::PathBuf;
use std::sync::Arc;

use clap::Parser;
use tokio::sync::Mutex;

use meshlet_server::{app_router, AppState, ServerDoc};

#[derive(Parser)]
#[command(name = "meshlet-server", version)]
struct Cli {
    /// Address to bind to
    #[arg(long, default_value = "127.0.0.1:3000")]
    bind: SocketAddr,

    /// Bearer token for authentication (optional)
    #[arg(long)]
    token: Option<String>,

    /// Data directory for state persistence
    #[arg(long)]
    data_dir: Option<PathBuf>,
}

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    tracing_subscriber::fmt::init();

    let cli = Cli::parse();

    let data_dir = cli
        .data_dir
        .unwrap_or_else(|| dirs::data_dir().unwrap_or_default().join("meshlet-server"));

    let server_doc = ServerDoc::load_or_create(&data_dir);
    tracing::info!("server started");

    let state = Arc::new(AppState {
        doc: Mutex::new(server_doc),
        token: cli.token,
        data_dir,
    });

    let app = app_router(state);

    let listener = tokio::net::TcpListener::bind(cli.bind).await?;
    tracing::info!("listening on {}", cli.bind);

    axum::serve(listener, app).await?;

    Ok(())
}