Workshop graphql with nodejs

Prerequisites

Let's get started

Open the terminal and create a new folder for the project: mkdir workshop-graphql
Navigate to the root of the folder: cd workshop-graphql
Create the package.json file: npm init
Create a folder called api: mkdir api
Create a file called server.js: touch api/server.js

Create Server

Install express npm i -S express
Install nodemon as dev dependency npm i -D nodemon
On the package.json we are going to add the following script "start": "nodemon api/server.js"
This will be our initial server.js

'use strict'
 
 const express = require('express');

 const app = express();
 
 const port = 3000;
 
 app.listen(port, () => console.log(`Server is now running on http://localhost:${port}`));

Create the Shows Entity

Install next dependencies npm i -S apollo-server-express body-parser graphql graphql-tools lodash.merge node-fetch
Create a folder called graphql: mkdir api/graphql
Create a folder called shows-tv: mkdir api/graphql/shows-tv

On the folder shows-tv we are going to create the following files:

Create a file called schema.js and added the next code

  'use strict'
  
  const schema = [`
    
    # show data
    type Show {
      id: Int,
      name: String,
      type: String,
      language: String
      genres: [String],
      status: String,
      runtime: Int,
      premiered: String,
      akas: [Aka]
    }
    
    type Aka {
      name: String,
      country: Country
    }
    
    type Country {
      name: String,
      code: String,
      timezone: String
    }
    
    type Query {
      shows: [Show]
      showById(id: ID!): Show
    }
  `];
  
  module.exports = schema;

Create a file called resolver.js and added the next code

  'use strict'
  
  const resolver = {
    Query: {
      shows(root, args, {showConnector}) {
        let results = [];
  
        try {
          results = showConnector.getShows();
        } catch (err) {
          throw new Error('Error: find all shows')
        }
  
        return results;
      },
      showById(root, args, {showConnector}) {
        let results = {};
  
        try {
          results = showConnector.getShowById(args.id);
        } catch (err) {
          throw new Error('Error: find show by id')
        }
  
        return results;
      }
    },
    Show: {
      akas({id}, args, {showConnector}) {
        let results = [];
        try {
          results = showConnector.getShowsAkas(id);
        } catch (err) {
          throw new Error('Error: find all akas')
        }
  
        return results;
      }
    }
  };
  
  
  module.exports = resolver;

Create a file called connector.js and added the next code

  'use strict'
  
  const fetch = require('node-fetch');
  
  
  class ShowConnector {
    constructor(url = '') {
      if (!url) throw new Error()('The url is not provider');
      this.API_ROOT = url;
    }
  
    async fetch(url) {
      const URL = `${this.API_ROOT}${url}`;
      const res = await fetch(URL).then(r => r.json());
  
      if (res.errors) throw Error(res.message);
      return res;
    }
  
    getShows() {
      return this.fetch('/shows?page=1');
    }
  
    getShowById(id) {
      return this.fetch(`/shows/${id}`);
    }
  
    getShowsAkas(id) {
      return this.fetch(`/shows/${id}/akas`);
    }
  }
  
  module.exports = ShowConnector;

Configure the global schema

On the folder graphql we are going to create a file called schema.js and added next code:

  'use strict'
  
  const merge = require('lodash.merge');
  const {makeExecutableSchema} = require('graphql-tools');
  
  const showSchema = require('./shows-tv/schema');
  const showResolver = require('./shows-tv/resolver');
  
  
  const typeDefs = [
    ...showSchema
  ];
  
  
  const resolvers = merge(
    showResolver
  );
  
  
  const executableSchema = makeExecutableSchema({
    typeDefs,
    resolvers
  });
  
  module.exports = executableSchema;

Configure the graphql server

On the folder api we are going to create a file called config.js and added next code:

  'use strict'
  
  module.exports = {
    db: 'mongodb://localhost:27017/workshop-graphql',
    tvMazeUrl: 'http://api.tvmaze.com'
  };

On the file server.js we are going to added next code:

import the next files:

  
const bodyParse = require('body-parser');
const {graphqlExpress, graphiqlExpress} = require('apollo-server-express');

const config = require('./config');
const schema = require('./graphql/schema');
const ShowConnector = require('./graphql/shows-tv/connector');

Configure graphql and graphiql:

  app.use(bodyParse.json());
  
  app.use('/graphql', graphqlExpress(req => {
    return {
      schema,
      context: {
        showConnector: new ShowConnector(config.tvMazeUrl)
      }
    }
  }));
  
  app.get('/graphiql', graphiqlExpress({
    endpointURL: '/graphql'
  }));

