Add a node server for running locally.

mramato · Nov 19, 2014 · 8ad7619 · 8ad7619
1 parent 0e2f06d
commit 8ad7619
Show file tree

Hide file tree

Showing 4 changed files with 189 additions and 0 deletions.
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1,4 @@
+/.metadata
+.DS_Store
+Thumbs.db
+/node_modules
diff --git a/11-20-2014/index.html b/11-20-2014/index.html
@@ -0,0 +1,9 @@
+<html>
+<body>
+<ul>
+	<li><a href='../CesiumViewer/index.html?source=/11-20-2014/gps/gps.czml'>GPS Coverage</a></li>
+	<li><a href='../CesiumViewer/index.html?source=/11-20-2014/new-york_new-york.osm.pbf.czml'>New York City OSM Extract</a></li>
+	<li><a href='../CesiumViewer/index.html?source=/11-20-2014/traffic.czml'>Oshawa traffic</a></li>
+</ul>
+<body>
+</html>
diff --git a/package.json b/package.json
@@ -0,0 +1,16 @@
+{
+    "name": "mramato",
+    "version": "1.0.0",
+    "description": "My personal website.",
+    "homepage": "http://mramato.github.io",
+    "repository": {
+        "type": "git",
+        "url": "mramato.github.io"
+    },
+    "devDependencies": {
+        "express": "4.4.4",
+        "compression": "1.0.8",
+        "request": "2.36.0",
+        "yargs": "1.2.6"
+    }
+}
diff --git a/server.js b/server.js
@@ -0,0 +1,160 @@
+(function() {
+    "use strict";
+    /*global console,require,__dirname,process*/
+    /*jshint es3:false*/
+
+    var express = require('express');
+    var compression = require('compression');
+    var url = require('url');
+    var request = require('request');
+
+    var yargs = require('yargs').options({
+        'port' : {
+            'default' : 8080,
+            'description' : 'Port to listen on.'
+        },
+        'public' : {
+            'type' : 'boolean',
+            'description' : 'Run a public server that listens on all interfaces.'
+        },
+        'upstream-proxy' : {
+            'description' : 'A standard proxy server that will be used to retrieve data.  Specify a URL including port, e.g. "http://proxy:8000".'
+        },
+        'bypass-upstream-proxy-hosts' : {
+            'description' : 'A comma separated list of hosts that will bypass the specified upstream_proxy, e.g. "lanhost1,lanhost2"'
+        },
+        'help' : {
+            'alias' : 'h',
+            'type' : 'boolean',
+            'description' : 'Show this help.'
+        }
+    });
+    var argv = yargs.argv;
+
+    if (argv.help) {
+        return yargs.showHelp();
+    }
+
+    // eventually this mime type configuration will need to change
+    // https://github.com/visionmedia/send/commit/d2cb54658ce65948b0ed6e5fb5de69d022bef941
+    var mime = express.static.mime;
+    mime.define({
+        'application/json' : ['czml', 'json', 'geojson', 'topojson', 'gltf'],
+        'text/plain' : ['glsl']
+    });
+
+    var app = express();
+    app.use(compression());
+    app.use(express.static(__dirname));
+
+    function getRemoteUrlFromParam(req) {
+        var remoteUrl = req.params[0];
+        if (remoteUrl) {
+            // add http:// to the URL if no protocol is present
+            if (!/^https?:\/\//.test(remoteUrl)) {
+                remoteUrl = 'http://' + remoteUrl;
+            }
+            remoteUrl = url.parse(remoteUrl);
+            // copy query string
+            remoteUrl.search = url.parse(req.url).search;
+        }
+        return remoteUrl;
+    }
+
+    var dontProxyHeaderRegex = /^(?:Host|Proxy-Connection|Connection|Keep-Alive|Transfer-Encoding|TE|Trailer|Proxy-Authorization|Proxy-Authenticate|Upgrade)$/i;
+
+    function filterHeaders(req, headers) {
+        var result = {};
+        // filter out headers that are listed in the regex above
+        Object.keys(headers).forEach(function(name) {
+            if (!dontProxyHeaderRegex.test(name)) {
+                result[name] = headers[name];
+            }
+        });
+        return result;
+    }
+
+    var upstreamProxy = argv['upstream-proxy'];
+    var bypassUpstreamProxyHosts = {};
+    if (argv['bypass-upstream-proxy-hosts']) {
+        argv['bypass-upstream-proxy-hosts'].split(',').forEach(function(host) {
+            bypassUpstreamProxyHosts[host.toLowerCase()] = true;
+        });
+    }
+
+    app.get('/proxy/*', function(req, res, next) {
+        // look for request like http://localhost:8080/proxy/http://example.com/file?query=1
+        var remoteUrl = getRemoteUrlFromParam(req);
+        if (!remoteUrl) {
+            // look for request like http://localhost:8080/proxy/?http%3A%2F%2Fexample.com%2Ffile%3Fquery%3D1
+            remoteUrl = Object.keys(req.query)[0];
+            if (remoteUrl) {
+                remoteUrl = url.parse(remoteUrl);
+            }
+        }
+
+        if (!remoteUrl) {
+            return res.send(400, 'No url specified.');
+        }
+
+        if (!remoteUrl.protocol) {
+            remoteUrl.protocol = 'http:';
+        }
+
+        var proxy;
+        if (upstreamProxy && !(remoteUrl.host in bypassUpstreamProxyHosts)) {
+            proxy = upstreamProxy;
+        }
+
+        // encoding : null means "body" passed to the callback will be raw bytes
+
+        request.get({
+            url : url.format(remoteUrl),
+            headers : filterHeaders(req, req.headers),
+            encoding : null,
+            proxy : proxy
+        }, function(error, response, body) {
+            var code = 500;
+
+            if (response) {
+                code = response.statusCode;
+                res.header(filterHeaders(req, response.headers));
+            }
+
+            res.send(code, body);
+        });
+    });
+
+    var server = app.listen(argv.port, argv.public ? undefined : 'localhost', function() {
+        if (argv.public) {
+            console.log('Cesium development server running publicly.  Connect to http://localhost:%d/', server.address().port);
+        } else {
+            console.log('Cesium development server running locally.  Connect to http://localhost:%d/', server.address().port);
+        }
+    });
+
+    server.on('error', function (e) {
+        if (e.code === 'EADDRINUSE') {
+            console.log('Error: Port %d is already in use, select a different port.', argv.port);
+            console.log('Example: node server.js --port %d', argv.port + 1);
+        } else if (e.code === 'EACCES') {
+            console.log('Error: This process does not have permission to listen on port %d.', argv.port);
+            if (argv.port < 1024) {
+                console.log('Try a port number higher than 1024.');
+            }
+        }
+        console.log(e);
+        process.exit(1);
+    });
+
+    server.on('close', function() {
+        console.log('Cesium development server stopped.');
+    });
+
+    process.on('SIGINT', function() {
+        server.close(function() {
+            process.exit(0);
+        });
+    });
+
+})();