mentedb-server 0.41.0

MenteDB server with REST API, WebSocket, auth, and observability
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

//! Route definitions for the MenteDB REST API.

use std::sync::Arc;

use axum::Router;
use axum::routing::{delete, get, post};

use crate::handlers;
use crate::hosting;
use crate::state::AppState;
use crate::websocket;

/// Routes that act on one database. Mounted twice: under `/v1` for the
/// default database and under `/v1/db/{db}` for a named one.
fn database_routes() -> Router<Arc<AppState>> {
    Router::new()
        .route(
            "/memories",
            post(handlers::store_memory).get(hosting::list_memories),
        )
        .route(
            "/memories/{id}",
            get(handlers::get_memory)
                .delete(handlers::forget_memory)
                .patch(hosting::patch_memory),
        )
        .route("/recall", post(handlers::recall_memories))
        .route("/search", post(handlers::search_similar))
        .route("/edges", post(handlers::create_edge))
        .route("/stats", get(handlers::stats))
        .route("/ingest", post(handlers::ingest_conversation))
        .route("/process_turn", post(handlers::process_turn))
        .route("/admin/memories", get(handlers::admin_list_memories))
        .route(
            "/admin/memories/{id}",
            delete(handlers::admin_delete_memory),
        )
        .route("/admin/mql", post(handlers::admin_run_mql))
        .merge(crate::handlers_memory::routes())
        .merge(crate::handlers_ops::routes())
        .merge(hosting::routes())
}

/// Build the complete axum router with all v1 API routes.
pub fn build_router(state: Arc<AppState>) -> Router {
    Router::new()
        .route("/v1/health", get(handlers::health))
        .route("/v1/auth/token", post(crate::auth::generate_token))
        .route(
            "/v1/spaces",
            post(handlers::create_space).get(handlers::list_spaces),
        )
        .route("/v1/spaces/{id}/grant", post(handlers::grant_space_access))
        .route("/v1/ws/stream", get(websocket::ws_handler))
        .route(
            crate::cluster::GOSSIP_PATH,
            post(crate::cluster::gossip_handler),
        )
        .route("/metrics", get(crate::metrics::handler))
        .route("/console", get(crate::console::handler))
        .merge(crate::handlers_ops::global_routes())
        .merge(hosting::global_routes())
        .nest("/v1", database_routes())
        .nest("/v1/db/{db}", database_routes())
        .with_state(state)
}