Feature/buyer approve request

app/auth-hooks.js

@@ -1,4 +1,5 @@
 import { getAccount, logout } from 'actions/authActions';
+import notifyHub from 'socket/notify';
 
 /* istanbul ignore next */
 export const requireAuth = (store) => (nextState, replace, done) => {
@@ -11,6 +12,11 @@ export const requireAuth = (store) => (nextState, replace, done) => {
             pathname: '/login',
             state: { nextPathname: nextState.location.pathname }
           });
+        } else {
+          const socket = notifyHub.getInstance();
+          if (socket.disconnected) {
+            socket.connect();
+          }
         }
 
         done();
@@ -30,6 +36,10 @@ export const requireAuth = (store) => (nextState, replace, done) => {
 /* istanbul ignore next */
 export const handleLogout = (store) => (nextState, replace) => {
   store.dispatch(logout());
+  const socket = notifyHub.getInstance();
+  if (socket.connected) {
+    socket.disconnect();
+  }
   replace({
     pathname: '/login'
   });

app/constants/index.js

@@ -1,7 +1,9 @@
 import merge from 'lodash/merge';
 
-export const BASE_URL = 'https://mxfactorial.appspot.com/systemaccounting';
-// export const BASE_URL = 'http://localhost:8080/systemaccounting'
+// export const BASE_URL = 'https://mxfactorial.appspot.com/systemaccounting';
+// export const SOCKET_URL = 'https://mxfactorial.appspot.com/';
+export const BASE_URL = 'http://192.168.66.131:8081/systemaccounting';
+export const SOCKET_URL = 'http://192.168.66.131:8081/';
 
 export const GET_EMPTY_TRANSACTION = (key, info)=>(merge({
   key,

app/socket/notify.js

@@ -0,0 +1,45 @@
+/* eslint no-console: 0 */
+import { SOCKET_URL } from 'constants/index';
+import io from 'socket.io-client';
+
+const link = `${SOCKET_URL}notify`;
+
+const notifyHub = (function () {
+  let socket;
+
+  function init() {
+    socket = io(link);
+
+    socket.on('connect', function () {
+      console.log('connected', socket);
+    });
+
+    socket.on('child_added', function (data) {
+      console.log(data);
+    });
+
+    socket.on('connection_refused', function (err) {
+      console.log(err);
+    });
+
+    socket.on('disconnect', function () {
+    });
+
+    return socket;
+  }
+
+  return {
+    getInstance: function () {
+
+      if ( !socket ) {
+        socket = init();
+      }
+
+      return socket;
+    }
+
+  };
+
+})();
+
+export default notifyHub;

firebase-db.js

@@ -0,0 +1,9 @@
+var firebase = require('firebase');
+var config = require('config.js');
+
+firebase.initializeApp({
+  databaseURL: config.get('FIREBASE_URL'),
+  serviceAccount: config.get('FIREBASE_KEY_PATH')
+});
+
+module.exports = firebase.database();

main.js

@@ -10,10 +10,14 @@ var passport = require('passport');
 var cors = require('cors');
 var JwtStrategy = require('passport-jwt').Strategy;
 var ExtractJwt = require('passport-jwt').ExtractJwt;
-
+var socketServer = require('socket-server');
 
 var app = express();
 
+var http = require('http').Server(app);
+
+socketServer(http);
+
 app.disable('etag');
 app.set('trust proxy', true);
 app.use(function (req, res, next) {
@@ -58,7 +62,7 @@ passport.use(new JwtStrategy(opts, function (jwt_payload, done) {
 
 if (module === require.main) {
   // Start the server
-  var server = app.listen(config.get('PORT'), function () {
+  var server = http.listen(config.get('PORT'), function () {
     var port = server.address().port;
     console.log('App listening on port %s', port);
   });

notification/hub.js

@@ -0,0 +1,25 @@
+var authorize = require('socket-server/cookie-authorize');
+var db = require('firebase-db');
+var ref = db.ref('notification');
+
+var socketMap = {};
+
+var subscribe = function (socket) {
+  authorize(socket).then(function (username) {
+    socketMap[username] = socket;
+  }).catch(function (err) {
+    socket.emit('connection_refused', err);
+  });
+};
+
+ref.on('child_added', function (snapshot, prevChildKey) {
+  var notification = snapshot.val();
+  var socket = notification.to && socketMap[notification.to];
+  if (socket) {
+    socket.emit('child_added', notification);
+  }
+});
+
+module.exports = {
+  subscribe: subscribe
+};

package.json

@@ -26,6 +26,7 @@
     "axios": "^0.12.0",
     "body-parser": "^1.15.0",
     "classnames": "^2.2.5",
+    "cookie": "^0.3.1",
     "cors": "^2.7.1",
     "crypto-js": "^3.1.6",
     "es6-promise": "^3.2.1",
@@ -58,8 +59,8 @@
     "redux-logger": "^2.6.1",
     "redux-promise": "^0.5.3",
     "reselect": "^2.5.3",
-    "socket.io": "^1.4.5",
-    "socket.io-client": "^1.4.5",
+    "socket.io": "^1.4.8",
+    "socket.io-client": "^1.4.8",
     "superagent": "^1.8.3",
     "url-search-params": "^0.5.0",
     "validator": "^5.4.0"

socket-server/cookie-authorize.js

@@ -0,0 +1,26 @@
+var cookie = require('cookie');
+var jwt = require('jsonwebtoken');
+
+var config = require('config.js');
+
+module.exports = function authorize(socket) {
+  return new Promise(function (resolve, reject) {
+    var cookies = cookie.parse(socket.request.headers.cookie);
+    if (cookies.token) {
+      jwt.verify(cookies.token.replace('JWT ', ''), config.get('API_SECRET'), function (err, decoded) {
+        if (!err) {
+          var username = decoded && decoded.username;
+          if (username) {
+            resolve(username);
+          } else {
+            reject('Invalid token');
+          }
+        } else {
+          reject(err);
+        }
+      });
+    } else {
+      reject('No token provided');
+    }
+  });
+};

socket-server/index.js

@@ -0,0 +1,13 @@
+var notificationHub = require('notification/hub');
+
+module.exports = function (httpServer) {
+  var io = require('socket.io')(httpServer);
+
+  io.of('/notify').on('connection', function (socket) {
+    notificationHub.subscribe(socket);
+
+    socket.on('disconnect', function () {
+
+    });
+  });
+};