droonga/express-droonga at fcc9597 [master] load: add Loader (Groonga-commit) - Groonga - fulltext search engine.

Kouhei Sutou	2014-04-25 14:05:18 +0900 (Fri, 25 Apr 2014)

  New Revision: fcc959777827af5d03206fc22b552a4402236783
  https://github.com/droonga/express-droonga/commit/fcc959777827af5d03206fc22b552a4402236783

  Message:
    load: add Loader

  Modified files:
    lib/adapter/api/groonga.js

  Modified: lib/adapter/api/groonga.js (+73 -66)
===================================================================

--- lib/adapter/api/groonga.js    2014-04-25 13:53:03 +0900 (fa255f3)
+++ lib/adapter/api/groonga.js    2014-04-25 14:05:18 +0900 (dde8ecb)
@@ -5,20 +5,83 @@ var statusCodes = {
   SUCCESS: 0
 };
 
-function createResponse(statusCode, startTimeInMilliseconds, body) {
-  var elapsedTimeInMilliseconds = Date.now() - startTimeInMilliseconds;
+function Loader(request, response, connection) {
+  this._request = request;
+  this._response = response;
+  this._connection = connection;
+}
+
+Loader.prototype.run = function run() {
+  this._jsonParser = new jsonParser();
+  this._statusCode = statusCodes.SUCCESS;
+  this._startTimeInMilliseconds = Date.now();
+  this._nRecords = 0;
+  this._nResponses = 0;
+  this._nAdded = 0;
+  this._isEnd = false;
+
+  this._jsonParser.onValue = this._onValue.bind(this);
+  this._request.on('data', function(chunk) {
+    this._jsonParser.write(chunk);
+  }.bind(this));
+  this._request.once('end', function() {
+    this._isEnd = true;
+
+    if (this._nRecords == 0) {
+      this._sendResponse([0]);
+    }
+  }.bind(this));
+};
+
+Loader.prototype._onValue = function(value) {
+  if (this._jsonParser.stack.length != 1) {
+    return;
+  }
+
+  this._nRecords++;
+
+  var message = {
+    table: this._request.query.table, // TODO: validate it
+    values: {}
+  };
+  Object.keys(value).forEach(function(key) {
+    if (key == '_key') {
+      message.key = value[key];
+    } else {
+      message.values[key] = value[key];
+    }
+  });
+
+  this._connection.emit('add', message, function(error, message) {
+    this._nResponses++;
+    if (error) {
+      // TODO: Output to error log file.
+      console.error("/d/load: failed to add a record", message);
+    } else {
+      var succeeded = message;
+      if (succeeded) {
+        this._nAdded++;
+      }
+    }
+    if (this._isEnd && this._nRecords == this._nResponses) {
+      this._sendResponse([this._nAdded]);
+    }
+  }.bind(this));
+};
+
+Loader.prototype._createResponse = function(body) {
+  var elapsedTimeInMilliseconds = Date.now() - this._startTimeInMilliseconds;
   var header = [
-    statusCode,
-    startTimeInMilliseconds / 1000,
+    this._statusCode,
+    this._startTimeInMilliseconds / 1000,
     elapsedTimeInMilliseconds / 1000,
   ];
   return [header, body];
 };
 
-function sendResponse(response, statusCode, startTimeInMilliseconds, body) {
-  var groongaResponse =
-    createResponse(statusCode, startTimeInMilliseconds, body);
-  response.jsonp(groongaResponse);
+Loader.prototype._sendResponse = function sendResponse(body) {
+  var groongaResponse = this._createResponse(body);
+  this._response.jsonp(groongaResponse);
 };
 
 module.exports = {
@@ -32,64 +95,8 @@ module.exports = {
     method: 'POST',
     path:   '/d/load',
     onRequest: function(request, connection, response) {
-      var parser = new jsonParser();
-      var nRecords = 0;
-      var nResponses = 0;
-      var nAdded = 0;
-      var isEnd = false;
-      var startTimeInMilliseconds = Date.now();
-
-      parser.onValue = function(value) {
-        if (parser.stack.length != 1) {
-          return;
-        }
-
-        nRecords++;
-
-        var message = {
-          table: request.query.table, // TODO: validate it
-          values: {}
-        };
-        Object.keys(value).forEach(function(key) {
-          if (key == '_key') {
-            message.key = value[key];
-          } else {
-            message.values[key] = value[key];
-          }
-        });
-
-        connection.emit('add', message, function(error, message) {
-          nResponses++;
-          if (error) {
-            // TODO: Output to error log file.
-            console.error("/d/load: failed to add a record", message);
-          } else {
-            var succeeded = message;
-            if (succeeded) {
-              nAdded++;
-            }
-          }
-          if (isEnd && nRecords == nResponses) {
-            sendResponse(response,
-                         statusCodes.SUCCESS,
-                         startTimeInMilliseconds,
-                         [nAdded]);
-          }
-        });
-      };
-      request.on('data', function(chunk) {
-        parser.write(chunk);
-      });
-      request.once('end', function() {
-        isEnd = true;
-
-        if (nRecords == 0) {
-          sendResponse(response,
-                       statusCodes.SUCCESS,
-                       startTimeInMilliseconds,
-                       [0]);
-        }
-      });
+      var loader = new Loader(request, response, connection);
+      loader.run();
     }
   })
 };
-------------- next part --------------
HTML����������������������������...
Download 


Groonga - fulltext search engine.

[Groonga-commit] droonga/express-droonga at fcc9597 [master] load: add Loader