experimental sse-support

package.json

@@ -46,13 +46,15 @@
     "bootstrap": "^3.3.4",
     "console-polyfill": "^0.2.0",
     "es5-shim": "^4.1.0",
+    "express-sse": "^0.2.1",
     "jquery": "^2.1.3",
     "moment": "^2.10.2",
     "pubsub-js": "^1.5.2",
     "q": "^1.2.0",
     "react": "^0.13.1",
     "react-router": "^0.13.2",
     "web3.js": "ethereum/ethereum.js#develop",
+    "ws": "^0.7.1",
     "xhr": "^2.0.1"
   },
   "browserify": {

server.js

@@ -1,9 +1,11 @@
 import express from 'express';
+import SSE from 'express-sse';
 import bodyParser from 'body-parser';
 import dockerx from 'docker-transfer';
 import moment from 'moment';
 
 let app = express();
+let sse = new SSE(['connected']);
 
 // Serve static files
 app.use(express.static(__dirname + '/build'));
@@ -24,12 +26,16 @@ app.post('/transfer', function(req, res) {
     res.send(timestamp() + " TRANSFER: Init client transfer of " + imageHash + " to " + host + ":" + port + "\n");
 });
 
+app.get('/stream', sse.init);
+
 app.post('/receive', function(req, res) {
     let name = "lolubuntu";
     let port = req.body.port;
+    sse.send(timestamp())
     dockerx.server.receive(name, port).then(
-        res.send(timestamp() + " RECEIVE: Init server listening at " + port + "\n")
+        sse.send('Finished at ' + timestamp())
     );
+    res.send(timestamp() + " RECEIVE: Init server listening at " + port + "\n");
 });
 
 function timestamp() {

src/main.jsx

@@ -49,6 +49,10 @@ let App = React.createClass({
         // tell ui that docker is hosted
     },
     workerEnableXfer(agreement) {
+        let es = new EventSource('/stream');
+        es.onmessage = function(event) {
+            console.log(event);
+        };
         $.post("/receive", {
             port: DockerConfig.port
         }, (data) => {