global leak protection

lib/mongodb/admin.js

@@ -13,6 +13,8 @@ var Collection = require('./collection').Collection,
  * @return {Function} Constructor for Admin type.
  */
 function Admin(db) {  
+  if(!(this instanceof Admin)) return new Admin(db);
+
   this.db = db;
 };
 

lib/mongodb/bson/binary.js

@@ -20,7 +20,9 @@ var bson = require('./bson');
  * @param {Number} [subType] the option binary type.
  * @return {Grid}
  */
-function Binary(buffer, subType) {  
+function Binary(buffer, subType) {
+  if(!(this instanceof Binary)) return new Binary(buffer, subType);
+
   this._bsontype = 'Binary';
 
   if(buffer instanceof Number) {

lib/mongodb/bson/code.js

@@ -7,6 +7,8 @@
  * @return {Code}
  */
 function Code(code, scope) {
+  if(!(this instanceof Code)) return new Code(code, scope);
+
   this._bsontype = 'Code';
   this.code = code;
   this.scope = scope == null ? {} : scope;

lib/mongodb/bson/db_ref.js

@@ -8,6 +8,8 @@
  * @return {DBRef}
  */
 function DBRef(namespace, oid, db) {
+  if(!(this instanceof DBRef)) return new DBRef(namespace, oid, db);
+
   this._bsontype = 'DBRef';
   this.namespace = namespace;
   this.oid = oid;

lib/mongodb/bson/double.js

@@ -6,6 +6,8 @@
  * @return {Double}
  */
 function Double(value) {
+  if(!(this instanceof Double)) return new Double(value);
+
   this._bsontype = 'Double';
   this.value = value;
 }

lib/mongodb/bson/long.js

@@ -40,6 +40,8 @@
  * @param {Number} high the high (signed) 32 bits of the Long.
  */
 function Long(low, high) {
+  if(!(this instanceof Long)) return new Long(low, high);
+
   this._bsontype = 'Long';
   /**
    * @type {number}

lib/mongodb/bson/max_key.js

@@ -5,6 +5,8 @@
  * @return {MaxKey}
  */
 function MaxKey() {
+  if(!(this instanceof MaxKey)) return new MaxKey();
+
   this._bsontype = 'MaxKey';  
 }
 

lib/mongodb/bson/min_key.js

@@ -5,6 +5,8 @@
  * @return {MinKey}
  */
 function MinKey() {
+  if(!(this instanceof MinKey)) return new MinKey();
+
   this._bsontype = 'MinKey';
 }
 

lib/mongodb/bson/objectid.js

@@ -25,6 +25,8 @@ var checkForHexRegExp = new RegExp("^[0-9a-fA-F]{24}$");
 * @return {Object} instance of ObjectID.
 */
 function ObjectID(id) {
+  if(!(this instanceof ObjectID)) return new ObjectID(id);
+
   this._bsontype = 'ObjectID';
 
   var self = this;

lib/mongodb/bson/symbol.js

@@ -6,6 +6,8 @@
  * @return {Symbol}
  */
 function Symbol(value) {
+  if(!(this instanceof Symbol)) return new Symbol(value);
+
   this._bsontype = 'Symbol';
   this.value = value;
 }

lib/mongodb/bson/timestamp.js

@@ -40,6 +40,8 @@
  * @param {Number} high the high (signed) 32 bits of the Timestamp.
  */
 function Timestamp(low, high) {
+  if(!(this instanceof Timestamp)) return new Timestamp(low, high);
+
   this._bsontype = 'Timestamp';
   /**
    * @type {number}

lib/mongodb/collection.js

@@ -44,6 +44,8 @@ var toString = Object.prototype.toString;
  * @return {Object} a collection instance.
  */
 function Collection (db, collectionName, pkFactory, options) {
+  if(!(this instanceof Collection)) return new Collection(db, collectionName, pkFactory, options);
+
   checkCollectionName(collectionName);
 
   this.db = db;

lib/mongodb/connection/repl_set_servers.js

@@ -29,6 +29,8 @@ const STATE_ROLLBACK = 9;
 *
 */
 var ReplSetServers = exports.ReplSetServers = function(servers, options) {
+  if(!(this instanceof ReplSetServers)) return new ReplSetServers(server, options);
+
   var self = this;
   // Contains the master server entry
   this.options = options == null ? {} : options;

lib/mongodb/connection/server.js

@@ -7,6 +7,8 @@ var Connection = require('./connection').Connection,
   inherits = require('util').inherits;
 
 var Server = exports.Server = function(host, port, options) {
+  if(!(this instanceof Server)) return new Server(host, port, options);
+
   var self = this;
   this.host = host;
   this.port = port;

lib/mongodb/cursorstream.js

@@ -18,6 +18,8 @@ var Stream = require('stream').Stream;
  * @return {Stream}
  */
 function CursorStream(cursor) {
+  if(!(this instanceof CursorStream)) return new CursorStream(cursor);
+
   Stream.call(this);
 
   this.readable = true;

lib/mongodb/db.js

@@ -58,6 +58,9 @@ inherits(CallbackStore, EventEmitter);
  * @param {Object} [options] additional options for the collection.
  */
 function Db(databaseName, serverConfig, options) {
+
+  if(!(this instanceof Db)) return new Db(databaseName, serverConfig, options);
+
   EventEmitter.call(this);
   this.databaseName = databaseName;
   this.serverConfig = serverConfig;  

lib/mongodb/gridfs/chunk.js

@@ -21,6 +21,8 @@ var BinaryParser = require('../bson/binary_parser').BinaryParser,
  * @see Chunk#buildMongoObject
  */
 var Chunk = exports.Chunk = function(file, mongoObject) {
+  if(!(this instanceof Chunk)) return new Chunk(file, mongoObject);
+
   this.file = file;
   var self = this;
   var mongoObjectFinal = mongoObject == null ? {} : mongoObject;

lib/mongodb/gridfs/grid.js

@@ -10,6 +10,9 @@ var GridStore = require('./gridstore').GridStore,
  * @return {Grid}
  */
 function Grid(db, fsName) {
+
+  if(!(this instanceof Grid)) return new Grid(db, fsName);
+
   this.db = db;
   this.fsName = fsName == null ? GridStore.DEFAULT_ROOT_COLLECTION : fsName;
 } 

lib/mongodb/gridfs/gridstore.js

@@ -42,6 +42,8 @@ var REFERENCE_BY_FILENAME = 0,
  * @return {GridStore}
  */
 function GridStore(db, fileIdObject, mode, options) {
+  if(!(this instanceof GridStore)) return new GridStore(db, fileIdObject, mode, options);
+
   var self = this;
   this.db = db;