fix(buffer): use safe-buffer polyfill to maintain compatibility

node.js < 4.5 and node.js < 5.9 doesn't support Buffer.alloc and Buffer.from

Author: Fonger

lib/auth/scram.js

@@ -4,7 +4,8 @@ var f = require('util').format,
   crypto = require('crypto'),
   retrieveBSON = require('../connection/utils').retrieveBSON,
   Query = require('../connection/commands').Query,
-  MongoError = require('../error').MongoError;
+  MongoError = require('../error').MongoError,
+  Buffer = require('safe-buffer').Buffer;
 
 let saslprep;
 

lib/connection/commands.js

@@ -4,6 +4,7 @@ var retrieveBSON = require('./utils').retrieveBSON;
 var BSON = retrieveBSON();
 var Long = BSON.Long;
 const MongoError = require('../error').MongoError;
+const Buffer = require('safe-buffer').Buffer;
 
 // Incrementing request id
 var _requestId = 0;

lib/connection/connection.js

@@ -13,7 +13,8 @@ var inherits = require('util').inherits,
   MongoNetworkError = require('../error').MongoNetworkError,
   Logger = require('./logger'),
   OP_COMPRESSED = require('../wireprotocol/shared').opcodes.OP_COMPRESSED,
-  MESSAGE_HEADER_SIZE = require('../wireprotocol/shared').MESSAGE_HEADER_SIZE;
+  MESSAGE_HEADER_SIZE = require('../wireprotocol/shared').MESSAGE_HEADER_SIZE,
+  Buffer = require('safe-buffer').Buffer;
 
 var _id = 0;
 var debugFields = [

lib/connection/pool.js

@@ -18,6 +18,7 @@ const uncompressibleCommands = require('../wireprotocol/compression').uncompress
 const resolveClusterTime = require('../topologies/shared').resolveClusterTime;
 const apm = require('./apm');
 const defaultAuthProviders = require('../auth/defaultAuthProviders').defaultAuthProviders;
+const Buffer = require('safe-buffer').Buffer;
 
 var DISCONNECTED = 'disconnected';
 var CONNECTING = 'connecting';

lib/topologies/replset_state.js

@@ -6,7 +6,8 @@ var inherits = require('util').inherits,
   EventEmitter = require('events').EventEmitter,
   Logger = require('../connection/logger'),
   ReadPreference = require('./read_preference'),
-  MongoError = require('../error').MongoError;
+  MongoError = require('../error').MongoError,
+  Buffer = require('safe-buffer').Buffer;
 
 var TopologyType = {
   Single: 'Single',

lib/topologies/shared.js

@@ -3,6 +3,7 @@
 const os = require('os');
 const f = require('util').format;
 const ReadPreference = require('./read_preference');
+const Buffer = require('safe-buffer').Buffer;
 
 /**
  * Emit event if it exists

package-lock.json

@@ -21,7 +21,8 @@
   ],
   "dependencies": {
     "bson": "^1.1.0",
-    "require_optional": "^1.0.1"
+    "require_optional": "^1.0.1",
+    "safe-buffer": "^5.1.2"
   },
   "devDependencies": {
     "chai": "^4.1.2",

package.json

@@ -7,6 +7,7 @@ const Server = require('../../../lib/topologies/server');
 const Bson = require('bson');
 const Connection = require('../../../lib/connection/connection');
 const mock = require('mongodb-mock-server');
+const Buffer = require('safe-buffer').Buffer;
 
 describe('Server tests', function() {
   it('should correctly connect server to single instance', {

test/tests/functional/server_tests.js

@@ -4,6 +4,7 @@ const mock = require('mongodb-mock-server');
 const ObjectId = require('bson').ObjectId;
 const Timestamp = require('bson').Timestamp;
 const Binary = require('bson').Binary;
+const Buffer = require('safe-buffer').Buffer;
 
 class ReplSetFixture {
   constructor() {

test/tests/unit/common.js

@@ -3,6 +3,7 @@
 const expect = require('chai').expect;
 const mock = require('mongodb-mock-server');
 const Server = require('../../../lib/topologies/server');
+const Buffer = require('safe-buffer').Buffer;
 
 describe('SCRAM Iterations Tests', function() {
   const test = {};