ninox-server 0.1.0

HTTP/WebSocket server exposing the Ninox engine to the native app and web dashboard.
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

use crate::routes::{
    brain::brain_router,
    events::events_router,
    orchestrators::orchestrators_router,
    sessions::sessions_router,
    terminal::terminal_router,
};
use ninox_core::{events::Engine, BrainIndex};
use axum::Router;
use std::{net::SocketAddr, sync::Arc};
use tower_http::cors::CorsLayer;

pub async fn start(engine: Arc<Engine>, brain: Arc<BrainIndex>, port: u16) -> anyhow::Result<()> {
    let addr = SocketAddr::from(([127, 0, 0, 1], port));
    let app = Router::new()
        .nest("/api/v1/sessions", sessions_router(engine.clone()))
        .nest("/api/v1/sessions", terminal_router(engine.clone()))
        .nest("/api/v1/orchestrators", orchestrators_router(engine.clone()))
        .nest("/api/v1/events", events_router(engine.clone()))
        .nest("/api/brain", brain_router(brain))
        .layer(CorsLayer::permissive());
    tracing::info!("ninox listening on {addr}");
    axum::serve(tokio::net::TcpListener::bind(addr).await?, app).await?;
    Ok(())
}