@madbean/middle/src/index.js

import { createServer } from 'http';
import { execute, subscribe } from 'graphql';
import { graphqlExpress, graphiqlExpress } from 'graphql-server-express';
import { SubscriptionServer } from 'subscriptions-transport-ws';
import bodyParser from 'body-parser';
import express from 'express';
import fs from 'fs';
import jwt from 'jsonwebtoken';
import { makeExecutableSchema } from 'graphql-tools';
import { glue } from 'schemaglue';

import loaders from './Loaders';
import { userMapper } from './Mapper/User';

const app = express();
const PORT = 3000;
const isDev = process.env.NODE_ENV === 'dev';
const cert = isDev
  ? 'hive'
  : fs.readFileSync('/etc/letsencrypt/production/certs/madbean.ovh/fullchain.pem');

app.use(bodyParser.json());

app.use((req, res, next) => {
  if (!req.headers.authorization) {
    next();
  } else {
    const bearer = req.headers.authorization;
    const token = bearer.replace('Bearer ', '');

    jwt.verify(token, cert, { algorithms: ['RS256'] }, (err, decoded) => {
      if (!decoded) {
        next();
      } else {
        const { data } = decoded;
        if (data) {
          req.user = userMapper(data);
          next();
        }
      }
    });
  }
});

const { schema, resolver } = glue('src/graphql');
const executableSchema = makeExecutableSchema({
  typeDefs: schema,
  resolvers: resolver,
});

app.use('/graphql', graphqlExpress(req => ({
  context: {
    loaders,
    auth: {
      isAuthenticated: isDev ? true : !!req.user,
      scope: req.user && req.user.scope
        ? req.user.scope
        : null,
    },
  },
  schema: executableSchema,
  tracing: true,
  cacheControl: true,
})));

app.use('/graphiql', graphiqlExpress({
  endpointURL: '/graphql',
  subscriptionsEndpoint: `ws://localhost:${PORT}/subscriptions`,
}));

const server = createServer(app);

server.listen(PORT, () => {
  new SubscriptionServer({
    execute,
    subscribe,
    schema: executableSchema,
    onConnect: () => console.log('new client connected'),
  }, {
    server,
    path: '/subscriptions',
  });
});

console.log(`Middle running at http://localhost:${PORT}`);