anna/async-graphql
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add async-graphql-tide::ResponseExt

Browse Source
This commit is contained in:
Sunli 2020-05-14 15:24:24 +08:00
parent 3cd98918db
commit ed6c87b004
2 changed files with 23 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
async-graphql-tide/Cargo.toml
View File

@ -1,6 +1,6 @@
[package]
name = "async-graphql-tide"
version = "1.4.4"
version = "1.4.5"
authors = ["vkill <vkill.net@gmail.com>"]
edition = "2018"
description = "async-graphql for tide"
@ -16,9 +16,9 @@ categories = ["network-programming", "asynchronous"]
async-graphql = { path = "..", version = "1.12.4" }
tide = "0.8"
async-trait = "0.1.30"
serde_json = "1.0.51"
[dev-dependencies]
async-std = "1.5.0"
serde_json = "1.0.51"
smol = { version = "0.1", features = ["tokio02"] }
reqwest = "0.10.4"

29
async-graphql-tide/src/lib.rs
View File

@ -6,8 +6,8 @@
use async_graphql::http::GQLResponse;
use async_graphql::{
IntoQueryBuilder, IntoQueryBuilderOpts, ObjectType, ParseRequestError, QueryBuilder, Schema,
SubscriptionType,
IntoQueryBuilder, IntoQueryBuilderOpts, ObjectType, ParseRequestError, QueryBuilder,
QueryResponse, Schema, SubscriptionType,
};
use async_trait::async_trait;
use tide::{http::headers, Request, Response, Status, StatusCode};
@ -57,7 +57,7 @@ where
TideState: Send + Sync + 'static,
F: Fn(QueryBuilder) -> QueryBuilder + Send,
{
let query_builder = req.graphql().await.status(StatusCode::BadRequest)?;
let query_builder = req.body_graphql().await.status(StatusCode::BadRequest)?;
let resp = GQLResponse(
query_builder_configuration(query_builder)
.execute(&schema)
@ -81,7 +81,7 @@ where
F: Fn(QueryBuilder) -> QueryBuilder + Send,
{
let query_builder = req
.graphql_opts(opts)
.body_graphql_opts(opts)
.await
.status(StatusCode::BadRequest)?;
let resp = GQLResponse(
@ -97,12 +97,12 @@ where
#[async_trait]
pub trait RequestExt<State: Send + Sync + 'static>: Sized {
/// Convert a query to `async_graphql::QueryBuilder`.
async fn graphql(self) -> Result<QueryBuilder, ParseRequestError> {
self.graphql_opts(Default::default()).await
async fn body_graphql(self) -> Result<QueryBuilder, ParseRequestError> {
self.body_graphql_opts(Default::default()).await
}
/// Similar to graphql, but you can set the options `IntoQueryBuilderOpts`.
async fn graphql_opts(
async fn body_graphql_opts(
self,
opts: IntoQueryBuilderOpts,
) -> Result<QueryBuilder, ParseRequestError>;
@ -110,7 +110,7 @@ pub trait RequestExt<State: Send + Sync + 'static>: Sized {
#[async_trait]
impl<State: Send + Sync + 'static> RequestExt<State> for Request<State> {
async fn graphql_opts(
async fn body_graphql_opts(
self,
opts: IntoQueryBuilderOpts,
) -> Result<QueryBuilder, ParseRequestError> {
@ -120,3 +120,16 @@ impl<State: Send + Sync + 'static> RequestExt<State> for Request<State> {
(content_type, self).into_query_builder_opts(&opts).await
}
}
/// Tide response extension
///
pub trait ResponseExt<State: Send + Sync + 'static>: Sized {
/// Set Body as the result of a GraphQL query.
fn body_graphql(self, res: async_graphql::Result<QueryResponse>) -> serde_json::Result<Self>;
}
impl<State: Send + Sync + 'static> ResponseExt<State> for Response {
fn body_graphql(self, res: async_graphql::Result<QueryResponse>) -> serde_json::Result<Self> {
self.body_json(&GQLResponse(res))
}
}