Axum integration

Cargo.toml

@@ -14,6 +14,7 @@ members = [
     "juniper_graphql_ws",
     "juniper_warp",
     "juniper_actix",
+    "juniper_axum",
     "tests/codegen",
     "tests/integration",
 ]

juniper/src/http/mod.rs

@@ -400,6 +400,9 @@ pub mod tests {
         println!("  - test_get_with_variables");
         test_get_with_variables(integration);
 
+        println!("  - test_post_with_variables");
+        test_post_with_variables(integration);
+
         println!("  - test_simple_post");
         test_simple_post(integration);
 
@@ -510,6 +513,40 @@ pub mod tests {
         );
     }
 
+    fn test_post_with_variables<T: HttpIntegration>(integration: &T) {
+        let response = integration.post_json(
+            "/",
+            r#"{
+            "query": "query($id: String!) { human(id: $id) { id, name, appearsIn, homePlanet } }",
+            "variables": { "id": "1000" }
+        }"#,
+        );
+
+        assert_eq!(response.status_code, 200);
+        assert_eq!(response.content_type, "application/json");
+
+        assert_eq!(
+            unwrap_json_response(&response),
+            serde_json::from_str::<Json>(
+                r#"{
+                    "data": {
+                        "human": {
+                            "appearsIn": [
+                                "NEW_HOPE",
+                                "EMPIRE",
+                                "JEDI"
+                                ],
+                                "homePlanet": "Tatooine",
+                                "name": "Luke Skywalker",
+                                "id": "1000"
+                            }
+                        }
+                    }"#
+            )
+            .expect("Invalid JSON constant in test")
+        );
+    }
+
     fn test_simple_post<T: HttpIntegration>(integration: &T) {
         let response = integration.post_json("/", r#"{"query": "{hero{name}}"}"#);
 
@@ -690,7 +727,7 @@ pub mod tests {
                 r#"{
                     "type":"connection_error",
                     "payload":{
-                        "message":"serde error: expected value at line 1 column 1"
+                        "message":"expected value at line 1 column 1"
                     }
                 }"#
                 .into(),

juniper/src/schema/meta.rs

@@ -43,6 +43,7 @@ impl DeprecationStatus {
 }
 
 /// Scalar type metadata
+#[derive(Clone)]
 pub struct ScalarMeta<'a, S> {
     #[doc(hidden)]
     pub name: Cow<'a, str>,
@@ -61,7 +62,7 @@ pub type InputValueParseFn<S> = for<'b> fn(&'b InputValue<S>) -> Result<(), Fiel
 pub type ScalarTokenParseFn<S> = for<'b> fn(ScalarToken<'b>) -> Result<S, ParseError>;
 
 /// List type metadata
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub struct ListMeta<'a> {
     #[doc(hidden)]
     pub of_type: Type<'a>,
@@ -71,14 +72,14 @@ pub struct ListMeta<'a> {
 }
 
 /// Nullable type metadata
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub struct NullableMeta<'a> {
     #[doc(hidden)]
     pub of_type: Type<'a>,
 }
 
 /// Object type metadata
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub struct ObjectMeta<'a, S> {
     #[doc(hidden)]
     pub name: Cow<'a, str>,
@@ -91,6 +92,7 @@ pub struct ObjectMeta<'a, S> {
 }
 
 /// Enum type metadata
+#[derive(Clone)]
 pub struct EnumMeta<'a, S> {
     #[doc(hidden)]
     pub name: Cow<'a, str>,
@@ -102,7 +104,7 @@ pub struct EnumMeta<'a, S> {
 }
 
 /// Interface type metadata
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub struct InterfaceMeta<'a, S> {
     #[doc(hidden)]
     pub name: Cow<'a, str>,
@@ -115,7 +117,7 @@ pub struct InterfaceMeta<'a, S> {
 }
 
 /// Union type metadata
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub struct UnionMeta<'a> {
     #[doc(hidden)]
     pub name: Cow<'a, str>,
@@ -126,6 +128,7 @@ pub struct UnionMeta<'a> {
 }
 
 /// Input object metadata
+#[derive(Clone)]
 pub struct InputObjectMeta<'a, S> {
     #[doc(hidden)]
     pub name: Cow<'a, str>,
