hiring-test-one/bin/ws.js

#!/usr/bin/env node
"use strict";
var dope = require("console-dope"),
    http = require("http"),
    cliArgs = require("command-line-args"),
    o = require("object-tools"),
    t = require("typical"),
    path = require("path"),
    loadConfig = require("config-master"),
    homePath = require("home-path"),
    logStats = require("stream-log-stats"),
    connect = require("connect"),
    morgan = require("morgan"),
    serveStatic = require("serve-static"),
    directory = require("serve-index"),
    compress = require("compression"),
    cliOptions = require("../lib/cli-options");

/* specify the command line arg definitions and usage forms */
var cli = cliArgs(cliOptions);
var usage = cli.usage({
    forms: [ 
        "$ ws <server options>",  
        "$ ws --config",
        "$ ws --help"
    ]
});

/* parse command line args */
try {
    var argv = cli.parse();
} catch(err){
    halt(err.message);
}

/* Load and merge together options from
- ~/.local-web-server.json
- {cwd}/.local-web-server.json
- the `local-web-server` property of {cwd}/package.json
*/
var storedConfig = loadConfig(
    path.join(homePath(), ".local-web-server.json"),
    path.join(process.cwd(), ".local-web-server.json"),
    { jsonPath: path.join(process.cwd(), "package.json"), configProperty: "local-web-server" }
);

var builtInDefaults = {
    port: 8000,
    directory: process.cwd(),
    "refresh-rate": 500
};

/* override built-in defaults with stored config and then command line args */
argv.Server = o.extend(builtInDefaults, storedConfig, argv.Server);

/* user input validation */
var logFormat = argv.Server["log-format"];
if (!t.isNumber(argv.Server.port)) {
    halt("please supply a numeric port value");
}

if (argv.Misc.config){
    dope.log("Stored config: ");
    dope.log(storedConfig);
    process.exit(0);

} else if (argv.Misc.help){
    dope.log(usage);

} else {
    process.on("SIGINT", function(){
        dope.showCursor();
        dope.log();
        process.exit(0);
    });
    
    var app = connect();

    /* enable cross-origin requests on all resources */
    app.use(function(req, res, next){
        res.setHeader("Access-Control-Allow-Origin", "*");
        next();
    });

    /* log using --log-format (if supplied) */
    if(logFormat) {
        if (logFormat === "none"){
            // do nothing, no logging required
        } else {
            if (logFormat === "logstalgia"){
                /* customised logger :date token, purely to satisfy Logstalgia. */
                morgan.token("date", function(){
                    var a = new Date();
                    return (a.getDate() + "/" + a.getUTCMonth() + "/" + a.getFullYear() + ":" + a.toTimeString())
                            .replace("GMT", "").replace(" (BST)", "");
                });
                logFormat = "default";
            }

            app.use(morgan(logFormat));
        }        

    /* if no `--log-format` was specified, pipe the default format output
    into `log-stats`, which prints statistics to the console */
    } else {
        dope.hideCursor();
        app.use(morgan({ stream: logStats({ refreshRate: argv.Server["refresh-rate"] }) }));
    }

    /* --compress enables compression */
    if (argv.Server.compress) app.use(compress());

    /* enable static file server, including directory browsing support */
    app.use(serveStatic(path.resolve(argv.Server.directory)))
        .use(directory(path.resolve(argv.Server.directory), { icons: true }));

    /* launch server */
    http.createServer(app)
        .on("error", function(err){
            if (err.code === "EADDRINUSE"){
                halt("port " + argv.Server.port + " is already is use");
            } else {
                halt(err.message);
            }
        })
        .listen(argv.Server.port);

    /* write launch information to stderr (stdout is reserved for web log output) */
    if (path.resolve(argv.Server.directory) === process.cwd()){
        dope.error("serving at %underline{%s}", "http://localhost:" + argv.Server.port);
    } else {
        dope.error("serving %underline{%s} at %underline{%s}", argv.Server.directory, "http://localhost:" + argv.Server.port);
    }
}

function halt(message){
    dope.red.log("Error: %s",  message);
    dope.log(usage);
    process.exit(1);
}