First isolated e2e

scripts/e2e-serve.js

@@ -0,0 +1,169 @@
+#!/usr/bin/env node
+
+const debug = require('debug')('talk:e2e:serve');
+const app = require('../app');
+const errors = require('../errors');
+const {createServer} = require('http');
+const scraper = require('../services/scraper');
+const mailer = require('../services/mailer');
+const SetupService = require('../services/setup');
+const kue = require('../services/kue');
+const mongoose = require('../services/mongoose');
+const util = require('../bin/util');
+const cache = require('../services/cache');
+const MigrationService = require('../services/migration');
+const {createSubscriptionManager} = require('../graph/subscriptions');
+const {
+  PORT
+} = require('../config');
+
+/**
+* Get port from environment and store in Express.
+*/
+
+const port = normalizePort(PORT);
+app.set('port', port);
+
+/**
+* Create HTTP server.
+*/
+const server = createServer(app);
+
+/**
+ * Event listener for HTTP server "error" event.
+ */
+function onError(error) {
+  if (error.syscall !== 'listen') {
+    throw error;
+  }
+
+  let bind = typeof port === 'string'
+    ? `Pipe ${port}`
+    : `Port ${port}`;
+
+  // handle specific listen errors with friendly messages
+  switch (error.code) {
+  case 'EACCES':
+    console.error(`${bind} requires elevated privileges`);
+    break;
+  case 'EADDRINUSE':
+    console.error(`${bind} is already in use`);
+    break;
+  }
+
+  throw error;
+}
+
+/**
+ * Normalize a port into a number, string, or false.
+ */
+
+function normalizePort(val) {
+  let port = parseInt(val, 10);
+
+  if (isNaN(port)) {
+
+    // named pipe
+    return val;
+  }
+
+  if (port >= 0) {
+
+    // port number
+    return port;
+  }
+
+  return false;
+}
+
+/**
+ * Event listener for HTTP server "listening" event.
+ */
+
+async function onListening() {
+
+  // Start the cache instance.
+  await cache.init();
+
+  let addr = server.address();
+  let bind = typeof addr === 'string'
+    ? `pipe ${addr}`
+    : `port ${addr.port}`;
+  debug(`API Server Listening on ${bind}`);
+}
+
+/**
+ * Start the app.
+ */
+async function serve() {
+  try {
+
+    // Check to see if the application is installed. If the application
+    // has been installed, then it will throw errors.ErrSettingsNotInit, this
+    // just means we don't have to check that the migrations have run.
+    await SetupService.isAvailable();
+
+    debug('setup is currently available, migrations not being checked');
+
+  } catch (e) {
+
+    // Check the error.
+    switch (e) {
+    case errors.ErrInstallLock, errors.ErrSettingsInit:
+
+      debug('setup is not currently available, migrations now being checked');
+
+      // The error was expected, just continue.
+      break;
+    default:
+
+      // The error was not expected, throw the error!
+      throw e;
+    }
+
+    // Now try and check the migration status.
+    try {
+
+      // Verify that the minimum migration version is met.
+      await MigrationService.verify();
+
+    } catch (e) {
+      console.error(e);
+      process.exit(1);
+    }
+  }
+
+  /**
+  * Listen on provided port, on all network interfaces.
+  */
+  server.on('error', onError);
+  server.on('listening', onListening);
+  server.on('listening', () => {
+
+  });
+  server.listen(port, () => {
+
+    // Mount the websocket server if requested.
+    debug(`Websocket Server Listening on ${port}`);
+
+    // Mount the subscriptions server on the application server.
+    createSubscriptionManager(server);
+  });
+
+  // Start the scraper processor.
+  scraper.process();
+
+  // Start the mail processor.
+  mailer.process();
+
+  // Define a safe shutdown function to call in the event we need to shutdown
+  // because the node hooks are below which will interrupt the shutdown process.
+  // Shutdown the mongoose connection, the app server, and the scraper.
+  util.onshutdown([
+    () => kue.Task.shutdown(),
+    () => mongoose.disconnect(),
+    () => server.close()
+  ]);
+}
+
+module.exports = serve;

scripts/e2e.js

@@ -2,40 +2,50 @@
 
 const Nightwatch = require('nightwatch');
 const browserstack = require('browserstack-local');
+const {onshutdown} = require('../bin/util');
 
-try {
-  const bs_local = new browserstack.Local();
-  process.mainModule.filename = './node_modules/.bin/nightwatch';
+async function start() {
+  try {
+    const bs_local = new browserstack.Local();
+    process.mainModule.filename = './node_modules/.bin/nightwatch';
 
-  // Code to start browserstack local before start of test
-  console.log('Connecting local');
-  Nightwatch.bs_local = bs_local;
-  bs_local.start({
-    'key': process.env.BROWSERSTACK_KEY,
-    'logFile': './test/e2e/bslocal.log'
-  }, function(error) {
-    if (error) {
-      console.error(error);
-      throw error;
-    }
+    // Code to start browserstack local before start of test
+    console.log('Connecting local');
+    Nightwatch.bs_local = bs_local;
 
-    console.log('Connected. Now testing...');
-    Nightwatch.cli(function(argv) {
-      Nightwatch.CliRunner(argv)
-        .setup(null, function(){
+    bs_local.start({
+      'key': process.env.BROWSERSTACK_KEY,
+      'logFile': './test/e2e/bslocal.log'
+    }, function(error) {
+      if (error) {
+        console.error(error);
+        throw error;
+      }
 
-          // Code to stop browserstack local after end of parallel test
-          bs_local.stop(function(){});
-        })
-        .runTests(function(){
+      console.log('Connected. Now testing...');
+      Nightwatch.cli(function(argv) {
+        Nightwatch.CliRunner(argv)
+          .setup(null, function(){
 
-          // Code to stop browserstack local after end of single test
-          bs_local.stop(function(){});
-        });
+            // Code to stop browserstack local after end of parallel test
+            bs_local.stop(function(){});
+          })
+          .runTests(function(){
+
+            // Code to stop browserstack local after end of single test
+            bs_local.stop(function(){});
+          });
+      });
     });
-  });
-} catch (ex) {
-  console.log('There was an error while starting the test runner:\n\n');
-  process.stderr.write(`${ex.stack}\n`);
-  process.exit(2);
+
+    onshutdown([
+      () => bs_local.stop(function(){}),
+    ]);
+  } catch (ex) {
+    console.log('There was an error while starting the test runner:\n\n');
+    process.stderr.write(`${ex.stack}\n`);
+    process.exit(2);
+  }
 }
+
+start();