From 737bedf5efcb26d254d2643080f76079943f48ad Mon Sep 17 00:00:00 2001 From: lovebing Date: Fri, 23 Feb 2018 15:48:43 +0800 Subject: [PATCH 1/2] Add Socket.IO connection options --- lib/generator.js | 7 +++++++ lib/workers/socketioworker.js | 12 +++++++++++- 2 files changed, 18 insertions(+), 1 deletion(-) diff --git a/lib/generator.js b/lib/generator.js index e4d3f5f..666d520 100644 --- a/lib/generator.js +++ b/lib/generator.js @@ -37,5 +37,12 @@ module.exports = { //client.emit('test', { hello: 'world' }); //client.publish('/test', { hello: 'world' }); done(); + }, + + /** + * WAMP or Socket.IO connection options + */ + options : { + // realm: 'chat', } }; diff --git a/lib/workers/socketioworker.js b/lib/workers/socketioworker.js index 3831330..99f7ed3 100644 --- a/lib/workers/socketioworker.js +++ b/lib/workers/socketioworker.js @@ -15,7 +15,17 @@ util.inherits(SocketIOWorker, BaseWorker); SocketIOWorker.prototype.createClient = function (callback) { var self = this; - var client = io.connect(this.server, { 'force new connection' : true}); + var options = { + 'force new connection' : true + }; + if (self.generator.options) { + for (var k in self.generator.options) { + if (self.generator.options[k] !== null || self.generator.options[k] !== '') { + options[k] = self.generator.options[k]; + } + } + } + var client = io.connect(this.server, options); client.on('connect', function () { callback(false, client); From 3d4f37dceabeafd10009d7277553bcd9944b18e9 Mon Sep 17 00:00:00 2001 From: lovebing Date: Fri, 23 Feb 2018 15:53:14 +0800 Subject: [PATCH 2/2] Add Socket.IO connection options --- lib/generator.js | 7 ------- 1 file changed, 7 deletions(-) diff --git a/lib/generator.js b/lib/generator.js index 666d520..e4d3f5f 100644 --- a/lib/generator.js +++ b/lib/generator.js @@ -37,12 +37,5 @@ module.exports = { //client.emit('test', { hello: 'world' }); //client.publish('/test', { hello: 'world' }); done(); - }, - - /** - * WAMP or Socket.IO connection options - */ - options : { - // realm: 'chat', } };