First commit

Author: mguillech

.idea/scopes/scope_settings.xml

@@ -0,0 +1 @@
+web: node app.js

.idea/workspace.xml

@@ -0,0 +1,37 @@
+'use strict';
+
+/**
+ *
+ * Main application
+ */
+var express = require("express"),
+    morgan = require("morgan"),
+    errorHandler = require('errorhandler'),
+    bodyParser = require('body-parser'),
+    http = require('http'),
+    app = express();
+
+// Some uses
+app.use(morgan('dev'));
+app.use(bodyParser.json());
+
+// Require the master (cluster) app
+require('./master')(app);
+
+// development only
+if (app.get('env') == 'development') {
+    app.use(errorHandler());
+}
+else {      // production error handling
+    app.use(function(err, req, res, next){
+        console.error(err.stack);
+        res.send(500, 'Something broke!');
+    });
+}
+
+
+var port = Number(process.env.PORT || 5000);
+
+http.createServer(app).listen(port, function(){
+    console.log('Express server listening on port ' + port);
+});

Procfile

@@ -0,0 +1,48 @@
+'use strict';
+
+module.exports = function(app) {
+    var cluster = require('cluster');
+
+    cluster.setupMaster({
+        exec : "worker.js",     // run this script when we fork ourselves
+        args : process.argv.slice(2),
+        silent : false
+    });
+
+    // Routing
+    app.get('/', function(req, res) {
+        res.send(401, 'Unauthorized');
+    });
+
+    app.post('/js', function(req, res) {
+        // Sanitize input first
+        var command = req.body.command;
+
+        if (typeof command === 'undefined') {
+            res.send(400);
+            return;
+        }
+
+        //This will be fired when the forked process becomes online
+        cluster.on("online", function(worker) {
+            var timer = 0;
+
+            worker.on("message", function (message) {
+                clearTimeout(timer);
+                console.log(message);
+                worker.destroy();   // destroy the spun worker
+                res.send({'text': message});
+            });
+
+            // handle long running processes here (5 seconds tops)
+            timer = setTimeout(function() {
+                worker.destroy();
+                console.log("worker execution expired");
+                res.send(400, 'Invalid command supplied');
+            }, 5000);
+            worker.send(command); // Send the expression to run from the worker
+        });
+
+        cluster.fork();   // fork one process so if for some reason the executed code hangs it doesn't crash the server
+    });
+};