Add missing files

Author: weiznich

wundergraph_cli/src/print_schema/snapshots/tests__infer_schema.snap

@@ -0,0 +1,147 @@
+---
+source: wundergraph_cli/src/print_schema/mod.rs
+expression: "&s"
+---
+use wundergraph::query_builder::types::{HasMany, HasOne};
+use wundergraph::scalar::WundergraphScalarValue;
+use wundergraph::WundergraphEntity;
+
+table! {
+    infer_test.comments (id) {
+        id -> Int4,
+        post -> Nullable<Int4>,
+        commenter -> Nullable<Int4>,
+        content -> Text,
+    }
+}
+
+table! {
+    infer_test.posts (id) {
+        id -> Int4,
+        author -> Nullable<Int4>,
+        title -> Text,
+        content -> Nullable<Text>,
+    }
+}
+
+table! {
+    infer_test.users (id) {
+        id -> Int4,
+        name -> Text,
+    }
+}
+
+allow_tables_to_appear_in_same_query!(
+    comments,
+    posts,
+    users,
+);
+
+
+#[derive(Clone, Debug, Identifiable, WundergraphEntity)]
+#[table_name = "comments"]
+#[primary_key(id)]
+pub struct Comment {
+    id: i32,
+    post: Option<HasOne<i32, Post>>,
+    commenter: Option<HasOne<i32, User>>,
+    content: String,
+}
+
+#[derive(Clone, Debug, Identifiable, WundergraphEntity)]
+#[table_name = "posts"]
+#[primary_key(id)]
+pub struct Post {
+    id: i32,
+    author: Option<HasOne<i32, User>>,
+    title: String,
+    content: Option<String>,
+    comments: HasMany<Comment, comments::post>,
+}
+
+#[derive(Clone, Debug, Identifiable, WundergraphEntity)]
+#[table_name = "users"]
+#[primary_key(id)]
+pub struct User {
+    id: i32,
+    name: String,
+    comments: HasMany<Comment, comments::commenter>,
+    posts: HasMany<Post, posts::author>,
+}
+
+
+
+wundergraph::query_object!{
+    Query {
+        Comment,
+        Post,
+        User,
+    }
+}
+
+
+#[derive(Insertable, juniper::GraphQLInputObject, Clone, Debug)]
+#[graphql(scalar = "WundergraphScalarValue")]
+#[table_name = "comments"]
+pub struct NewComment {
+    post: Option<i32>,
+    commenter: Option<i32>,
+    content: String,
+}
+
+#[derive(AsChangeset, Identifiable, juniper::GraphQLInputObject, Clone, Debug)]
+#[graphql(scalar = "WundergraphScalarValue")]
+#[table_name = "comments"]
+#[primary_key(id)]
+pub struct CommentChangeset {
+    id: i32,
+    post: Option<i32>,
+    commenter: Option<i32>,
+    content: String,
+}
+
+#[derive(Insertable, juniper::GraphQLInputObject, Clone, Debug)]
+#[graphql(scalar = "WundergraphScalarValue")]
+#[table_name = "posts"]
+pub struct NewPost {
+    author: Option<i32>,
+    title: String,
+    content: Option<String>,
+}
+
+#[derive(AsChangeset, Identifiable, juniper::GraphQLInputObject, Clone, Debug)]
+#[graphql(scalar = "WundergraphScalarValue")]
+#[table_name = "posts"]
+#[primary_key(id)]
+pub struct PostChangeset {
+    id: i32,
+    author: Option<i32>,
+    title: String,
+    content: Option<String>,
+}
+
+#[derive(Insertable, juniper::GraphQLInputObject, Clone, Debug)]
+#[graphql(scalar = "WundergraphScalarValue")]
+#[table_name = "users"]
+pub struct NewUser {
+    name: String,
+}
+
+#[derive(AsChangeset, Identifiable, juniper::GraphQLInputObject, Clone, Debug)]
+#[graphql(scalar = "WundergraphScalarValue")]
+#[table_name = "users"]
+#[primary_key(id)]
+pub struct UserChangeset {
+    id: i32,
+    name: String,
+}
+
+wundergraph::mutation_object!{
+    Mutation{
+        Comment(insert = NewComment, update = CommentChangeset, ),
+        Post(insert = NewPost, update = PostChangeset, ),
+        User(insert = NewUser, update = UserChangeset, ),
+    }
+}
+
+

wundergraph_cli/src/print_schema/snapshots/tests__round_trip-2.snap

@@ -0,0 +1,12 @@
+---
+source: wundergraph_cli/src/print_schema/mod.rs
+expression: "r.json::<serde_json::Value>().unwrap()"
+---
+{
+  "data": {
+    "CreateUser": {
+      "id": 1,
+      "name": "Max"
+    }
+  }
+}

