graph_fs 0.1.5

A CLI tool that helps query a local or remote file system by a GraphQL interface
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

use crate::auth::check_access::Authorized;
use crate::schema;
use crate::schema::GraphqlWebData;
use actix_web::{route, HttpResponse};
use actix_web::{web, HttpRequest, Responder};
use actix_web_lab::respond::Html;
use juniper::http::graphiql::graphiql_source;
use juniper::http::GraphQLRequest;

//graphql config
/// GraphiQL playground UI
pub async fn graphql_playground() -> impl Responder {
    Html(graphiql_source("/graphql", None))
}

/// GraphQL endpoint
#[route("/graphql", method = "GET", method = "POST")]
pub async fn graphql(
    st: web::Data<GraphqlWebData>,
    data: web::Json<GraphQLRequest>,
    req: HttpRequest,
    _: Authorized,
) -> impl Responder {
    let token = req.headers().get("authorization");

    match token {
        Some(token_value) => {
            //use ssh connection in context
            let ctx = schema::Context {
                sess: st.sess.clone(),
                //set auth token to context
                auth_token: Some(token_value.to_str().unwrap_or("").to_string()),
                args: st.args.clone(),
                db_conn: st.db_conn.clone(),
            };
            let value = data.execute(&st.schema, &ctx).await;
            HttpResponse::Ok().json(value)
        }
        None => {
            //use ssh connection in context
            let ctx = schema::Context {
                sess: st.sess.clone(),
                auth_token: None,
                args: st.args.clone(),
                db_conn: st.db_conn.clone(),
            };
            let value = data.execute(&st.schema, &ctx).await;
            HttpResponse::Ok().json(value)
        }
    }
}