Add graphql schema definitions

Author: rolandszoke

scripts/createTestData.js

@@ -0,0 +1,11 @@
+#!/usr/bin/env node
+/* eslint-disable no-console */
+
+const db = require('../src/db');
+
+Promise.all(db.createTables()).then(() => {
+  Promise.all(db.createTestData()).then(() => {
+    console.log('Test data created.');
+    process.exit(0);
+  });
+});

scripts/dropTables.js

@@ -0,0 +1,9 @@
+#!/usr/bin/env node
+/* eslint-disable no-console */
+
+const db = require('../src/db');
+
+Promise.all(db.dropTables()).then(() => {
+  console.log('Tables dropped.');
+  process.exit(0);
+});

src/db.js

@@ -44,7 +44,7 @@ const createTables = () => {
     )`,
   ];
 
-  createTableQueries.forEach((query) => pool.query(query));
+  return createTableQueries.map((query) => pool.query(query));
 };
 
 const dropTables = () => {
@@ -54,11 +54,44 @@ const dropTables = () => {
     'DROP TABLE IF EXISTS comments',
   ];
 
-  dropTableQueries.forEach((query) => pool.query(query));
+  return dropTableQueries.map((query) => pool.query(query));
+};
+
+const createTestData = () => {
+  // password for test user: password
+  const testDataQueries = [
+    `INSERT INTO users(id, name, username, email, password_digest)
+    VALUES('8aaf37cf-94c9-4c6a-b566-0265ce34b58c', 'Tyler', 'tyler1337', '[email protected]', '$2b$10$yv9DxXTpvBmBYKu8rXoSIONn3BZB5/jQRDPMKt/YUAq8eTYoXGwKu')
+    RETURNING *
+    `,
+    `INSERT INTO users(id, name, username, email, password_digest)
+    VALUES('8aaf37cf-94c9-4c6a-b566-0265ce34b68c', 'Marla', 'marlaSinger', '[email protected]', '$2b$10$yv9DxXTpvBmBYKu8rXoSIONn3BZB5/jQRDPMKt/YUAq8eTYoXGwKu')
+    RETURNING *
+    `,
+    `INSERT INTO posts(id, title, description, content, author, timestamp)
+    VALUES('8aaf37cf-94c9-4c6a-b566-0265ce34b78c', 'Test Post', 'This is my test post', 'Test post Content', '[email protected]', '2019-09-15T07:30:57.392Z')
+    RETURNING *
+    `,
+    `INSERT INTO posts(id, title, description, content, author, timestamp)
+    VALUES('8aaf37cf-94c9-4c6a-b566-0265ce34b58a', 'Test Post 2', 'This is my test post', 'Test post Content', '[email protected]', '2019-09-18T07:30:57.392Z')
+    RETURNING *
+    `,
+    `INSERT INTO comments(id, content, author, post, timestamp)
+    VALUES('8aaf37cf-94c9-4c6a-b566-0265ce34b88c', 'Test Comment', '[email protected]', '8aaf37cf-94c9-4c6a-b566-0265ce34b78c', '2019-09-15T08:30:57.392Z')
+    RETURNING *
+    `,
+    `INSERT INTO comments(id, content, author, post, timestamp)
+    VALUES('8aaf37cf-94c9-4c6a-b566-0265ce34b98c', 'Test Comment 2', '[email protected]', '8aaf37cf-94c9-4c6a-b566-0265ce34b78c', '2019-09-16T07:30:57.392Z')
+    RETURNING *
+    `,
+  ];
+
+  return testDataQueries.map((query) => pool.query(query));
 };
 
 module.exports = {
   query: (text, params) => pool.query(text, params),
   createTables,
   dropTables,
+  createTestData,
 };

src/gqlSchema.js

@@ -0,0 +1,85 @@
+
+const { buildSchema } = require('graphql');
+
+const { getHello, resolveQuery } = require('./fetcher');
+
+const schema = buildSchema(`
+  enum OrderDirection {
+    asc
+    desc
+  }
+  type PageInfo {
+    hasNextPage: Boolean
+    hasPreviousPage: Boolean
+    totalRecords: Int
+  }
+
+  enum UserArgField {
+    id
+    name
+    username
+    email
+  }
+  input UserFieldOrder {
+    field: UserArgField
+    direction: OrderDirection
+  }
+  type User {
+    id: ID
+    name: String
+    username: String
+    email: String
+  }
+  type UserEdge {
+    node: User
+  }
+  type UserConnection {
+    pageInfo: PageInfo
+    edges: [UserEdge]
+  }
+
+  enum PostArgField {
+    id
+    title
+    description
+    content
+    author
+    timestamp
+  }
+  input PostFieldOrder {
+    field: PostArgField
+    direction: OrderDirection
+  }
+  type Post {
+    id: ID
+    title: String
+    description: String
+    content: String
+    author: String
+    timestamp: String
+  }
+  type PostEdge {
+    node: Post
+  }
+  type PostConnection {
+    pageInfo: PageInfo
+    edges: [PostEdge]
+  }
+
+  type Query {
+    hello: String
+    users(limit: Int, offset: Int, order: UserFieldOrder): UserConnection
+    posts(limit: Int, offset: Int, order: PostFieldOrder): PostConnection
+  }
+`);
+
+const rootValue = {
+  hello: () => getHello(),
+  users: (args) => resolveQuery({ table: 'users', args }),
+  posts: (args) => resolveQuery({ table: 'posts', args }),
+};
+
+module.exports = {
+  schema,
+  rootValue,
+};

src/schema/comment.js

@@ -14,8 +14,8 @@ const {
   Node, PageInfo, FilterOperation, OrderDirection, Datetime,
 } = require('./common');
 
-const CommentField = new GraphQLEnumType({
-  name: 'CommentField',
+const CommentArgField = new GraphQLEnumType({
+  name: 'CommentArgField',
   values: {
     id: { value: 'id' },
     content: { value: 'content' },
@@ -29,15 +29,15 @@ const CommentFieldFilter = new GraphQLInputObjectType({
   name: 'CommentFieldFilter',
   fields: {
     value: { type: GraphQLString },
-    field: { type: CommentField },
+    field: { type: CommentArgField },
     operation: { type: FilterOperation },
   },
 });
 
 const CommentFieldOrder = new GraphQLInputObjectType({
   name: 'CommentFieldOrder',
   fields: {
-    field: { type: CommentField },
+    field: { type: CommentArgField },
     direction: { type: OrderDirection },
   },
 });
@@ -115,7 +115,7 @@ const CommentMutations = new GraphQLObjectType({
 });
 
 module.exports = {
-  CommentField,
+  CommentArgField,
   CommentFieldFilter,
   CommentFieldOrder,
   Comment,

src/schema/post.js

@@ -16,8 +16,8 @@ const {
 } = require('./common');
 const { CommentConnection, CommentFieldFilter, CommentFieldOrder } = require('./comment');
 
-const PostField = new GraphQLEnumType({
-  name: 'PostField',
+const PostArgField = new GraphQLEnumType({
+  name: 'PostArgField',
   values: {
     id: { value: 'id' },
     content: { value: 'content' },
@@ -32,15 +32,15 @@ const PostFieldFilter = new GraphQLInputObjectType({
   name: 'PostFieldFilter',
   fields: {
     value: { type: GraphQLString },
-    field: { type: PostField },
+    field: { type: PostArgField },
     operation: { type: FilterOperation },
   },
 });
 
 const PostFieldOrder = new GraphQLInputObjectType({
   name: 'PostFieldOrder',
   fields: {
-    field: { type: PostField },
+    field: { type: PostArgField },
     direction: { type: OrderDirection },
   },
 });
@@ -129,7 +129,7 @@ const PostMutations = new GraphQLObjectType({
 });
 
 module.exports = {
-  PostField,
+  PostArgField,
   PostFieldFilter,
   PostFieldOrder,
   Post,

src/schema/user.js

@@ -17,8 +17,8 @@ const {
 const { PostConnection, PostFieldFilter, PostFieldOrder } = require('./post');
 const { CommentConnection, CommentFieldFilter, CommentFieldOrder } = require('./comment');
 
-const UserField = new GraphQLEnumType({
-  name: 'UserField',
+const UserArgField = new GraphQLEnumType({
+  name: 'UserArgField',
   values: {
     id: { value: 'id' },
     name: { value: 'name' },
@@ -31,15 +31,15 @@ const UserFieldFilter = new GraphQLInputObjectType({
   name: 'UserFieldFilter',
   fields: {
     value: { type: GraphQLString },
-    field: { type: UserField },
+    field: { type: UserArgField },
     operation: { type: FilterOperation },
   },
 });
 
 const UserFieldOrder = new GraphQLInputObjectType({
   name: 'UserFieldOrder',
   fields: {
-    field: { type: UserField },
+    field: { type: UserArgField },
     direction: { type: OrderDirection },
   },
 });
@@ -133,7 +133,7 @@ const UserMutations = new GraphQLObjectType({
 });
 
 module.exports = {
-  UserField,
+  UserArgField,
   UserFieldFilter,
   UserFieldOrder,
   User,

src/server.js

@@ -4,9 +4,14 @@ const helmet = require('helmet');
 const cors = require('cors');
 
 const db = require('./db');
+
+// Graphql Types - cut rootValue from graphqlHTTP when used
 const schema = require('./schema');
 const config = require('./config');
 
+// Raw Graphql schema language - add rootValue from graphqlHTTP when used
+// const { schema, rootValue } = require('./gqlSchema');
+
 const app = express();
 
 db.createTables();
@@ -21,6 +26,7 @@ app.use(cors({
 
 app.use('/graphql', graphqlHTTP(async () => ({
   schema,
+  // rootValue,
   graphiql: true,
   customFormatErrorFn: (error) => {
     // eslint-disable-next-line no-console