Federator.js

/*
 * Simple NodeJS Implementation of EIDA Federator
 *
 * Copyright Mathijs Koymans, 2016
 *
 * Only supports GET requests.
 *
 * Dataselect allowed parameters:
 * >>> Network, Station, Location, Channel, Starttime & Endtime
 *
 * Station allowed parameters:
 * >>> Network, Station, Location, Channel, Starttime & Endtime
 * >>> latitude, longitude, minradius, maxradius
 * >>> minlatitude, maxlatitude, minlongitude, maxlontigude
 *
 * WFCatalog allowed parametes:
 * >>> net(work), sta(tion), loc(ation), cha(nnel), start(time) & end(time)
 * >>> include
 * 
 */

"use strict";

// Federator is powered by NodeJS Express
const Federator = require("express")();
const CONFIG = require("./Config");

// Wrap the federator in a module
module.exports = function(federatorCallback) {

  /*
   * Require the Federator Routes:
   * WFCatalog is currently not implemented in routing
   *
   * |--routes
   *   |--version
   *   |--application.wadl
   *   |--dataselect
   *     |--query
   *     |--application.wadl
   *   |--wfcatalog
   *     |--query
   *     |--application.wadl
   *   |-- station
   *     |--query
   *     |--application.wadl
   *
   */

  // Default request handler
  require("./routes")(Federator);

  // Require the paths
  require("./routes/version")(Federator);
  require("./routes/application.wadl")(Federator);

  // Query implementations
  require("./routes/dataselect/query")(Federator);
  require("./routes/station/query")(Federator);
  require("./routes/wfcatalog/query")(Federator);

  // Require the .wadls
  require("./routes/dataselect/application.wadl")(Federator);
  require("./routes/station/application.wadl")(Federator);
  require("./routes/wfcatalog/application.wadl")(Federator);

  // Listen to incoming HTTP requests
  var server = Federator.listen(CONFIG.PORT, CONFIG.HOST, function() {

    // If a callback function was passed
    if(federatorCallback instanceof Function) {
      federatorCallback("NodeJS Federator has been started");
    }

  });

  // Disable server timeouts
  server.timeout = CONFIG.FEDERATOR_TIMEOUT;

}

// Called directly
if(require.main === module) {

  // Start a single federator
  new module.exports(function(message) {
    console.log(message);
  });

}