mongodb-core - npm Package Compare versions

Comparing version 1.1.11 to 1.1.12

conf.json

@@ -6,6 +6,2 @@ {
       "test/tests/functional/operation_example_tests.js",
-      "lib/tools/mongos_manager.js", 
-      "lib/tools/replset_manager.js", 
-      "lib/tools/server_manager.js", 
-      "lib/tools/sharding_manager.js", 
       "lib/topologies/mongos.js",
@@ -12,0 +8,0 @@ "lib/topologies/command_result.js",

HISTORY.md

@@ -0,1 +1,5 @@
+1.1.12 02-16-2015
+-----------------
+- Fixed cursor transforms for buffered document reads from cursor.
+
 1.1.11 02-02-2015
@@ -2,0 +6,0 @@ -----------------

lib/cursor.js

@@ -298,2 +298,12 @@ "use strict";
   this.cursorState.cursorIndex = this.cursorState.cursorIndex + length;
+
+  // Transform the doc with passed in transformation method if provided
+  if(this.cursorState.transforms && typeof this.cursorState.transforms.doc == 'function') {
+    // Transform all the elements
+    for(var i = 0; i < elements.length; i++) {
+      elements[i] = this.cursorState.transforms.doc(elements[i]);
+    }
+  }
+
+  // Return elements
   return elements;
@@ -501,3 +511,3 @@ }
   // If we have exhaust
-  if(self.options.exhaust && self.cursorState.cursorId == null) {
+  if(self.cmd.exhaust && self.cursorState.cursorId == null) {
     // Handle all the exhaust responses
@@ -507,8 +517,8 @@ self.callbacks.register(self.query.requestId, processExhaustMessages);
     return self.connection.write(self.query.toBin());
-  } else if(self.options.exhaust && self.cursorState.cursorIndex < self.cursorState.documents.length) {
+  } else if(self.cmd.exhaust && self.cursorState.cursorIndex < self.cursorState.documents.length) {
     return handleCallback(callback, null, self.cursorState.documents[self.cursorState.cursorIndex++]);
-  } else if(self.options.exhaust && Long.ZERO.equals(self.cursorState.cursorId)) {
+  } else if(self.cmd.exhaust && Long.ZERO.equals(self.cursorState.cursorId)) {
     self.callbacks.unregister(self.query.requestId);
     return setCursorNotified(self, callback);
-  } else if(self.options.exhaust) {
+  } else if(self.cmd.exhaust) {
     return setTimeout(function() {
@@ -529,3 +539,3 @@ if(Long.ZERO.equals(self.cursorState.cursorId)) return;
       if(err) return handleCallback(callback, err, null);
-      if(self.cursorState.documents.length == 0) {
+      if(self.cursorState.documents.length == 0 && !self.cmd.tailable && !self.cmd.awaitData) {
         return setCursorNotified(self, callback);
@@ -556,7 +566,7 @@ }
         // core module to handle to keep core simple
-        if(self.cursorState.documents.length == 0 && self.options.tailable) {
+        if(self.cursorState.documents.length == 0 && self.cmd.tailable) {
           return handleCallback(callback, MongoError.create({
               message: "No more documents in tailed cursor"
-            , tailable: self.options.tailable
-            , awaitData: self.options.awaitData
+            , tailable: self.cmd.tailable
+            , awaitData: self.cmd.awaitData
           }));
@@ -572,7 +582,7 @@ }
   } else if(self.cursorState.documents.length == self.cursorState.cursorIndex 
-    && self.options.tailable) { 
+    && self.cmd.tailable) { 
       return handleCallback(callback, MongoError.create({
           message: "No more documents in tailed cursor"
-        , tailable: self.options.tailable
-        , awaitData: self.options.awaitData
+        , tailable: self.cmd.tailable
+        , awaitData: self.cmd.awaitData
       }));
@@ -579,0 +589,0 @@ } else if(self.cursorState.documents.length == self.cursorState.cursorIndex

lib/topologies/server.js

@@ -984,2 +984,5 @@ "use strict";
 Server.prototype.cursor = function(ns, cmd, cursorOptions) {
+  // console.log("============================================ cursor")
+  // console.dir(cmd)
+  // console.dir(cursorOptions)
   var s = this.s;
@@ -986,0 +989,0 @@ cursorOptions = cursorOptions || {};

lib/wireprotocol/2_4_support.js

@@ -248,9 +248,2 @@ "use strict";
 
-  // Options
-  if(options.tailable) query.tailable = options.tailable;
-  if(options.oplogReplay)query.oplogReplay = options.oplogReplay;
-  if(options.noCursorTimeout) query.noCursorTimeout = options.noCursorTimeout;
-  if(options.awaitdata) query.awaitdata = options.awaitdata;
-  if(options.exhaust) query.exhaust = options.exhaust;
-  if(options.partial) query.partial = options.partial;
   // Return the query
@@ -257,0 +250,0 @@ return query;

lib/wireprotocol/2_6_support.js

@@ -234,9 +234,2 @@ "use strict";
 
-  // Options
-  if(typeof options.tailable == 'boolean') query.tailable = options.tailable;
-  if(typeof options.oplogReplay == 'boolean') query.oplogReplay = options.oplogReplay;
-  if(typeof options.noCursorTimeout == 'boolean') query.noCursorTimeout = options.noCursorTimeout;
-  if(typeof options.awaitdata == 'boolean') query.awaitdata = options.awaitdata;
-  if(typeof options.exhaust == 'boolean') query.exhaust = options.exhaust;
-  if(typeof options.partial == 'boolean') query.partial = options.partial;
   // Return the query
@@ -243,0 +236,0 @@ return query;

package.json

 {
   "name": "mongodb-core",
-  "version": "1.1.11",
+  "version": "1.1.12",
   "description": "Core MongoDB driver functionality, no bells and whistles and meant for integration not end applications",
@@ -18,3 +18,3 @@ "main": "index.js",
   "dependencies": {
-    "bson": "0.2.18",
+    "bson": "0.2.19",
     "mkdirp": "0.5.0",
@@ -24,3 +24,3 @@ "rimraf": "2.2.6"
   "devDependencies": {
-    "integra": "0.1.1",
+    "integra": "0.1.8",
     "optimist": "latest",
@@ -33,3 +33,3 @@ "jsdoc": "3.3.0-alpha8",
   "optionalDependencies": {
-    "kerberos": "0.0.8"
+    "kerberos": "0.0.9"
   },
@@ -36,0 +36,0 @@ "author": "Christian Kvalheim",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

305572

decreased by-0.15%

Lines of code

7548

decreased by-0.09%

Dependency changes

• + Addedbson@0.2.19(transitive)

• + Addedkerberos@0.0.9(transitive)

• + Addednan@1.6.2(transitive)

• - Removedbson@0.2.18(transitive)

• - Removedkerberos@0.0.8(transitive)

• - Removednan@1.5.1(transitive)

• Updatedbson@0.2.19