vimwiki-server 0.1.0

Daemon that supports parsing and modifying vimwiki files.
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

use crate::{graphql, Opt};
use log::*;
use std::convert::Infallible;
use warp::{reply::Reply, Filter};

macro_rules! graphql_endpoint {
    ($path:expr, $program:expr) => {{
        let schema = graphql::new_schema();
        warp::path($path).and(
            async_graphql_warp::graphql(schema).and_then(
                |(schema, request): (
                    graphql::Schema,
                    async_graphql::Request,
                )| async move {
                    let resp = schema.execute(request).await;
                    Ok::<_, Infallible>(
                        warp::reply::json(&resp).into_response(),
                    )
                },
            ),
        )
    }};
}

macro_rules! graphiql_endpoint {
    ($path:expr, $graphql_endpoint:expr) => {{
        warp::path($path).map(move || {
            warp::reply::html(async_graphql::http::graphiql_source(
                $graphql_endpoint,
                None,
            ))
        })
    }};
}

pub async fn run(opt: Opt) {
    let graphql_filter = graphql_endpoint!("graphql", program);

    info!("Listening on {}:{}", opt.host, opt.port);
    if opt.graphiql {
        info!("Enabling graphiql interface");
        let graphiql_filter = graphiql_endpoint!("graphiql", "/graphql");
        let routes = warp::any().and(graphiql_filter.or(graphql_filter));
        warp::serve(routes).run((opt.host, opt.port)).await;
    } else {
        info!("Disabling graphiql interface");
        let routes = warp::any().and(graphql_filter);
        warp::serve(routes).run((opt.host, opt.port)).await;
    };
}