The server.js file should be seen as follows:

  'use strict'
  
  const express = require('express');
  const bodyParse = require('body-parser');
  const {graphqlExpress, graphiqlExpress} = require('apollo-server-express');
  
  const config = require('./config');
  const schema = require('./graphql/schema');
  const ShowConnector = require('./graphql/shows-tv/connector');
  
  const app = express();
  const port = 3000;
  
  app.use(bodyParse.json());
  
  app.use('/graphql', graphqlExpress(req => {
    return {
      schema,
      context: {
        showConnector: new ShowConnector(config.tvMazeUrl)
      }
    }
  }));
  
  app.get('/graphiql', graphiqlExpress({
    endpointURL: '/graphql'
  }));
  
  app.listen(port, () => console.log(`Server is now running on http://localhost:${port}`));

Create the Post Entity

Install next dependencies: npm i -S mongoose bluebird
Create a folder called posts: mkdir api/graphql/posts

On the folder posts we are going to create the following files:

Create a file called schema.js and added the next code

  'use strict'

  const schema = [`
    
    # data to create post
    input PostInput {
      author: String!, 
      email: String, 
      title: String!, 
      body: String!
    }
    
    # data to update post
    input PostEditInput {
      author: String, 
      email: String, 
      title: String, 
      body: String
    }
    
    # data post
    type Post {
      id: ID, 
      author: String, 
      title: String, 
      body: String,
      createdAt: String
    }
    
    extend type Query {
      # find all post
      posts: [Post]
      # find post by id
      postById(id: ID!): Post
    }
    
    type Mutation {
      # create post
      postAdd(data: PostInput): Post
      # update post
      postEdit(id: ID!, data: PostEditInput): Post
      # delete post
      postDelete(id: ID!): Post
    }
  `];
  
  module.exports = schema;

Create a file called resolver.js and added the next code

  'use strict'

  const resolver = {
    Query: {
      async posts(root, args, {postStorage}) {
        let results = [];
        try {
          results = await postStorage.find();
        } catch (err) {
          throw new Error('Error: find all posts');
        }
        return results;
      },
      async postById(root, args, {postStorage}) {
        let result = {};
        try {
          result = await postStorage.findById(args.id);
        } catch (err) {
          throw new Error('Error: find post by id');
        }
        return result;
      }
    },
    Mutation: {
      postAdd(root, args, {postStorage}) {
        let result = {};
        try {
          result = postStorage.save({...args.data});
        } catch (err) {
          throw new Error('Error: save post');
        }
        return result;
      },
      async postEdit(root, args, {postStorage}) {
        let result = {};
        try {
          result = await postStorage.update(args.id, {...args.data});
        } catch (err) {
          throw new Error('Error: update post');
        }
        return result;
      },
      async postDelete(root, args, {postStorage}) {
        let result = {};
        try {
          result = await postStorage.delete(args.id);
        } catch (err) {
          throw new Error('Error: delete post');
        }
        return result;
      }
    }
  };
  
  module.exports = resolver;

Create a file called model.js and added the next code

  'use strict'
  
  const mongoose = require('mongoose');
  
  const schema = new mongoose.Schema({
    title: {
      type: String,
      required: 'The title field is required'
    },
    body: {
      type: String,
      required: 'The body field is required'
    },
    author:{
      type: String,
      required: 'The author field is required'
    },
    email:{
      type: String
    }
  }, {timestamps: true});
  
  if (!schema.options.toJSON) schema.options.toJSON = {};
  
  /**
   * Add a tranforma method to change _id by id
   * whent toJSON is used.
   */
  schema.options.toJSON.transform = (doc, ret) => {
    // remove the _id of every document before returning the result
    ret.id = ret._id;
    delete ret._id;
    return ret;
  };
  
  
  module.exports =  mongoose.model('Post', schema);

Create a file called storage.js and added the next code

  'use strict'
  
  require('./model');
  
  class PostStorage {
    constructor(conn = null) {
      if (!conn) throw new Error('connection not provider');
  
      this.Model = conn.model('Post');
    }
  
    async save(data) {
      let result = {};
      try {
        result = await new this.Model(data).save();
      } catch (err) {
        throw new Error(err.messages);
      }
      return result;
    }
  
    async update(id, data) {
      let result = {};
      try {
        result = await this.Model.findByIdAndUpdate(id, {$set: data}, {new: true});
        if (!result) {
          result = {failed: true, message: 'Post not found'}
        }
      } catch (err) {
        throw new Error(err.messages);
      }
      return result;
    }
  
    async delete(id) {
      let result = {};
      try {
        result = await this.Model.findByIdAndRemove(id);
        if (!result) {
          result = {failed: true, message: 'Post not found'}
        }
      } catch (err) {
        throw new Error(err.messages);
      }
      return result;
    }
  
    async find(query = {}) {
      let results = [];
      try {
        results = await this.Model.find(query);
      } catch (err) {
        throw new Error(err.messages);
      }
      return results;
    }
  
    async findById(id) {
      let result = {};
      try {
        result = await this.Model.findById(id);
        if (!result) {
          result = {failed: true, message: 'Post not found'}
        }
      } catch (err) {
        throw new Error(err.messages);
      }
      return result;
    }
  }
  
  module.exports = PostStorage;

