[Groonga-commit] groonga/express-droonga at 308be8d [master] Separate definitions of wrappers from socket.io API framework

Back to archive index

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����������������������������...
Descargar 



More information about the Groonga-commit mailing list
Back to archive index