Initial commit.

Author: jbroadice

.editorconfig

@@ -0,0 +1,20 @@
+# EditorConfig helps developers define and maintain consistent
+# coding styles between different editors and IDEs
+# editorconfig.org
+
+root = true
+
+[*]
+
+# Change these settings to your own preference
+indent_style = space
+indent_size = 2
+
+# We recommend you to keep these unchanged
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = true
+
+[*.md]
+trim_trailing_whitespace = false

.env.example

@@ -0,0 +1,4 @@
+DB_HOST=127.0.0.1
+DB_USER=user
+DB_PASSWORD=secret
+DB_DATABASE=mydatabase

.eslintrc

@@ -0,0 +1,31 @@
+{
+  "extends": "airbnb-base",
+  "globals": {
+    "describe": false,
+    "it": false,
+    "beforeAll": false,
+    "beforeEach": false,
+    "expect": false
+  },
+  "env": {
+    "node": true
+  },
+  "plugins": [
+    "import"
+  ],
+  "rules": {
+    "no-param-reassign": [0],
+    "radix": "off",
+    "no-continue": "off",
+    "no-use-before-define": "off",
+    "no-underscore-dangle": "off",
+    "class-methods-use-this": "off",
+    "max-len": ["error", 150, 2, {
+      "ignoreUrls": true,
+      "ignoreComments": false,
+      "ignoreRegExpLiterals": true,
+      "ignoreStrings": true,
+      "ignoreTemplateLiterals": true
+    }]
+  }
+}

.gitignore

@@ -0,0 +1,5 @@
+.env
+node_modules
+yarn-error.log
+public.key
+private.key

README.md

@@ -0,0 +1 @@
+A GraphQL (Apollo) Express server with JWT authentication, and using Objection.js ORM that automagically generates GQL schema types & resolvers.

knexfile.js

@@ -0,0 +1,24 @@
+require('dotenv').config();
+
+const {
+  DB_HOST,
+  DB_USER,
+  DB_PASSWORD,
+  DB_DATABASE,
+} = process.env;
+
+module.exports = {
+
+  development: {
+    client: 'mysql',
+    debug: true,
+    useNullAsDefault: true,
+    connection: {
+      host: DB_HOST,
+      user: DB_USER,
+      password: DB_PASSWORD,
+      database: DB_DATABASE,
+    },
+  },
+
+};

migrations/20180617203030_users.js

@@ -0,0 +1,21 @@
+
+exports.up = async (knex) => {
+  await knex.schema.createTable('User', (table) => {
+    table.increments('id').primary();
+    table.string('email');
+    table.string('firstName');
+    table.string('lastName');
+    table.string('password');
+    table.dateTime('createdAt').defaultTo(knex.fn.now(6));
+  });
+  await knex.schema.createTable('Project', (table) => {
+    table.increments('id').primary();
+    table.integer('ownerId');
+    table.string('title');
+  });
+};
+
+exports.down = async (knex) => {
+  await knex.schema.dropTable('User');
+  await knex.schema.dropTable('Project');
+};

migrations/20181006213558_books.js

@@ -0,0 +1,12 @@
+
+exports.up = async (knex) => {
+  await knex.schema.createTable('Book', (table) => {
+    table.increments('id').primary();
+    table.string('title');
+    table.string('author');
+  });
+};
+
+exports.down = async (knex) => {
+  await knex.schema.dropTable('Book');
+};

nodemon.json

@@ -0,0 +1,10 @@
+{
+  "watch": [
+    "src/",
+    "knexfile.js",
+    ".env"
+  ],
+  "env": {
+    "NODE_ENV": "development"
+  }
+}

package.json

@@ -0,0 +1,34 @@
+{
+  "name": "apollo-graphql-express-objection-server",
+  "version": "1.0.0",
+  "description": "A GraphQL (Apollo) Express server with JWT authentication, and using Objection.js ORM that automagically generates GQL schema types & resolvers.",
+  "main": "index.js",
+  "scripts": {
+    "test": "jest",
+    "start": "./node_modules/.bin/nodemon src/server.js"
+  },
+  "author": "Jack Chapple",
+  "license": "ISC",
+  "dependencies": {
+    "apollo-server-express": "^2.1.0",
+    "bcryptjs": "^2.4.3",
+    "body-parser": "^1.18.3",
+    "cors": "^2.8.4",
+    "dotenv": "^6.0.0",
+    "express": "^4.16.3",
+    "graphql": "^14.0.2",
+    "jsonwebtoken": "^8.3.0",
+    "knex": "^0.14.6",
+    "lodash": "^4.17.11",
+    "mysql": "^2.16.0",
+    "objection": "^1.1.10",
+    "objection-graphql": "^0.4.2"
+  },
+  "devDependencies": {
+    "eslint": "^4.16.0",
+    "eslint-config-airbnb-base": "^12.1.0",
+    "eslint-plugin-import": "^2.8.0",
+    "jest": "^23.1.0",
+    "nodemon": "^1.18.4"
+  }
+}

seeds/books.js

