carbon-core 0.12.0

Core library for Carbon
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

use axum::{
    routing::{get, on, MethodFilter},
    Extension, Router,
};
use juniper::{EmptyMutation, EmptySubscription, RootNode};
use juniper_axum::{extract::JuniperRequest, graphiql, response::JuniperResponse};
use std::sync::Arc;

pub type DefaultMutation<C> = EmptyMutation<C>;
pub type DefaultSubscription<C> = EmptySubscription<C>;

pub fn build_schema<Q, C>(
    query_root: Q,
) -> Arc<RootNode<'static, Q, DefaultMutation<C>, DefaultSubscription<C>>>
where
    Q: juniper::GraphQLType<Context = C, TypeInfo = ()> + Send + Sync + 'static,
    C: juniper::Context + Send + Sync + 'static,
{
    Arc::new(RootNode::new(
        query_root,
        DefaultMutation::new(),
        DefaultSubscription::new(),
    ))
}

type ExtensionSchema<Q, C> =
    Extension<Arc<RootNode<'static, Q, DefaultMutation<C>, DefaultSubscription<C>>>>;

pub fn graphql_router<Q, C>(
    schema: Arc<RootNode<'static, Q, DefaultMutation<C>, DefaultSubscription<C>>>,
    context: C,
) -> Router
where
    Q: juniper::GraphQLTypeAsync<Context = C, TypeInfo = ()>
        + juniper::GraphQLValueAsync<Context = C, TypeInfo = ()>
        + Send
        + Sync
        + 'static,
    C: juniper::Context + Clone + Send + Sync + 'static,
{
    async fn handler<Q, C>(
        Extension(schema): ExtensionSchema<Q, C>,
        Extension(ctx): Extension<C>,
        juniper_axum::extract::JuniperRequest(req): JuniperRequest<juniper::DefaultScalarValue>,
    ) -> JuniperResponse<juniper::DefaultScalarValue>
    where
        Q: juniper::GraphQLTypeAsync<Context = C, TypeInfo = ()> + Send + Sync + 'static,
        C: juniper::Context + Clone + Send + Sync + 'static,
    {
        JuniperResponse(req.execute(&schema, &ctx).await)
    }

    Router::new()
        .route(
            "/graphql",
            on(MethodFilter::GET.or(MethodFilter::POST), handler::<Q, C>),
        )
        .route("/graphiql", get(graphiql("/graphql", None)))
        .layer(Extension(schema))
        .layer(Extension(context))
}