eight 1.0.0-alpha.2

Modular asynchronous embedded key-value database
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

use crate::client::messaging::{Request, Response};
use crate::embedded::server::Server;
use axum::{extract::State, http::StatusCode, Json};
use tracing::{debug, info};

pub(super) async fn run_query(
    State(database): State<Server>,
    Json(payload): Json<Request>,
) -> (StatusCode, Json<Response>) {
    let Request { query, vars, id } = payload;
    info!("Incoming request with ID:{id}");

    let response = database.query(query, vars).await;
    debug!("Sending response for {id} -> {response:?}");

    match response {
        Ok(results) => (StatusCode::OK, Json(Response { id, results })),
        Err(error) => (
            StatusCode::BAD_REQUEST,
            Json(Response {
                id,
                results: vec![error.as_response()],
            }),
        ),
    }
}