river-data-core 0.1.0

Common types & traits for the in the river-data platform
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

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

use crate::server::handlers::{admin, commands, enroll, events, heartbeat};
use crate::server::state::SyncState;

/// Build the sync control plane routers.
///
/// Returns `(service_routes, admin_routes)`:
/// - `service_routes`: Mount at `/api/service/sync` — enrollment (unauthenticated),
///   heartbeat + commands + events (auth via SyncServiceContext extractor)
/// - `admin_routes`: Mount at `/api/admin/sync` — the host app should wrap with its
///   own admin auth (e.g., Keycloak)
pub fn routes<S: SyncState>() -> (Router<S>, Router<S>) {
    let service_routes = Router::new()
        .route("/enroll", post(enroll::enroll::<S>))
        .route("/heartbeat", post(heartbeat::heartbeat::<S>))
        .route("/commands/{id}", patch(commands::update_command::<S>))
        .route("/events", post(events::create_sync_event::<S>))
        .route("/events/{id}", patch(events::update_sync_event::<S>));

    let admin_routes = Router::new()
        .route("/services", get(admin::list_services::<S>))
        .route("/services/{id}", get(admin::get_service::<S>))
        .route(
            "/services/{id}/commands",
            post(admin::issue_command::<S>),
        )
        .route(
            "/services/{id}/revoke",
            post(admin::revoke_service::<S>),
        )
        .route("/commands", get(admin::list_commands::<S>))
        .route("/events", get(admin::list_sync_events::<S>))
        .route(
            "/credentials",
            get(admin::list_credentials::<S>).post(admin::create_credential::<S>),
        )
        .route(
            "/credentials/{id}/revoke",
            post(admin::revoke_credential::<S>),
        );

    (service_routes, admin_routes)
}