@@ -140,14 +143,14 @@ pub struct InputObjectMeta<'a, S> {
 ///
 /// After a type's `meta` method has been called but before it has returned, a placeholder type
 /// is inserted into a registry to indicate existence.
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub struct PlaceholderMeta<'a> {
     #[doc(hidden)]
     pub of_type: Type<'a>,
 }
 
 /// Generic type metadata
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub enum MetaType<'a, S = DefaultScalarValue> {
     #[doc(hidden)]
     Scalar(ScalarMeta<'a, S>),

juniper/src/schema/model.rs

@@ -20,7 +20,7 @@ use crate::schema::translate::{graphql_parser::GraphQLParserTranslator, SchemaTr
 ///
 /// This brings the mutation, subscription and query types together,
 /// and provides the predefined metadata fields.
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub struct RootNode<
     'a,
     QueryT: GraphQLType<S>,
@@ -47,7 +47,7 @@ pub struct RootNode<
 }
 
 /// Metadata for a schema
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub struct SchemaType<'a, S> {
     pub(crate) description: Option<Cow<'a, str>>,
     pub(crate) types: FnvHashMap<Name, MetaType<'a, S>>,
@@ -66,7 +66,7 @@ pub enum TypeType<'a, S: 'a> {
     List(Box<TypeType<'a, S>>, Option<usize>),
 }
 
-#[derive(Debug)]
+#[derive(Clone, Debug)]
 pub struct DirectiveType<'a, S> {
     pub name: String,
     pub description: Option<String>,

juniper/src/tests/fixtures/starwars/schema.rs

@@ -4,6 +4,7 @@ use std::{collections::HashMap, pin::Pin};
 
 use crate::{graphql_interface, graphql_object, graphql_subscription, Context, GraphQLEnum};
 
+#[derive(Clone, Copy, Debug)]
 pub struct Query;
 
 #[graphql_object(context = Database)]
@@ -33,6 +34,7 @@ impl Query {
     }
 }
 
+#[derive(Clone, Copy, Debug)]
 pub struct Subscription;
 
 type HumanStream = Pin<Box<dyn futures::Stream<Item = Human> + Send>>;

juniper/src/types/scalars.rs

@@ -346,6 +346,14 @@ mod impl_float_scalar {
 #[derive(Debug)]
 pub struct EmptyMutation<T: ?Sized = ()>(PhantomData<JoinHandle<Box<T>>>);
 
+impl<T> Clone for EmptyMutation<T> {
+    fn clone(&self) -> Self {
+        Self(PhantomData)
+    }
+}
+
+impl<T> Copy for EmptyMutation<T> {}
+
 // `EmptyMutation` doesn't use `T`, so should be `Send` and `Sync` even when `T` is not.
 crate::sa::assert_impl_all!(EmptyMutation<Rc<String>>: Send, Sync);
 
@@ -405,8 +413,17 @@ impl<T> Default for EmptyMutation<T> {
 ///
 /// If you instantiate `RootNode` with this as the subscription,
 /// no subscriptions will be generated for the schema.
+#[derive(Debug)]
 pub struct EmptySubscription<T: ?Sized = ()>(PhantomData<JoinHandle<Box<T>>>);
 
+impl<T> Clone for EmptySubscription<T> {
+    fn clone(&self) -> Self {
+        Self(PhantomData)
+    }
+}
+
+impl<T> Copy for EmptySubscription<T> {}
+
 // `EmptySubscription` doesn't use `T`, so should be `Send` and `Sync` even when `T` is not.
 crate::sa::assert_impl_all!(EmptySubscription<Rc<String>>: Send, Sync);
 

juniper_actix/src/lib.rs

@@ -416,7 +416,7 @@ pub mod subscriptions {
     impl fmt::Display for Error {
         fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
             match self {
-                Self::Serde(e) => write!(f, "serde error: {e}"),
+                Self::Serde(e) => write!(f, "{e}"),
                 Self::UnexpectedClientMessage => {
                     write!(f, "unexpected message received from client")
                 }

juniper_axum/CHANGELOG.md

@@ -0,0 +1,10 @@
+`juniper_axum` changelog
+========================
+
+All user visible changes to `juniper_axum` crate will be documented in this file. This project uses [Semantic Versioning 2.0.0].
+
+
+
+
+[`juniper` crate]: https://docs.rs/juniper
+[Semantic Versioning 2.0.0]: https://semver.org

juniper_axum/Cargo.toml

@@ -0,0 +1,32 @@
+[package]
+name = "juniper_axum"
+version = "0.1.0"
+edition = "2021"
+rust-version = "1.62"
+description = "`juniper` GraphQL integration with `axum`."
+license = "BSD-2-Clause"
+authors = ["Benno Tielen <[email protected]>"]
+documentation = "https://docs.rs/juniper_axum"
+homepage = "https://github.com/graphql-rust/juniper/tree/master/juniper_axum"
+repository = "https://github.com/graphql-rust/juniper"
+readme = "README.md"
+categories = ["asynchronous", "web-programming", "web-programming::http-server"]
+keywords = ["graphql", "juniper", "axum", "websocket"]
+exclude = ["/release.toml"]
+
+[dependencies]
+axum = { version = "0.5.11", features = ["ws"] }
+juniper = { path = "../juniper" }
+serde = "1.0"
+serde_json = "1.0"
+juniper_graphql_ws = { path = "../juniper_graphql_ws" }
+futures = "0.3"
+
+[dev-dependencies]
+tokio = { version = "1.20", features = ["full"] }
+tokio-tungstenite = "0.17.2"
+tokio-stream = "0.1.9"
+tower = "0.4.13"
+hyper = "0.14.20"
+juniper = { path = "../juniper", features = ["expose-test-schema"] }
+anyhow = "1.0"

juniper_axum/LICENCE

@@ -0,0 +1,25 @@
+BSD 2-Clause License
+
+Copyright (c) 2022, Benno Tielen
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+  list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+  this list of conditions and the following disclaimer in the documentation
+  and/or other materials provided with the distribution.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.