server.js

import path from 'path';
import express from 'express';
import bodyParser from 'body-parser';
import { graphqlExpress, graphiqlExpress } from 'graphql-server-express';
import { createServer } from 'http';
import { SubscriptionServer } from 'subscriptions-transport-ws';
import cors from 'cors';

import settings from './settings';
import { connectToMongo } from './data/connectors';
import { subscriptionManager } from './data/subscription-manager';
import schema from './data/schema';
import { markCustomerAsNotActive } from './data/utils';

// connect to mongo database
connectToMongo();

const GRAPHQL_PORT = settings.GRAPHQL_PORT;

const app = express();

app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());

const corsOptions = {
  origin(origin, callback) {
    // origin is white listed
    callback(null, settings.ALLOWED_DOMAINS.includes(origin));
  },

  credentials: true,
};

app.use(cors(corsOptions));

app.use('/graphql', graphqlExpress(() =>
  ({
    schema,
  }),
));

// set the view engine to ejs
app.set('view engine', 'ejs');

// Express Middleware for serving static files
app.use('/build', express.static(path.join(__dirname, '../static')));

// routes ===
app.get('/inapp', (req, res) => {
  res.render('widget', { type: 'inApp' });
});

app.get('/chat', (req, res) => {
  res.render('widget', { type: 'chat' });
});

app.get('/form', (req, res) => {
  res.render('widget', { type: 'form' });
});

app.get('/test', (req, res) => {
  res.render('widget-test', { type: req.query.type });
});

// graphiql ==
app.use('/graphiql', graphiqlExpress({
  endpointURL: '/graphql',
}));

app.listen(GRAPHQL_PORT);

// websocket server
const WS_PORT = settings.WS_PORT;

const httpServer = createServer((request, response) => {
  response.writeHead(404);
  response.end();
});

httpServer.listen(WS_PORT, () => console.log( // eslint-disable-line no-console
  `Websocket Server is now running on http://localhost:${WS_PORT}`,
));

// subscription server
const server = new SubscriptionServer( // eslint-disable-line no-unused-vars
  { subscriptionManager },
  httpServer,
);

// receive inAppConnected message and save integrationId, customerId in
// connection
server.wsServer.on('connect', (connection) => {
  connection.on('message', (message) => {
    const parsedMessage = JSON.parse(message.utf8Data);

    if (parsedMessage.type === 'inAppConnected') {
      connection.inAppData = parsedMessage.value; // eslint-disable-line no-param-reassign
    }
  });
});

// mark customer as not active when connection close
server.wsServer.on('close', (connection) => {
  const inAppData = connection.inAppData;

  if (inAppData) {
    markCustomerAsNotActive(inAppData.customerId);
  }
});