"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.calculateObjectSize = void 0; var buffer_1 = require("buffer"); var binary_1 = require("../binary"); var constants = require("../constants"); var utils_1 = require("./utils"); function calculateObjectSize(object, serializeFunctions, ignoreUndefined) { var totalLength = 4 + 1; if (Array.isArray(object)) { for (var i = 0; i < object.length; i++) { totalLength += calculateElement(i.toString(), object[i], serializeFunctions, true, ignoreUndefined); } } else { // If we have toBSON defined, override the current object if (typeof (object === null || object === void 0 ? void 0 : object.toBSON) === 'function') { object = object.toBSON(); } // Calculate size for (var key in object) { totalLength += calculateElement(key, object[key], serializeFunctions, false, ignoreUndefined); } } return totalLength; } exports.calculateObjectSize = calculateObjectSize; /** @internal */ function calculateElement(name, // eslint-disable-next-line @typescript-eslint/no-explicit-any value, serializeFunctions, isArray, ignoreUndefined) { if (serializeFunctions === void 0) { serializeFunctions = false; } if (isArray === void 0) { isArray = false; } if (ignoreUndefined === void 0) { ignoreUndefined = false; } // If we have toBSON defined, override the current object if (typeof (value === null || value === void 0 ? void 0 : value.toBSON) === 'function') { value = value.toBSON(); } switch (typeof value) { case 'string': return 1 + buffer_1.Buffer.byteLength(name, 'utf8') + 1 + 4 + buffer_1.Buffer.byteLength(value, 'utf8') + 1; case 'number': if (Math.floor(value) === value && value >= constants.JS_INT_MIN && value <= constants.JS_INT_MAX) { if (value >= constants.BSON_INT32_MIN && value <= constants.BSON_INT32_MAX) { // 32 bit return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (4 + 1); } else { return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (8 + 1); } } else { // 64 bit return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (8 + 1); } case 'undefined': if (isArray || !ignoreUndefined) return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1; return 0; case 'boolean': return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (1 + 1); case 'object': if (value == null || value['_bsontype'] === 'MinKey' || value['_bsontype'] === 'MaxKey') { return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1; } else if (value['_bsontype'] === 'ObjectId' || value['_bsontype'] === 'ObjectID') { return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (12 + 1); } else if (value instanceof Date || (0, utils_1.isDate)(value)) { return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (8 + 1); } else if (ArrayBuffer.isView(value) || value instanceof ArrayBuffer || (0, utils_1.isAnyArrayBuffer)(value)) { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (1 + 4 + 1) + value.byteLength); } else if (value['_bsontype'] === 'Long' || value['_bsontype'] === 'Double' || value['_bsontype'] === 'Timestamp') { return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (8 + 1); } else if (value['_bsontype'] === 'Decimal128') { return (name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (16 + 1); } else if (value['_bsontype'] === 'Code') { // Calculate size depending on the availability of a scope if (value.scope != null && Object.keys(value.scope).length > 0) { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1 + 4 + 4 + buffer_1.Buffer.byteLength(value.code.toString(), 'utf8') + 1 + calculateObjectSize(value.scope, serializeFunctions, ignoreUndefined)); } else { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1 + 4 + buffer_1.Buffer.byteLength(value.code.toString(), 'utf8') + 1); } } else if (value['_bsontype'] === 'Binary') { var binary = value; // Check what kind of subtype we have if (binary.sub_type === binary_1.Binary.SUBTYPE_BYTE_ARRAY) { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (binary.position + 1 + 4 + 1 + 4)); } else { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + (binary.position + 1 + 4 + 1)); } } else if (value['_bsontype'] === 'Symbol') { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + buffer_1.Buffer.byteLength(value.value, 'utf8') + 4 + 1 + 1); } else if (value['_bsontype'] === 'DBRef') { // Set up correct object for serialization var ordered_values = Object.assign({ $ref: value.collection, $id: value.oid }, value.fields); // Add db reference if it exists if (value.db != null) { ordered_values['$db'] = value.db; } return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1 + calculateObjectSize(ordered_values, serializeFunctions, ignoreUndefined)); } else if (value instanceof RegExp || (0, utils_1.isRegExp)(value)) { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1 + buffer_1.Buffer.byteLength(value.source, 'utf8') + 1 + (value.global ? 1 : 0) + (value.ignoreCase ? 1 : 0) + (value.multiline ? 1 : 0) + 1); } else if (value['_bsontype'] === 'BSONRegExp') { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1 + buffer_1.Buffer.byteLength(value.pattern, 'utf8') + 1 + buffer_1.Buffer.byteLength(value.options, 'utf8') + 1); } else { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + calculateObjectSize(value, serializeFunctions, ignoreUndefined) + 1); } case 'function': // WTF for 0.4.X where typeof /someregexp/ === 'function' if (value instanceof RegExp || (0, utils_1.isRegExp)(value) || String.call(value) === '[object RegExp]') { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1 + buffer_1.Buffer.byteLength(value.source, 'utf8') + 1 + (value.global ? 1 : 0) + (value.ignoreCase ? 1 : 0) + (value.multiline ? 1 : 0) + 1); } else { if (serializeFunctions && value.scope != null && Object.keys(value.scope).length > 0) { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1 + 4 + 4 + buffer_1.Buffer.byteLength((0, utils_1.normalizedFunctionString)(value), 'utf8') + 1 + calculateObjectSize(value.scope, serializeFunctions, ignoreUndefined)); } else if (serializeFunctions) { return ((name != null ? buffer_1.Buffer.byteLength(name, 'utf8') + 1 : 0) + 1 + 4 + buffer_1.Buffer.byteLength((0, utils_1.normalizedFunctionString)(value), 'utf8') + 1); } } } return 0; } //# sourceMappingURL=calculate_size.js.map