mongodb-core - npm Package Compare versions

Comparing version 3.2.3 to 3.2.4

lib/auth/scram.js

@@ -180,3 +180,4 @@ 'use strict';
 
-      const dict = parsePayload(r.payload.value());
+      const payload = Buffer.isBuffer(r.payload) ? new Binary(r.payload) : r.payload;
+      const dict = parsePayload(payload.value());
       const iterations = parseInt(dict.i, 10);
@@ -202,3 +203,3 @@ const salt = dict.s;
       const storedKey = H(cryptoMethod, clientKey);
-      const authMessage = [firstBare, r.payload.value().toString('base64'), withoutProof].join(',');
+      const authMessage = [firstBare, payload.value().toString('base64'), withoutProof].join(',');
 
@@ -205,0 +206,0 @@ const clientSignature = HMAC(cryptoMethod, storedKey, authMessage);

lib/connection/command_result.js

@@ -22,3 +22,5 @@ 'use strict';
 CommandResult.prototype.toJSON = function() {
-  return this.result;
+  let result = Object.assign({}, this, this.result);
+  delete result.message;
+  return result;
 };
@@ -25,0 +27,0 @@

lib/connection/connect.js

@@ -8,2 +8,3 @@ 'use strict';
 const MongoError = require('../error').MongoError;
+const MongoNetworkError = require('../error').MongoNetworkError;
 const defaultAuthProviders = require('../auth/defaultAuthProviders').defaultAuthProviders;
@@ -287,3 +288,3 @@ const WIRE_CONSTANTS = require('../wireprotocol/constants');
       socket.removeListener('connect', connectHandler);
-      callback(err, eventName);
+      callback(new MongoNetworkError(err.message), eventName);
     };
@@ -290,0 +291,0 @@ }

lib/sessions.js

@@ -477,3 +477,3 @@ 'use strict';
   if (
-    commandName === 'commitTransaction' &&
+    // Assumption here that commandName is "commitTransaction" or "abortTransaction"
     session.transaction.recoveryToken &&
@@ -480,0 +480,0 @@ supportsRecoveryToken(session)

lib/topologies/shared.js

@@ -7,2 +7,3 @@ 'use strict';
 const Buffer = require('safe-buffer').Buffer;
+const TopologyType = require('../sdam/topology_description').TopologyType;
 
@@ -402,2 +403,16 @@ /**
 
+function topologyType(topology) {
+  if (topology.description) {
+    return topology.description.type;
+  }
+
+  if (topology.type === 'mongos') {
+    return TopologyType.Sharded;
+  } else if (topology.type === 'replset') {
+    return TopologyType.ReplicaSetWithPrimary;
+  }
+
+  return TopologyType.Single;
+}
+
 const RETRYABLE_WIRE_VERSION = 6;
@@ -420,2 +435,6 @@
 
+  if (topologyType(topology) === TopologyType.Single) {
+    return false;
+  }
+
   return true;
@@ -422,0 +441,0 @@ };

package.json

 {
   "name": "mongodb-core",
-  "version": "3.2.3",
+  "version": "3.2.4",
   "description": "Core MongoDB driver functionality, no bells and whistles and meant for integration not end applications",
@@ -5,0 +5,0 @@ "main": "index.js",

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

Improved metrics

Total package byte prevSize

568897

increased by0.27%

Lines of code

13863

increased by0.14%

No dependency changes