From 824153d740e87f992422a5d7cfd4126ba2996c36 Mon Sep 17 00:00:00 2001 From: Calin Gavriliuc <13826789+alisenai@users.noreply.github.com> Date: Sun, 3 Apr 2022 22:02:55 -0700 Subject: [PATCH 1/4] Update Axum integration to Axum 0.5 --- integrations/axum/Cargo.toml | 2 +- integrations/axum/src/extract.rs | 2 +- integrations/axum/src/subscription.rs | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/integrations/axum/Cargo.toml b/integrations/axum/Cargo.toml index 292634cf..0277c77d 100644 --- a/integrations/axum/Cargo.toml +++ b/integrations/axum/Cargo.toml @@ -15,7 +15,7 @@ categories = ["network-programming", "asynchronous"] async-graphql = { path = "../..", version = "3.0.37" } async-trait = "0.1.51" -axum = { version = "0.4", features = ["ws", "headers"] } +axum = { version = "0.5", features = ["ws", "headers"] } bytes = "1.0.1" http-body = "0.4.2" serde_json = "1.0.66" diff --git a/integrations/axum/src/extract.rs b/integrations/axum/src/extract.rs index 264d48d8..df298cfa 100644 --- a/integrations/axum/src/extract.rs +++ b/integrations/axum/src/extract.rs @@ -106,7 +106,7 @@ where } else { let content_type = req .headers() - .and_then(|headers| headers.get(http::header::CONTENT_TYPE)) + .get(http::header::CONTENT_TYPE) .and_then(|value| value.to_str().ok()) .map(ToString::to_string); let body_stream = BodyStream::from_request(req) diff --git a/integrations/axum/src/subscription.rs b/integrations/axum/src/subscription.rs index 11c3fe4b..9333bb7e 100644 --- a/integrations/axum/src/subscription.rs +++ b/integrations/axum/src/subscription.rs @@ -29,7 +29,7 @@ impl FromRequest for GraphQLProtocol { async fn from_request(req: &mut RequestParts) -> Result { req.headers() - .and_then(|headers| headers.get(http::header::SEC_WEBSOCKET_PROTOCOL)) + .get(http::header::SEC_WEBSOCKET_PROTOCOL) .and_then(|value| value.to_str().ok()) .and_then(|protocols| { protocols From 6c5081b392e6ca3f82630e06c41a62812292088c Mon Sep 17 00:00:00 2001 From: Calin Gavriliuc <13826789+alisenai@users.noreply.github.com> Date: Sun, 3 Apr 2022 22:46:38 -0700 Subject: [PATCH 2/4] Update Axum integration to Axum 0.5.1 --- integrations/axum/Cargo.toml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/integrations/axum/Cargo.toml b/integrations/axum/Cargo.toml index 0277c77d..7c1180ee 100644 --- a/integrations/axum/Cargo.toml +++ b/integrations/axum/Cargo.toml @@ -15,7 +15,7 @@ categories = ["network-programming", "asynchronous"] async-graphql = { path = "../..", version = "3.0.37" } async-trait = "0.1.51" -axum = { version = "0.5", features = ["ws", "headers"] } +axum = { version = "0.5.1", features = ["ws", "headers"] } bytes = "1.0.1" http-body = "0.4.2" serde_json = "1.0.66" From f8b1502fefde2c51ef613e1e13345656e3a96b06 Mon Sep 17 00:00:00 2001 From: Calin Gavriliuc <13826789+alisenai@users.noreply.github.com> Date: Thu, 7 Apr 2022 15:11:37 -0700 Subject: [PATCH 3/4] Update examples submodule --- examples | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples b/examples index 6a638085..ef09f81f 160000 --- a/examples +++ b/examples @@ -1 +1 @@ -Subproject commit 6a63808523f7e4995f9111a3497f06921cd3b11b +Subproject commit ef09f81f6f348eb2ba4d24ec1dc4ed84b2ed684f From 4831364f01b2af7362f187ed799800dc700b756d Mon Sep 17 00:00:00 2001 From: Calin Gavriliuc <13826789+alisenai@users.noreply.github.com> Date: Thu, 7 Apr 2022 17:55:32 -0700 Subject: [PATCH 4/4] Clippy check fixes --- src/http/mod.rs | 4 ++-- src/look_ahead.rs | 4 ---- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/src/http/mod.rs b/src/http/mod.rs index c97e02bf..2fddf6e9 100644 --- a/src/http/mod.rs +++ b/src/http/mod.rs @@ -91,8 +91,8 @@ pub async fn receive_batch_json(body: impl AsyncRead) -> Result(&data) - .map_err(|e| ParseRequestError::InvalidRequest(Box::new(e)))?) + serde_json::from_slice::(&data) + .map_err(|e| ParseRequestError::InvalidRequest(Box::new(e))) } /// Receive a GraphQL request from a body as CBOR. diff --git a/src/look_ahead.rs b/src/look_ahead.rs index 90844c54..e8629707 100644 --- a/src/look_ahead.rs +++ b/src/look_ahead.rs @@ -38,7 +38,6 @@ impl<'a> Lookahead<'a> { self.fragments, &field.selection_set.node, name, - self.context, ) } @@ -108,7 +107,6 @@ fn filter<'a>( fragments: &'a HashMap>, selection_set: &'a SelectionSet, name: &str, - context: &'a Context<'a>, ) { for item in &selection_set.items { match &item.node { @@ -122,7 +120,6 @@ fn filter<'a>( fragments, &fragment.node.selection_set.node, name, - context, ), Selection::FragmentSpread(spread) => { if let Some(fragment) = fragments.get(&spread.node.fragment_name.node) { @@ -131,7 +128,6 @@ fn filter<'a>( fragments, &fragment.node.selection_set.node, name, - context, ) } }