pub-server/server.js

/*
 * pub server.js
 *
 * launches (express) server after resolving opts
 * invoke directly via node command line, or via require()
 * see: https://nodejs.org/api/modules.html#modules_accessing_the_main_module
 *
 * copyright 2015-2020, Jürgen Leschner - github.com/jldec - MIT license
 */

var debug = require('debug')('pub:server');

var osType = require('os').type();
var exec = require('child_process').exec;
var events = require('events');
var path = require('path');
var u = require('pub-util');

if (require.main === module) {
  pubServer().run();
}
else {
  module.exports = pubServer;
}

u.inherits(pubServer, events.EventEmitter);

//--//--//--//--//--//--//--//--//--//--//--//--//

function pubServer(opts) {

  if (!(this instanceof pubServer)) return new pubServer(opts);
  events.EventEmitter.call(this);

  var server = this;

  // pass platform-specific ./node_modules path to resolve-opts for builtin packages
  server.opts = opts = require('pub-resolve-opts')(opts, path.join(__dirname, 'node_modules'));

  opts.production  = opts.production || (process.env.NODE_ENV === 'production');
  opts.port        = opts.port       || process.env.PORT || '3001';
  opts.appUrl      = opts.appUrl     || process.env.APP  || ('http://localhost:' + opts.port);

  server.run       = run;

  var generator = server.generator = require('pub-generator')(opts);

  u.each(opts.serverPlugins.reverse(), function(plugin) {
    debug('server plugin:', plugin.inspect());
    require(plugin.path)(server);
  });

  u.each(opts.generatorPlugins.reverse(), function(plugin) {
    debug('generator plugin:', plugin.path, plugin.inspect());
    require(plugin.path)(generator);
  });

  var log = opts.log;

  //--//--//--//--//--//--//--//--//--//--//--//

  function run() {
    if (opts.outputOnly) {

      var output =  opts.outputs[0];
      if (!output) return log('No output configured.');

      if (output.overrideOpts) {
        log('output only - override opts', output.overrideOpts);
        u.assign(opts, output.overrideOpts);
      }

      generator.load(function(err) {
        if (err) return log(err);

        generator.outputPages(function(err, result) {
          if (err) { log(err); }
          log('output %s generated pages', u.flatten(result).length);
        });

        var statics = require('./server/serve-statics')(opts, function(){
          statics.outputAll();
        });

        require('./server/serve-scripts')(opts).outputAll(generator);

        generator.unload();
      });

      return;
    }

    generator.load(function(err) {
      if (err) return log(err);

      if (opts.logPages) {
        generator.logPages();
        generator.unload();
        return;
      }

      require('./server/watch-sources')(generator);
      generator.listen(true);

      if (!opts['no-server']) { expressApp(); }
    });
  }

  function expressApp() {

    server.app =  require('express')();
    server.http = require('http').Server(server.app);
    require('./server/serve-sockets')(server);

    server.app.disable('x-powered-by');

    // see https://expressjs.com/en/guide/behind-proxies.html - boolean type sensitive
    server.app.set('trust proxy', opts['trust proxy'] || false);

    // log(err) shouldn't throw anymore
    log.logger.noErrors = true;

    // sessions come with optional redis logger
    server.sessions = require('pub-serve-sessions')(server);
    log('starting up', opts.appUrl, (opts.production ? 'production' : 'non-production'));

    // other default middleware
    var bodyParser = require('body-parser');
    server.app.use(bodyParser.json());
    server.app.use(bodyParser.urlencoded({ extended: false }));
    server.app.use(require('compression')());

    server.emit('init-app-first');
    server.sessions.authorizeRoutes();

    server.statics = require('./server/serve-statics')(opts).serveRoutes(server);

    if (!opts.staticOnly) {
      server.scripts = require('./server/serve-scripts')(opts).serveRoutes(server);
      require('./server/serve-pages')(server);
    }

    server.emit('init-app-last');

    var limit = 10;
    var tried = 1;
    server.http.on('error', function(err) {
      if (err.code === 'EADDRINUSE' && tried < limit) {
        server.http.close();
        opts.port = (parseInt(opts.port) || 3001) + 1;
        log('port in use, trying', opts.port);
        server.http.listen(opts.port);
        tried ++;
      }
    });

    require('./server/handle-errors')(server);

    server.http.listen(opts.port);
    log('port', opts.port);

    process.on('SIGTERM', function() {
      log('shutting down');
      server.http.close(function() {
        generator.unload();
        server.emit('shutdown');
        process.exit();
      });
    });

    setTimeout(function() {
      if (opts.cli && opts.openBrowser && osType.match(/Darwin/)) {
        exec('open "http://localhost:"' + opts.port);
      }
    }, 100);
  }

}