mozilla/publish.webmaker.org

"use strict";

if (process.env.NEW_RELIC_LICENSE_KEY) {
  require(`newrelic`);
}

// Initialize the environment before anything else happens
require(`./lib/environment`);

const Hapi = require(`hapi`);
const Hoek = require(`hoek`);
const redisUrl = require(`redis-url`);
const catboxRedis = require(`catbox-redis`);

Hoek.assert(process.env.API_HOST, `Must define API_HOST`);
Hoek.assert(process.env.PORT, `Must define PORT`);

const extensions = require(`./adaptors/extensions`);
const tokenValidators = require(`./lib/tokenValidator`);

let cache;

if (process.env.REDIS_URL) {
  const url = redisUrl.parse(process.env.REDIS_URL);

  cache = {
    engine: catboxRedis,
    host: url.hostname,
    port: url.port,
    password: url.password
  };
}

const server = new Hapi.Server({
  connections: {
    routes: {
      cors: true
    }
  },
  cache
});

server.app.cacheEnabled = !!process.env.REDIS_URL;

const connection = {
  host: process.env.API_HOST,
  port: process.env.PORT
};

server.connection(connection);

server.register({
  register: require(`hapi-bunyan`),
  options: {
    logger: require(`./lib/logger`),
    handler(eventType) {
      // In almost every situation we log to bunyan directly
      // through `req.log[level](...)` which doesn't trigger
      // a HAPI log event. When a HAPI log event is triggered,
      // this function determines if the data should be passed to
      // bunyan to be displayed.

      // Allow HAPI server-level logs (vs HAPI request-level logs)
      if (eventType === `log`) {
        // Returning false says "log this as normal"
        return false;
      }
      return true;
    }
  }
}, function(err) { Hoek.assert(!err, err); });

server.register(require(`./adaptors/plugins`), function(err) {
  if (err) {
    server.log(`error`, {
      message: `Error registering plugins`,
      error: err
    });
    throw err;
  }

  server.auth.strategy(
    `token`,
    `bearer-access-token`,
    true,
    require(`./lib/auth-config`)(tokenValidators.defaultTokenValidator)
  );

  server.auth.strategy(
    `projectToken`,
    `bearer-access-token`,
    {
      accessTokenName: `export_token`,
      tokenType: `export`,
      validateFunc: tokenValidators.exportProjectTokenValidator
    }
  );

  server.auth.strategy(
    `publishedProjectToken`,
    `bearer-access-token`,
    {
      accessTokenName: `export_token`,
      tokenType: `export`,
      validateFunc: tokenValidators.exportPublishedProjectTokenValidator
    }
  );

  server.register({ register: require(`./api`) }, function(apiRegisterError) {
    if (apiRegisterError) {
      server.log(`error`, {
        message: `Error registering api`,
        error: apiRegisterError
      });
      throw apiRegisterError;
    }

    // Server extension hooks
    server.ext(`onPreResponse`, [extensions.logRequest, extensions.clearTemporaryFile]);

    server.start(function(serverStartError) {
      if (serverStartError) {
        server.log(`error`, {
          message: `Error starting server`,
          error: serverStartError
        });
        throw serverStartError;
      }

      server.log(`info`, { server: server.info }, `Server started`);
    });
  });
});

// Run a mox server if we're emulating S3
(function() {
  if (!process.env.S3_EMULATION) {
    return;
  }

  const endpoint = process.env.PUBLIC_PROJECT_ENDPOINT;
  let port = endpoint.match(/:(\d+)/);

  if (!port) {
    return;
  }

  port = parseInt(port[1]);
  require(`mox-server`).runServer(port, function() {
    console.log(`running mox server on port`, port);
  });
})();