add namespace of

Author: coderrorer

.idea/jsLibraryMappings.xml

@@ -16,6 +16,7 @@ function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { de
 
 require('colors');
 var Pm2Socket = require('./socket');
+var Pm2Namespace = require('./namespace');
 module.exports = function () {
     (0, _createClass3.default)(Pm2SocketIO, null, [{
         key: 'getIp',
@@ -79,7 +80,6 @@ module.exports = function () {
             for (var i = 0; i < (process.env.instances || 1); i++) {
                 processList.push(i);
             }
-
             this.addresses.map(function (ip) {
                 processList.map(function (id) {
                     setTimeout(function () {
@@ -93,15 +93,15 @@ module.exports = function () {
                         } catch (e) {
                             console.error(e);
                         }
-                        connect.on('@toServer', function (event) {
-                            for (var _len = arguments.length, data = Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
-                                data[_key - 1] = arguments[_key];
+                        connect.on('@toServer', function (event, namespace) {
+                            for (var _len = arguments.length, data = Array(_len > 2 ? _len - 2 : 0), _key = 2; _key < _len; _key++) {
+                                data[_key - 2] = arguments[_key];
                             }
 
                             if (_this.instanceId != id || ip != _this.localIp) {
-                                var _io$sockets;
+                                var _io$of$sockets;
 
-                                (_io$sockets = _this.io.sockets).emit.apply(_io$sockets, [event].concat(data));
+                                (_io$of$sockets = _this.io.of(namespace || '/').sockets).emit.apply(_io$of$sockets, [event].concat(data));
                             }
                         });
                     }, 0);
@@ -126,14 +126,19 @@ module.exports = function () {
     }, {
         key: 'emit',
         value: function emit(event) {
-            var _io$sockets2, _io$sockets3;
+            var _io$sockets, _io$sockets2;
 
             for (var _len2 = arguments.length, data = Array(_len2 > 1 ? _len2 - 1 : 0), _key2 = 1; _key2 < _len2; _key2++) {
                 data[_key2 - 1] = arguments[_key2];
             }
 
-            (_io$sockets2 = this.io.sockets).emit.apply(_io$sockets2, ['@toServer', event].concat(data));
-            (_io$sockets3 = this.io.sockets).emit.apply(_io$sockets3, [event].concat(data));
+            (_io$sockets = this.io.sockets).emit.apply(_io$sockets, ['@toServer', event, '/'].concat(data));
+            (_io$sockets2 = this.io.sockets).emit.apply(_io$sockets2, [event].concat(data));
+        }
+    }, {
+        key: 'of',
+        value: function of(namespace) {
+            return new Pm2Namespace(this.io, namespace);
         }
     }]);
     return Pm2SocketIO;

.idea/libraries/socketio_with_pm2_node_modules.xml

@@ -0,0 +1,50 @@
+'use strict';
+
+var _classCallCheck2 = require('babel-runtime/helpers/classCallCheck');
+
+var _classCallCheck3 = _interopRequireDefault(_classCallCheck2);
+
+var _createClass2 = require('babel-runtime/helpers/createClass');
+
+var _createClass3 = _interopRequireDefault(_createClass2);
+
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+var Pm2Socket = require('./socket');
+module.exports = function () {
+    function Namespace(io, namespace) {
+        (0, _classCallCheck3.default)(this, Namespace);
+
+        this.io = io;
+        this.namespace = namespace;
+    }
+
+    (0, _createClass3.default)(Namespace, [{
+        key: 'on',
+        value: function on(event, cb) {
+            var _this = this;
+
+            if (event == 'connection') {
+                this.io.of(this.namespace).on(event, function (socket) {
+                    var s = new Pm2Socket(socket, _this.io.of(_this.namespace));
+                    cb(s);
+                });
+            } else this.io.of(this.namespace).on(event, function () {
+                cb.apply(undefined, arguments);
+            });
+        }
+    }, {
+        key: 'emit',
+        value: function emit(event) {
+            var _io$sockets, _io$of$sockets;
+
+            for (var _len = arguments.length, data = Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+                data[_key - 1] = arguments[_key];
+            }
+
+            (_io$sockets = this.io.sockets).emit.apply(_io$sockets, ['@toServer', event, this.namespace].concat(data));
+            (_io$of$sockets = this.io.of(this.namespace).sockets).emit.apply(_io$of$sockets, [event].concat(data));
+        }
+    }]);
+    return Namespace;
+}();

.idea/socketio-with-pm2.iml

@@ -1,6 +1,6 @@
 {
   "name": "socketio-with-pm2",
-  "version": "0.1.4",
+  "version": "0.1.5",
   "description": "This is an nodejs plugin for socketio, which support socketio run with the cluster mode of pm2",
   "main": "index.js",
   "scripts": {

.idea/workspace.xml

@@ -3,6 +3,7 @@
  */
 require('colors');
 var Pm2Socket = require('./socket')
+var Pm2Namespace = require('./namespace');
 module.exports = class Pm2SocketIO {
     static getIp() {
         var os = require('os');
@@ -60,7 +61,6 @@ module.exports = class Pm2SocketIO {
         for (let i = 0; i < (process.env.instances || 1); i++) {
             processList.push(i);
         }
-
         this.addresses.map(ip=> {
             processList.map(id=> {
                 setTimeout(()=> {
@@ -74,9 +74,9 @@ module.exports = class Pm2SocketIO {
                     } catch (e) {
                         console.error(e)
                     }
-                    connect.on('@toServer', (event, ...data)=> {
+                    connect.on('@toServer', (event, namespace, ...data)=> {
                         if (this.instanceId != id || ip != this.localIp) {
-                            this.io.sockets.emit(event, ...data);
+                            this.io.of(namespace || '/').sockets.emit(event, ...data);
                         }
                     })
                 }, 0)
@@ -99,8 +99,12 @@ module.exports = class Pm2SocketIO {
     }
 
     emit(event, ...data) {
-        this.io.sockets.emit('@toServer', event, ...data);
+        this.io.sockets.emit('@toServer', event, '/', ...data);
         this.io.sockets.emit(event, ...data);
     }
 
+    of(namespace) {
+        return new Pm2Namespace(this.io, namespace);
+    }
+
 }

master.js

@@ -0,0 +1,29 @@
+/**
+ * Created by denniszhang on 17/2/23.
+ */
+var Pm2Socket = require('./socket')
+module.exports = class Namespace {
+    constructor(io, namespace) {
+        this.io = io;
+        this.namespace = namespace;
+        
+    }
+
+    on(event, cb) {
+        if (event == 'connection') {
+            this.io.of(this.namespace).on(event, socket=> {
+                var s = new Pm2Socket(socket, this.io.of(this.namespace));
+                cb(s);
+            })
+        }
+        else this.io.of(this.namespace).on(event, function (...data) {
+            cb(...data);
+        })
+    }
+
+    emit(event, ...data) {
+        this.io.sockets.emit('@toServer', event,this.namespace, ...data);
+        this.io.of(this.namespace).sockets.emit(event, ...data);
+    }
+
+}

namespace.js

@@ -4,7 +4,7 @@
 var Pm2Socketio = require('../index');
 var io = new Pm2Socketio();
 io.listen(3001);
-io.on('connection', socket=> {
+io.of('/chat').on('connection', socket=> {
     console.log('connect success!')
     socket.on('eventSave', data=> {
         socket.broadcast.emit('eventUpdate', data);