server.js

#! /usr/bin/node

var net = require('net');
var sqlite3 = require("sqlite3");
var argv = require("./argvparser");
var logger = require("./logger");
var connector = require("./connector");
var listener = require("./listener");
var express = require('express');
var path = require('path');
var kml = require('./kml');
var listings = require('./listings');
var streaminput = require('./streaminput');
var fs = require('fs');

var dbname = 'agpsd.db';
if (argv.options.db && argv.options.db.length > 0) {
  dbname = argv.options.db[0];
}
exports.serverSockets = {};
exports.db = new sqlite3.Database(dbname);
kml.db = exports.db;
logger.init(
  exports.db,
  function (err) {
    var port = 4711;
    if (argv.options.listen && argv.options.listen.length > 0) {
      port = parseInt(argv.options.listen[0]);
    }
    var server = net.createServer(function (socket) {
      new listener.Listener(socket);
    })
    server.listen(port);

    if (argv.options.upstream) {
      argv.options.upstream.forEach(function (val, index) {
        if (val.indexOf(":") != -1) {
          val = val.split(":");
          new connector.Connector(val[0], val[1], false);
        } else if (val == "-") {
          new streaminput.StreamInput(process.stdin, false);
          process.stdin.resume();
        } else {
          new streaminput.StreamInput(fs.createReadStream(val), false);
        }
      });
    }

    if (argv.options.downstream) {
      argv.options.downstream.forEach(function (val, index) {
        if (val.indexOf(":") != -1) {
          val = val.split(":");
          new connector.Connector(val[0], val[1], true);
        } else if (val == "-") {
          // FIXME
        } else {
          // FIXME
        }
      });
    }

    webserver = express();
    webserver.use(function (req, res, next) {
      res.header("Server", "AGPSD");
      next();
    });
    webserver.get('/kml', kml.getKml);
    webserver.get('/devices', listings.getDevices);
    webserver.get(/\/.*/, function(req, res, next) {
      res.sendfile(path.join(path.dirname(module.filename), "static", req.path), function (err) { if (err) next(); });
    });
    var httpport = 4812;
    if (argv.options.httplisten && argv.options.httplisten.length > 0) {
      httpport = parseInt(argv.options.httplisten[0]);
    }
    webserver.listen(httpport);


    console.log("Listening for web requests on " + httpport);
    console.log("Listening for connections on " + port);

  }
);