Configure the global schema

On the file schema.js we are going to added next code:

  
  const postSchema = require('./posts/schema');
  const postResolver = require('./posts/resolver');
  
  
  const typeDefs = [
    ...showSchema,
    ...postSchema
  ];
  
  
  const resolvers = merge(
    showResolver,
    postResolver
  );

Configure the post storage

On the file server.js we are going to added next code:

  
    const mongoose = require('mongoose');
    const Promise = require('bluebird');
    
    const PostStorage = require('./graphql/posts/storage');
    
    mongoose.Promise = Promise;
    const conn = mongoose.createConnection(config.db);
    
    app.use('/graphql', graphqlExpress(req => {
      return {
        schema,
        context: {
          showConnector: new ShowConnector(config.tvMazeUrl),
          postStorage: new PostStorage(conn)
        }
      }
    }));

The server.js file should be seen as follows:

  'use strict'
  
  const express = require('express');
  const mongoose = require('mongoose');
  const Promise = require('bluebird');
  const bodyParse = require('body-parser');
  const {graphqlExpress, graphiqlExpress} = require('apollo-server-express');
  
  const config = require('./config');
  const schema = require('./graphql/schema');
  const ShowConnector = require('./graphql/shows-tv/connector');
  const PostStorage = require('./graphql/posts/storage');
  
  const app = express();
  const port = 3000;
  
  mongoose.Promise = Promise;
  
  const conn = mongoose.createConnection(config.db);
  
  app.use(bodyParse.json());
  
  app.use('/graphql', graphqlExpress(req => {
    return {
      schema,
      context: {
        showConnector: new ShowConnector(config.tvMazeUrl),
        postStorage: new PostStorage(conn)
      }
    }
  }));
  
  app.get('/graphiql', graphiqlExpress({
    endpointURL: '/graphql'
  }));
  
  app.listen(port, () => console.log(`server running in the port ${port}`));

Create the Comment Entity

Create a folder called posts: mkdir api/graphql/comments

On the folder comments we are going to create the following files:

Create a file called schema.js and added the next code

  'use strict'

  const schema = [`
    
    # data to create comment
      input CommentInput {
        postId: ID!,
        name: String!,
        email: String,
        body: String!
      }
     
      type Comment {
        id: ID,
        post: Post,
        name: String,
        email: String,
        body: String
      }
    
      extend type Query { 
        comments: [Comment] 
      }
    
      type Subscription {
        commentAdd(data: CommentInput): Comment
      }
  `];
  
  module.exports = schema;

Create a file called resolver.js and added the next code

  'use strict'

  const resolver = {
    Query: {
      async comments(root, args, {commentStorage}) {
        let results = [];
        try {
          results = await commentStorage.find();
        } catch (err) {
          throw new Error('Error: find all comment');
        }
        return results;
      }
    },
    Comment: {
      async post({postId}, args, {postStorage}) {
        let result = {};
        if (!postId) return {};
        try {
          result = await postStorage.findById(postId);
        } catch (err) {
          throw new Error('Error: find post');
        }
        return result;
      }
    },
    Subscription: {
      async commentAdd(root, args, {commentStorage}) {
        let result = {};
        try {
          result = await commentStorage.save({...args.data});
        } catch (err) {
          throw new Error('Error: save comment');
        }
        return result;
      }
    }
  };
  
  module.exports = resolver;

Create a file called model.js and added the next code

  'use strict'
  
  const mongoose = require('mongoose');
  
  const schema = new mongoose.Schema({
    name: {
      type: String,
      required: 'The name field is required'
    },
    body: {
      type: String,
      required: 'The body field is required'
    },
    email: {
      type: String
    },
    postId:{
      type: mongoose.Schema.Types.ObjectId,
      required: 'The postId field is required'
    }
  }, {timestamps: true});
  
  if (!schema.options.toJSON) schema.options.toJSON = {};
  
  /**
   * Add a tranforma method to change _id by id
   * whent toJSON is used.
   */
  schema.options.toJSON.transform = (doc, ret) => {
    // remove the _id of every document before returning the result
    ret.id = ret._id;
    delete ret._id;
    return ret;
  };
  
  
  module.exports =  mongoose.model('Comment', schema);

