starfish-api 0.1.1

StarfishQL - A graph database and query engine
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

use rocket::serde::json::Json;
use rocket::{post, routes};
use sea_orm_rocket::Connection;
use starfish_core::lang::mutate::MutateJson;
use starfish_core::lang::query::{QueryJson, QueryResultJson};
use starfish_core::lang::schema::SchemaJson;
use starfish_core::mutate::Mutate;
use starfish_core::query::Query;

use crate::{check_auth_match, db::pool::Db, ErrorResponder};
use starfish_core::schema::Schema;

pub fn routes() -> Vec<rocket::Route> {
    routes![schema, mutate, query,]
}

#[post("/schema?<auth>", data = "<input_data>")]
async fn schema(
    conn: Connection<'_, Db>,
    input_data: Json<SchemaJson>,
    auth: Option<String>,
) -> Result<(), ErrorResponder> {
    check_auth_match(auth)?;

    let db = conn.into_inner();
    let schema_json = input_data.clone();

    Schema::define_schema(db, schema_json)
        .await
        .map_err(Into::into)?;

    Ok(())
}

#[post("/mutate?<auth>&<upsert>", data = "<input_data>")]
async fn mutate(
    conn: Connection<'_, Db>,
    input_data: Json<MutateJson>,
    auth: Option<String>,
    upsert: bool,
) -> Result<(), ErrorResponder> {
    check_auth_match(auth)?;

    let db = conn.into_inner();
    let mutate_json = input_data.clone();

    Mutate::mutate(db, mutate_json, upsert)
        .await
        .map_err(Into::into)?;

    Ok(())
}

#[post("/query", data = "<input_data>")]
async fn query(
    conn: Connection<'_, Db>,
    input_data: Json<QueryJson>,
) -> Result<Json<QueryResultJson>, ErrorResponder> {
    let db = conn.into_inner();
    let query_json = input_data.clone();

    Ok(Json(
        Query::query(db, query_json).await.map_err(Into::into)?,
    ))
}