actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2024-11-30 18:34:36 +01:00
Code Issues Releases Wiki Activity

update juniper example

Browse Source
This commit is contained in:
Nikolay Kim 2018-04-04 17:57:02 -07:00
parent d8a9606162
commit c1af59c618
1 changed files with 18 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
examples/juniper/src/main.rs
View File

@ -14,11 +14,10 @@ extern crate env_logger;
use actix::prelude::*; use actix::prelude::*;
use actix_web::{ use actix_web::{
middleware, http::{self, header::CONTENT_TYPE}, server, middleware, http, server,
App, AsyncResponder, HttpRequest, HttpResponse, HttpMessage, Error}; App, AsyncResponder, HttpRequest, HttpResponse, FutureResponse, Error, State, Json};
use juniper::http::graphiql::graphiql_source; use juniper::http::graphiql::graphiql_source;
use juniper::http::GraphQLRequest; use juniper::http::GraphQLRequest;
use futures::future::Future; use futures::future::Future;
mod schema; mod schema;
@ -26,7 +25,7 @@ mod schema;
use schema::Schema; use schema::Schema;
use schema::create_schema; use schema::create_schema;
struct State { struct AppState {
executor: Addr<Syn, GraphQLExecutor>, executor: Addr<Syn, GraphQLExecutor>,
} }
@ -63,33 +62,30 @@ impl Handler<GraphQLData> for GraphQLExecutor {
} }
} }
fn graphiql(_req: HttpRequest<State>) -> Result<HttpResponse, Error> { fn graphiql(_req: HttpRequest<AppState>) -> Result<HttpResponse, Error> {
let html = graphiql_source("http://127.0.0.1:8080/graphql"); let html = graphiql_source("http://127.0.0.1:8080/graphql");
Ok(HttpResponse::Ok() Ok(HttpResponse::Ok()
.content_type("text/html; charset=utf-8") .content_type("text/html; charset=utf-8")
.body(html)) .body(html))
} }
fn graphql(req: HttpRequest<State>) -> Box<Future<Item=HttpResponse, Error=Error>> { fn graphql(st: State<AppState>, data: Json<GraphQLData>) -> FutureResponse<HttpResponse> {
let executor = req.state().executor.clone(); st.executor.send(data.0)
req.json()
.from_err()
.and_then(move |val: GraphQLData| {
executor.send(val)
.from_err() .from_err()
.and_then(|res| { .and_then(|res| {
match res { match res {
Ok(user) => Ok(HttpResponse::Ok().header(CONTENT_TYPE, "application/json").body(user)), Ok(user) => Ok(HttpResponse::Ok()
.content_type("application/json")
.body(user)),
Err(_) => Ok(HttpResponse::InternalServerError().into()) Err(_) => Ok(HttpResponse::InternalServerError().into())
} }
}) })
})
.responder() .responder()
} }
fn main() { fn main() {
::std::env::set_var("RUST_LOG", "actix_web=info"); ::std::env::set_var("RUST_LOG", "actix_web=info");
let _ = env_logger::init(); env_logger::init();
let sys = actix::System::new("juniper-example"); let sys = actix::System::new("juniper-example");
let schema = std::sync::Arc::new(create_schema()); let schema = std::sync::Arc::new(create_schema());
@ -99,10 +95,10 @@ fn main() {
// Start http server // Start http server
let _ = server::new(move || { let _ = server::new(move || {
App::with_state(State{executor: addr.clone()}) App::with_state(AppState{executor: addr.clone()})
// enable logger // enable logger
.middleware(middleware::Logger::default()) .middleware(middleware::Logger::default())
.resource("/graphql", |r| r.method(http::Method::POST).h(graphql)) .resource("/graphql", |r| r.method(http::Method::POST).with2(graphql))
.resource("/graphiql", |r| r.method(http::Method::GET).h(graphiql))}) .resource("/graphiql", |r| r.method(http::Method::GET).h(graphiql))})
.bind("127.0.0.1:8080").unwrap() .bind("127.0.0.1:8080").unwrap()
.start(); .start();