feat(ext-json): add extended JSON codecs directly to BSON types

Author: mbroadst

lib/binary.js

@@ -274,6 +274,32 @@ class Binary {
   toString(format) {
     return this.buffer != null ? this.buffer.slice(0, this.position).toString(format) : '';
   }
+
+  /**
+   * @ignore
+   */
+  toExtendedJSON() {
+    const base64String = Buffer.isBuffer(this.buffer)
+      ? this.buffer.toString('base64')
+      : Buffer.from(this.buffer).toString('base64');
+
+    const subType = Number(this.sub_type).toString(16);
+    return {
+      $binary: {
+        base64: base64String,
+        subType: subType.length === 1 ? '0' + subType : subType
+      }
+    };
+  }
+
+  /**
+   * @ignore
+   */
+  static fromExtendedJSON(doc) {
+    const type = doc.$binary.subType ? parseInt(doc.$binary.subType, 16) : 0;
+    const data = new Buffer(doc.$binary.base64, 'base64');
+    return new Binary(data, type);
+  }
 }
 
 /**

lib/code.js

@@ -22,6 +22,24 @@ class Code {
   toJSON() {
     return { scope: this.scope, code: this.code };
   }
+
+  /**
+   * @ignore
+   */
+  toExtendedJSON() {
+    if (this.scope) {
+      return { $code: this.code, $scope: this.scope };
+    }
+
+    return { $code: this.code };
+  }
+
+  /**
+   * @ignore
+   */
+  static fromExtendedJSON(doc) {
+    return new Code(doc.$code, doc.$scope);
+  }
 }
 
 Object.defineProperty(Code.prototype, '_bsontype', { value: 'Code' });

lib/db_ref.js

@@ -42,6 +42,29 @@ class DBRef {
     if (this.db != null) o.$db = this.db;
     return o;
   }
+
+  /**
+   * @ignore
+   */
+  toExtendedJSON() {
+    let o = {
+      $ref: this.collection,
+      $id: this.oid
+    };
+
+    if (this.db) o.$db = this.db;
+    o = Object.assign(o, this.fields);
+    return o;
+  }
+
+  /**
+   * @ignore
+   */
+  static fromExtendedJSON(doc) {
+    var copy = Object.assign({}, doc);
+    ['$ref', '$id', '$db'].forEach(k => delete copy[k]);
+    return new DBRef(doc.$ref, doc.$id, doc.$db, copy);
+  }
 }
 
 Object.defineProperty(DBRef.prototype, '_bsontype', { value: 'DBRef' });

lib/decimal128.js

@@ -788,5 +788,19 @@ Decimal128.prototype.toJSON = function() {
   return { $numberDecimal: this.toString() };
 };
 
+/**
+ * @ignore
+ */
+Decimal128.prototype.toExtendedJSON = function() {
+  return { $numberDecimal: this.toString() };
+};
+
+/**
+ * @ignore
+ */
+Decimal128.fromExtendedJSON = function(doc) {
+  return Decimal128.fromString(doc.$numberDecimal);
+};
+
 Object.defineProperty(Decimal128.prototype, '_bsontype', { value: 'Decimal128' });
 module.exports = Decimal128;

lib/double.js

@@ -29,6 +29,23 @@ class Double {
   toJSON() {
     return this.value;
   }
+
+  /**
+   * @ignore
+   */
+  toExtendedJSON(options) {
+    if (options && options.relaxed && isFinite(this.value)) return this.value;
+    return { $numberDouble: this.value.toString() };
+  }
+
+  /**
+   * @ignore
+   */
+  static fromExtendedJSON(doc, options) {
+    return options && options.relaxed
+      ? parseFloat(doc.$numberDouble)
+      : new Double(parseFloat(doc.$numberDouble));
+  }
 }
 
 Object.defineProperty(Double.prototype, '_bsontype', { value: 'Double' });

lib/int_32.js

@@ -29,6 +29,21 @@ class Int32 {
   toJSON() {
     return this.value;
   }
+
+  /**
+   * @ignore
+   */
+  toExtendedJSON(options) {
+    if (options && options.relaxed) return this.value;
+    return { $numberInt: this.value.toString() };
+  }
+
+  /**
+   * @ignore
+   */
+  static fromExtendedJSON(doc, options) {
+    return options && options.relaxed ? parseInt(doc.$numberInt, 10) : new Int32(doc.$numberInt);
+  }
 }
 
 Object.defineProperty(Int32.prototype, '_bsontype', { value: 'Int32' });

lib/long.js

@@ -1,5 +1,21 @@
 'use strict';
 const Long = require('long');
 
+/**
+ * @ignore
+ */
+Long.prototype.toExtendedJSON = function(options) {
+  if (options && options.relaxed) return this.toNumber();
+  return { $numberLong: this.toString() };
+};
+
+/**
+ * @ignore
+ */
+Long.fromExtendedJSON = function(doc, options) {
+  const result = Long.fromString(doc.$numberLong);
+  return options && options.relaxed ? result.toNumber() : result;
+};
+
 Object.defineProperty(Long.prototype, '_bsontype', { value: 'Long' });
 module.exports = Long;

lib/max_key.js

@@ -9,6 +9,20 @@ class MaxKey {
    * @return {MaxKey} A MaxKey instance
    */
   constructor() {}
+
+  /**
+   * @ignore
+   */
+  toExtendedJSON() {
+    return { $maxKey: 1 };
+  }
+
+  /**
+   * @ignore
+   */
+  static fromExtendedJSON() {
+    return new MaxKey();
+  }
 }
 
 Object.defineProperty(MaxKey.prototype, '_bsontype', { value: 'MaxKey' });

lib/min_key.js

@@ -9,6 +9,20 @@ class MinKey {
    * @return {MinKey} A MinKey instance
    */
   constructor() {}
+
+  /**
+   * @ignore
+   */
+  toExtendedJSON() {
+    return { $minKey: 1 };
+  }
+
+  /**
+   * @ignore
+   */
+  static fromExtendedJSON() {
+    return new MinKey();
+  }
 }
 
 Object.defineProperty(MinKey.prototype, '_bsontype', { value: 'MinKey' });

lib/objectid.js

@@ -351,6 +351,21 @@ class ObjectId {
 
     return false;
   }
+
+  /**
+   * @ignore
+   */
+  toExtendedJSON() {
+    if (this.toHexString) return { $oid: this.toHexString() };
+    return { $oid: this.toString('hex') };
+  }
+
+  /**
+   * @ignore
+   */
+  static fromExtendedJSON(doc) {
+    return new ObjectId(doc.$oid);
+  }
 }
 
 /**