wundergraph_cli/src/print_schema/snapshots/tests__round_trip-3.snap

@@ -0,0 +1,14 @@
+---
+source: wundergraph_cli/src/print_schema/mod.rs
+expression: "r.json::<serde_json::Value>().unwrap()"
+---
+{
+  "data": {
+    "Users": [
+      {
+        "id": 1,
+        "name": "Max"
+      }
+    ]
+  }
+}

wundergraph_cli/src/print_schema/snapshots/tests__round_trip.snap

@@ -0,0 +1,9 @@
+---
+source: wundergraph_cli/src/print_schema/mod.rs
+expression: "r.json::<serde_json::Value>().unwrap()"
+---
+{
+  "data": {
+    "Users": []
+  }
+}

wundergraph_cli/src/print_schema/template_main.rs

@@ -0,0 +1,111 @@
+#[macro_use] extern crate diesel;
+
+use actix_web::web::Data;
+use actix_web::web::Json;
+use actix_web::middleware;
+use actix_web::web;
+use actix_web::App;
+use actix_web::HttpResponse;
+use actix_web::HttpServer;
+use diesel::{conn};
+use diesel::r2d2::ConnectionManager;
+use diesel::r2d2::Pool;
+use diesel::r2d2::PooledConnection;
+use diesel::r2d2::CustomizeConnection;
+use diesel::Connection;
+use diesel::connection::SimpleConnection;
+use juniper::graphiql::graphiql_source;
+use juniper::http::GraphQLRequest;
+use serde::Deserialize;
+use serde::Serialize;
+use std::sync::Arc;
+use wundergraph::scalar::WundergraphScalarValue;
+
+pub mod api;
+
+pub type Schema<Connection> = juniper::RootNode<
+    'static,
+    self::api::Query<PooledConnection<ConnectionManager<Connection>>>,
+    self::api::Mutation<PooledConnection<ConnectionManager<Connection>>>,
+    WundergraphScalarValue,
+>;
+
+// actix integration stuff
+#[derive(Serialize, Deserialize, Debug)]
+pub struct GraphQLData(GraphQLRequest<WundergraphScalarValue>);
+
+#[derive(Clone)]
+struct AppState {{
+    schema: Arc<Schema<{conn}>>,
+    pool: Arc<Pool<ConnectionManager<{conn}>>>,
+}}
+
+fn graphiql() -> HttpResponse {{
+    let html = graphiql_source("/graphql");
+    HttpResponse::Ok()
+        .content_type("text/html; charset=utf-8")
+        .body(html)
+}}
+
+fn graphql(
+    Json(GraphQLData(data)): Json<GraphQLData>,
+    st: Data<AppState>,
+) -> Result<HttpResponse, failure::Error> {{
+    let ctx = st.get_ref().pool.get()?;
+    let res = data.execute(&st.get_ref().schema, &ctx);
+    Ok(HttpResponse::Ok()
+        .content_type("application/json")
+        .body(serde_json::to_string(&res)?))
+}}
+
+#[derive(Debug)]
+struct ConnectionHandler;
+
+impl<E> CustomizeConnection<{conn}, E> for ConnectionHandler {{
+    fn on_acquire(&self, conn: &mut {conn}) -> Result<(), E> {{
+        Ok(conn.begin_test_transaction().unwrap())
+    }}
+}}
+
+fn main() {{
+    let manager = ConnectionManager::<{conn}>::new("{db_url}");
+    let pool = Pool::builder()
+        .max_size(1)
+        .connection_customizer(Box::new(ConnectionHandler))
+        .build(manager)
+        .expect("Failed to init pool");
+    {{
+        let conn = pool.get().unwrap();
+        conn.batch_execute("{migrations}").unwrap();
+    }}
+
+    let query = self::api::Query::default();
+    let mutation = self::api::Mutation::default();
+    let schema = Schema::new(query, mutation);
+
+    let schema = Arc::new(schema);
+    let pool = Arc::new(pool);
+    let data = AppState {{ schema, pool }};
+
+    let url = "{listen_url}";
+
+    println!("Started http server: http://{{}}", url);
+
+    HttpServer::new(move || {{
+        App::new()
+            .data(data.clone())
+            .wrap(middleware::Logger::default())
+            .route("/graphql", web::get().to(graphql))
+            .route("/graphql", web::post().to(graphql))
+            .route("/graphiql", web::get().to(graphiql))
+            .default_service(web::route().to(|| {{
+                HttpResponse::Found()
+                    .header("location", "/graphiql")
+                    .finish()
+            }}))
+    }})
+    .bind(&url)
+    .expect("Failed to start server")
+    .run()
+    .unwrap();
+}}