@@ -0,0 +1,17 @@
+const { Model } = require('objection');
+const { Book } = require('../src/models');
+
+exports.seed = async (knex) => {
+  Model.knex(knex);
+  await Book.query().delete();
+  await Book.query().insertGraph([
+    {
+      title: 'Harry Potter and the Chamber of Secrets',
+      author: 'J.K. Rowling',
+    },
+    {
+      title: 'Jurassic Park',
+      author: 'Michael Crichton',
+    },
+  ]);
+};

seeds/users.js

@@ -0,0 +1,31 @@
+const { Model } = require('objection');
+const { User, Project } = require('../src/models');
+
+exports.seed = async (knex) => {
+  Model.knex(knex);
+  await User.query().delete();
+  await Project.query().delete();
+  await User.query().insertGraph([
+    {
+      firstName: 'Alice',
+      lastName: 'Smith',
+      email: '[email protected]',
+      password: 'alice',
+      projects: [{ id: 1, title: 'Project by Alice' }],
+    },
+    {
+      firstName: 'Bob',
+      lastName: 'Smith',
+      email: '[email protected]',
+      password: 'bob',
+      projects: [{ id: 2, title: 'Project by Bob' }],
+    },
+    {
+      firstName: 'Eve',
+      lastName: 'Smith',
+      email: '[email protected]',
+      password: 'eve',
+      projects: [{ id: 3, title: 'Project by Eve' }],
+    },
+  ]);
+};

src/http-middleware/removeXPoweredBy.js

@@ -0,0 +1,6 @@
+const removeXPoweredBy = () => (req, res, next) => {
+  res.removeHeader('X-Powered-By');
+  next();
+};
+
+module.exports = removeXPoweredBy;

src/http-middleware/withAuth.js

@@ -0,0 +1,30 @@
+const { ForbiddenError } = require('apollo-server-express');
+const getUserFromRequest = require('../utils/getUserFromRequest');
+
+const withAuth = server => (
+  async (req, res, next) => {
+    const user = await getUserFromRequest(req);
+
+    server.context = () => {
+      if (!user) {
+        throw new ForbiddenError('Invalid credentials');
+      }
+      return { user };
+    };
+
+    res.locals.user = user;
+
+    server.requestOptions.rootValue = {
+      async onQuery(qb) {
+        await qb.mergeContext({
+          isApiQuery: true,
+          user,
+        });
+      },
+    };
+
+    next();
+  }
+);
+
+module.exports = withAuth;

src/knex.js

@@ -0,0 +1,8 @@
+const Knex = require('knex');
+const knexConfigs = require('../knexfile');
+
+const env = () => process.env.NODE_ENV || 'development';
+
+const knexConfig = knexConfigs[env()];
+
+module.exports = Knex(knexConfig);

src/models/BaseModel.js

@@ -0,0 +1,37 @@
+const { Model } = require('objection');
+
+module.exports = class BaseModel extends Model {
+  // Objection Model Configs
+  static get modelPaths() {
+    return [__dirname];
+  }
+  static get tableName() {
+    return this.name;
+  }
+
+  // eslint-disable-next-line
+  static async modifyApiQuery(qb, context) {}
+
+  // eslint-disable-next-line no-unused-vars
+  static async modifyApiResults(result, context, qb) {
+    return result;
+  }
+
+  static get QueryBuilder() {
+    return class extends super.QueryBuilder {
+      constructor(modelClass) {
+        super(modelClass);
+        this.runBefore(async (result, qb) => {
+          const context = qb.context();
+          if (!context.isApiQuery) return;
+          await modelClass.modifyApiQuery(qb, context);
+        });
+        this.runAfter(async (result, qb) => {
+          const context = qb.context();
+          if (!context.isApiQuery) return result;
+          return modelClass.modifyApiResults(result, context, qb);
+        });
+      }
+    };
+  }
+};

src/models/Book.js

@@ -0,0 +1,15 @@
+const BaseModel = require('./BaseModel');
+
+module.exports = class Book extends BaseModel {
+  static get jsonSchema() {
+    return {
+      type: 'object',
+
+      properties: {
+        title: { type: 'string', minLength: 1, maxLength: 255 },
+        author: { type: 'string', minLength: 1, maxLength: 255 },
+      },
+    };
+  }
+};
+

src/models/Project.js

@@ -0,0 +1,36 @@
+const BaseModel = require('./BaseModel');
+
+module.exports = class Project extends BaseModel {
+  static get jsonSchema() {
+    return {
+      type: 'object',
+
+      properties: {
+        id: { type: 'integer' },
+        title: { type: 'string', minLength: 1, maxLength: 255 },
+      },
+    };
+  }
+
+  static async modifyApiQuery(qb, { user }) {
+    if (user) {
+      qb.where('ownerId', user.id);
+    } else {
+      qb.whereRaw('1=2');
+    }
+  }
+
+  static get relationMappings() {
+    return {
+      owner: {
+        relation: this.BelongsToOneRelation,
+        modelClass: 'User',
+        join: {
+          from: 'Project.ownerId',
+          to: 'User.id',
+        },
+      },
+    };
+  }
+};
+