YUKI Hiroshi
null+****@clear*****
Thu Aug 1 13:49:27 JST 2013
YUKI Hiroshi 2013-08-01 13:49:27 +0900 (Thu, 01 Aug 2013) New Revision: 308be8dbbd786ca9727de793cb3c3aa4dad80cd1 https://github.com/groonga/express-droonga/commit/308be8dbbd786ca9727de793cb3c3aa4dad80cd1 Message: Separate definitions of wrappers from socket.io API framework Added files: lib/adapter/wrapper.js Modified files: lib/adapter/socket.io.js Modified: lib/adapter/socket.io.js (+3 -35) =================================================================== --- lib/adapter/socket.io.js 2013-08-01 13:47:33 +0900 (d73ff4f) +++ lib/adapter/socket.io.js 2013-08-01 13:49:27 +0900 (e10c060) @@ -1,5 +1,6 @@ var socketIo = require('socket.io'); var command = require('./command'); +var wrapper = require('./wrapper'); var defaultAPI = require('./api/socket.io'); var DEFAULT_TIMEOUT = 10 * 1000; @@ -23,39 +24,6 @@ function sanitizeBackendMessage(envelope) { } exports.sanitizeBackendMessage = sanitizeBackendMessage; - -function DroongaProtocolConnectionWrapper(connection, callback, options) { - this._connection = connection; - this._callback = callback; - this._options = options; -} -DroongaProtocolConnectionWrapper.prototype = { - emit: function(event, data) { - this._conneciton.emitMessage(event, data, this._callback, this._options); - }, - destroy: function() { - delete this._connection; - delete this._callback; - delete this._options; - } -}; -exports.DroongaProtocolConnectionWrapper = DroongaProtocolConnectionWrapper; - - -function SocketIOClientSocketWrapper(socket) { - this._socket = socket; -} -SocketIOClientSocketWrapper.prototype = { - emit: function(event, data) { - this._socket.emit(event, data); - }, - destroy: function() { - delete this._socket; - } -}; -exports.SocketIOClientSocketWrapper = SocketIOClientSocketWrapper; - - exports.register = function(application, server, params) { params = params || {}; var connection = params.connection; @@ -87,7 +55,7 @@ exports.register = function(application, server, params) { var responseEvent = envelope.type; var responseData = envelope.body; - var wrappedSocket = new SocketIOClientSocketWrapper(socket); + var wrappedSocket = new wrapper.SocketIOClientSocketWrapper(socket); if (clientOptions.responseEvent) responseEvent = clientOptions.responseEvent; @@ -109,7 +77,7 @@ exports.register = function(application, server, params) { options.sessionId = socket.id; - var wrappedConection = new DroongaProtocolConnectionWrapper(connection, callback, options); + var wrappedConection = new wrapper.DroongaProtocolConnectionWrapper(connection, callback, options); if (commandDefinition.onRequest) { try { commandDefinition.onRequest(data, wrappedConection); Added: lib/adapter/wrapper.js (+30 -0) 100644 =================================================================== --- /dev/null +++ lib/adapter/wrapper.js 2013-08-01 13:49:27 +0900 (5e2309f) @@ -0,0 +1,30 @@ +function DroongaProtocolConnectionWrapper(connection, callback, options) { + this._connection = connection; + this._callback = callback; + this._options = options; +} +DroongaProtocolConnectionWrapper.prototype = { + emit: function(event, data) { + this._conneciton.emitMessage(event, data, this._callback, this._options); + }, + destroy: function() { + delete this._connection; + delete this._callback; + delete this._options; + } +}; +exports.DroongaProtocolConnectionWrapper = DroongaProtocolConnectionWrapper; + + +function SocketIOClientSocketWrapper(socket) { + this._socket = socket; +} +SocketIOClientSocketWrapper.prototype = { + emit: function(event, data) { + this._socket.emit(event, data); + }, + destroy: function() { + delete this._socket; + } +}; +exports.SocketIOClientSocketWrapper = SocketIOClientSocketWrapper; -------------- next part -------------- HTML����������������������������... Download