Create a file called storage.js and added the next code

  'use strict'
  
  require('./model');
  
  class CommentStorage {
    constructor(conn = null) {
      if (!conn) throw new Error('connection not provider');
  
      this.Model = conn.model('Comment');
    }
  
    async save(data) {
      let result = {};
      try {
        result = await new this.Model(data).save();
      } catch (err) {
        console.log('err', err)
        throw new Error(err.messages);
      }
      return result;
    }
  
    async update(id, data) {
      let result = {};
      try {
        result = await this.Model.findByIdAndUpdate(id, {$set: data}, {new: true});
        if (!result) {
          result = {failed: true, message: 'Comment not found'}
        }
      } catch (err) {
        throw new Error(err.messages);
      }
      return result;
    }
  
    async delete(id) {
      let result = {};
      try {
        result = await this.Model.findByIdAndRemove(id);
        if (!result) {
          result = {failed: true, message: 'Comment not found'}
        }
      } catch (err) {
        throw new Error(err.messages);
      }
      return result;
    }
  
    async find(query) {
      let results = [];
      try {
        results = await this.Model.find(query);
      } catch (err) {
        throw new Error(err.messages);
      }
      return results;
    }
  
    async findById(id) {
      let result = {};
      try {
        result = await this.Model.findById(id);
        if (!result) {
          result = {failed: true, message: 'Comment not found'}
        }
      } catch (err) {
        throw new Error(err.messages);
      }
      return result;
    }
  }
  
  module.exports = CommentStorage;

Configure the global schema

On the file schema.js we are going to added next code:

  
  const commentSchema = require('./comments/schema');
  const commentResolver = require('./comments/resolver');
  
  
  const typeDefs = [
    ...showSchema,
    ...postSchema,
    ...commentSchema
  ];
  
  
  const resolvers = merge(
    showResolver,
    postResolver,
    commentResolver
  );

Configure the Comment storage

On the file server.js we are going to added next code:

    
    const CommentStorage = require('./graphql/comments/storage');
    
    app.use('/graphql', graphqlExpress(req => {
      return {
        schema,
        context: {
          showConnector: new ShowConnector(config.tvMazeUrl),
          postStorage: new PostStorage(conn),
          commentStorage: new CommentStorage(conn)
        }
      }
    }));

The server.js file should be seen as follows:

  'use strict'
  
  const express = require('express');
  const mongoose = require('mongoose');
  const Promise = require('bluebird');
  const bodyParse = require('body-parser');
  const {graphqlExpress, graphiqlExpress} = require('apollo-server-express');
  
  const config = require('./config');
  const schema = require('./graphql/schema');
  const ShowConnector = require('./graphql/shows-tv/connector');
  const PostStorage = require('./graphql/posts/storage');
  const CommentStorage = require('./graphql/comments/storage');
  
  const app = express();
  const port = 3000;
  
  mongoose.Promise = Promise;
  
  const conn = mongoose.createConnection(config.db);
  
  app.use(bodyParse.json());
  
  app.use('/graphql', graphqlExpress(req => {
    return {
      schema,
      context: {
        showConnector: new ShowConnector(config.tvMazeUrl),
        postStorage: new PostStorage(conn),
        commentStorage: new CommentStorage(conn)
      }
    }
  }));
  
  app.get('/graphiql', graphiqlExpress({
    endpointURL: '/graphql'
  }));
  
  app.listen(port, () => console.log(`server running in the port ${port}`));

Name		Name	Last commit message	Last commit date
Latest commit History 38 Commits
api		api
.gitignore		.gitignore
README.md		README.md
package-lock.json		package-lock.json
package.json		package.json

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

api

api

.gitignore

.gitignore

README.md

README.md

package-lock.json

package-lock.json

package.json

package.json

Repository files navigation

Workshop graphql with nodejs

Prerequisites

Let's get started

Create Server

Create the Shows Entity

Configure the global schema

Configure the graphql server

Create the Post Entity

Configure the global schema

Configure the post storage

Create the Comment Entity

Configure the global schema

Configure the Comment storage

About

Releases

Packages

Languages

IvanVilla1585/workshop-graphql-medellinjs

Folders and files

Latest commit

History

Repository files navigation

Workshop graphql with nodejs

Prerequisites

Let's get started

Create Server

Create the Shows Entity

Configure the global schema

Configure the graphql server

Create the Post Entity

Configure the global schema

Configure the post storage

Create the Comment Entity

Configure the global schema

Configure the Comment storage

About

Resources

Stars

Watchers

Forks

Languages