aboutsummaryrefslogtreecommitdiff
path: root/node_modules/mongodb-core/lib/wireprotocol/commands.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/mongodb-core/lib/wireprotocol/commands.js')
-rw-r--r--node_modules/mongodb-core/lib/wireprotocol/commands.js357
1 files changed, 0 insertions, 357 deletions
diff --git a/node_modules/mongodb-core/lib/wireprotocol/commands.js b/node_modules/mongodb-core/lib/wireprotocol/commands.js
deleted file mode 100644
index 9c665ee..0000000
--- a/node_modules/mongodb-core/lib/wireprotocol/commands.js
+++ /dev/null
@@ -1,357 +0,0 @@
-"use strict";
-
-var MongoError = require('../error');
-
-// Wire command operation ids
-var OP_UPDATE = 2001;
-var OP_INSERT = 2002;
-var OP_DELETE = 2006;
-
-var Insert = function(requestId, ismaster, bson, ns, documents, options) {
- // Basic options needed to be passed in
- if(ns == null) throw new MongoError("ns must be specified for query");
- if(!Array.isArray(documents) || documents.length == 0) throw new MongoError("documents array must contain at least one document to insert");
-
- // Validate that we are not passing 0x00 in the colletion name
- if(!!~ns.indexOf("\x00")) {
- throw new MongoError("namespace cannot contain a null character");
- }
-
- // Set internal
- this.requestId = requestId;
- this.bson = bson;
- this.ns = ns;
- this.documents = documents;
- this.ismaster = ismaster;
-
- // Ensure empty options
- options = options || {};
-
- // Unpack options
- this.serializeFunctions = typeof options.serializeFunctions == 'boolean' ? options.serializeFunctions : false;
- this.ignoreUndefined = typeof options.ignoreUndefined == 'boolean' ? options.ignoreUndefined : false;
- this.checkKeys = typeof options.checkKeys == 'boolean' ? options.checkKeys : true;
- this.continueOnError = typeof options.continueOnError == 'boolean' ? options.continueOnError : false;
- // Set flags
- this.flags = this.continueOnError ? 1 : 0;
-}
-
-// To Binary
-Insert.prototype.toBin = function() {
- // Contains all the buffers to be written
- var buffers = [];
-
- // Header buffer
- var header = new Buffer(
- 4 * 4 // Header
- + 4 // Flags
- + Buffer.byteLength(this.ns) + 1 // namespace
- );
-
- // Add header to buffers
- buffers.push(header);
-
- // Total length of the message
- var totalLength = header.length;
-
- // Serialize all the documents
- for(var i = 0; i < this.documents.length; i++) {
- var buffer = this.bson.serialize(this.documents[i]
- , this.checkKeys
- , true
- , this.serializeFunctions
- , 0, this.ignoreUndefined);
-
- // Document is larger than maxBsonObjectSize, terminate serialization
- if(buffer.length > this.ismaster.maxBsonObjectSize) {
- throw new MongoError("Document exceeds maximum allowed bson size of " + this.ismaster.maxBsonObjectSize + " bytes");
- }
-
- // Add to total length of wire protocol message
- totalLength = totalLength + buffer.length;
- // Add to buffer
- buffers.push(buffer);
- }
-
- // Command is larger than maxMessageSizeBytes terminate serialization
- if(totalLength > this.ismaster.maxMessageSizeBytes) {
- throw new MongoError("Command exceeds maximum message size of " + this.ismaster.maxMessageSizeBytes + " bytes");
- }
-
- // Add all the metadata
- var index = 0;
-
- // Write header length
- header[index + 3] = (totalLength >> 24) & 0xff;
- header[index + 2] = (totalLength >> 16) & 0xff;
- header[index + 1] = (totalLength >> 8) & 0xff;
- header[index] = (totalLength) & 0xff;
- index = index + 4;
-
- // Write header requestId
- header[index + 3] = (this.requestId >> 24) & 0xff;
- header[index + 2] = (this.requestId >> 16) & 0xff;
- header[index + 1] = (this.requestId >> 8) & 0xff;
- header[index] = (this.requestId) & 0xff;
- index = index + 4;
-
- // No flags
- header[index + 3] = (0 >> 24) & 0xff;
- header[index + 2] = (0 >> 16) & 0xff;
- header[index + 1] = (0 >> 8) & 0xff;
- header[index] = (0) & 0xff;
- index = index + 4;
-
- // Operation
- header[index + 3] = (OP_INSERT >> 24) & 0xff;
- header[index + 2] = (OP_INSERT >> 16) & 0xff;
- header[index + 1] = (OP_INSERT >> 8) & 0xff;
- header[index] = (OP_INSERT) & 0xff;
- index = index + 4;
-
- // Flags
- header[index + 3] = (this.flags >> 24) & 0xff;
- header[index + 2] = (this.flags >> 16) & 0xff;
- header[index + 1] = (this.flags >> 8) & 0xff;
- header[index] = (this.flags) & 0xff;
- index = index + 4;
-
- // Write collection name
- index = index + header.write(this.ns, index, 'utf8') + 1;
- header[index - 1] = 0;
-
- // Return the buffers
- return buffers;
-}
-
-var Update = function(requestId, ismaster, bson, ns, update, options) {
- // Basic options needed to be passed in
- if(ns == null) throw new MongoError("ns must be specified for query");
-
- // Ensure empty options
- options = options || {};
-
- // Set internal
- this.requestId = requestId;
- this.bson = bson;
- this.ns = ns;
- this.ismaster = ismaster;
-
- // Unpack options
- this.serializeFunctions = typeof options.serializeFunctions == 'boolean' ? options.serializeFunctions : false;
- this.ignoreUndefined = typeof options.ignoreUndefined == 'boolean' ? options.ignoreUndefined : false;
- this.checkKeys = typeof options.checkKeys == 'boolean' ? options.checkKeys : false;
-
- // Unpack the update document
- this.upsert = typeof update[0].upsert == 'boolean' ? update[0].upsert : false;
- this.multi = typeof update[0].multi == 'boolean' ? update[0].multi : false;
- this.q = update[0].q;
- this.u = update[0].u;
-
- // Create flag value
- this.flags = this.upsert ? 1 : 0;
- this.flags = this.multi ? this.flags | 2 : this.flags;
-}
-
-// To Binary
-Update.prototype.toBin = function() {
- // Contains all the buffers to be written
- var buffers = [];
-
- // Header buffer
- var header = new Buffer(
- 4 * 4 // Header
- + 4 // ZERO
- + Buffer.byteLength(this.ns) + 1 // namespace
- + 4 // Flags
- );
-
- // Add header to buffers
- buffers.push(header);
-
- // Total length of the message
- var totalLength = header.length;
-
- // Serialize the selector
- var selector = this.bson.serialize(this.q
- , this.checkKeys
- , true
- , this.serializeFunctions
- , 0, this.ignoreUndefined);
- buffers.push(selector);
- totalLength = totalLength + selector.length;
-
- // Serialize the update
- var update = this.bson.serialize(this.u
- , this.checkKeys
- , true
- , this.serializeFunctions
- , 0, this.ignoreUndefined);
- buffers.push(update);
- totalLength = totalLength + update.length;
-
- // Index in header buffer
- var index = 0;
-
- // Write header length
- header[index + 3] = (totalLength >> 24) & 0xff;
- header[index + 2] = (totalLength >> 16) & 0xff;
- header[index + 1] = (totalLength >> 8) & 0xff;
- header[index] = (totalLength) & 0xff;
- index = index + 4;
-
- // Write header requestId
- header[index + 3] = (this.requestId >> 24) & 0xff;
- header[index + 2] = (this.requestId >> 16) & 0xff;
- header[index + 1] = (this.requestId >> 8) & 0xff;
- header[index] = (this.requestId) & 0xff;
- index = index + 4;
-
- // No flags
- header[index + 3] = (0 >> 24) & 0xff;
- header[index + 2] = (0 >> 16) & 0xff;
- header[index + 1] = (0 >> 8) & 0xff;
- header[index] = (0) & 0xff;
- index = index + 4;
-
- // Operation
- header[index + 3] = (OP_UPDATE >> 24) & 0xff;
- header[index + 2] = (OP_UPDATE >> 16) & 0xff;
- header[index + 1] = (OP_UPDATE >> 8) & 0xff;
- header[index] = (OP_UPDATE) & 0xff;
- index = index + 4;
-
- // Write ZERO
- header[index + 3] = (0 >> 24) & 0xff;
- header[index + 2] = (0 >> 16) & 0xff;
- header[index + 1] = (0 >> 8) & 0xff;
- header[index] = (0) & 0xff;
- index = index + 4;
-
- // Write collection name
- index = index + header.write(this.ns, index, 'utf8') + 1;
- header[index - 1] = 0;
-
- // Flags
- header[index + 3] = (this.flags >> 24) & 0xff;
- header[index + 2] = (this.flags >> 16) & 0xff;
- header[index + 1] = (this.flags >> 8) & 0xff;
- header[index] = (this.flags) & 0xff;
- index = index + 4;
-
- // Return the buffers
- return buffers;
-}
-
-var Remove = function(requestId, ismaster, bson, ns, remove, options) {
- // Basic options needed to be passed in
- if(ns == null) throw new MongoError("ns must be specified for query");
-
- // Ensure empty options
- options = options || {};
-
- // Set internal
- this.requestId = requestId;
- this.bson = bson;
- this.ns = ns;
- this.ismaster = ismaster;
-
- // Unpack options
- this.serializeFunctions = typeof options.serializeFunctions == 'boolean' ? options.serializeFunctions : false;
- this.ignoreUndefined = typeof options.ignoreUndefined == 'boolean' ? options.ignoreUndefined : false;
- this.checkKeys = typeof options.checkKeys == 'boolean' ? options.checkKeys : false;
-
- // Unpack the update document
- this.limit = typeof remove[0].limit == 'number' ? remove[0].limit : 1;
- this.q = remove[0].q;
-
- // Create flag value
- this.flags = this.limit == 1 ? 1 : 0;
-}
-
-// To Binary
-Remove.prototype.toBin = function() {
- // Contains all the buffers to be written
- var buffers = [];
-
- // Header buffer
- var header = new Buffer(
- 4 * 4 // Header
- + 4 // ZERO
- + Buffer.byteLength(this.ns) + 1 // namespace
- + 4 // Flags
- );
-
- // Add header to buffers
- buffers.push(header);
-
- // Total length of the message
- var totalLength = header.length;
-
- // Serialize the selector
- var selector = this.bson.serialize(this.q
- , this.checkKeys
- , true
- , this.serializeFunctions
- , 0, this.ignoreUndefined);
- buffers.push(selector);
- totalLength = totalLength + selector.length;
-
- // Index in header buffer
- var index = 0;
-
- // Write header length
- header[index + 3] = (totalLength >> 24) & 0xff;
- header[index + 2] = (totalLength >> 16) & 0xff;
- header[index + 1] = (totalLength >> 8) & 0xff;
- header[index] = (totalLength) & 0xff;
- index = index + 4;
-
- // Write header requestId
- header[index + 3] = (this.requestId >> 24) & 0xff;
- header[index + 2] = (this.requestId >> 16) & 0xff;
- header[index + 1] = (this.requestId >> 8) & 0xff;
- header[index] = (this.requestId) & 0xff;
- index = index + 4;
-
- // No flags
- header[index + 3] = (0 >> 24) & 0xff;
- header[index + 2] = (0 >> 16) & 0xff;
- header[index + 1] = (0 >> 8) & 0xff;
- header[index] = (0) & 0xff;
- index = index + 4;
-
- // Operation
- header[index + 3] = (OP_DELETE >> 24) & 0xff;
- header[index + 2] = (OP_DELETE >> 16) & 0xff;
- header[index + 1] = (OP_DELETE >> 8) & 0xff;
- header[index] = (OP_DELETE) & 0xff;
- index = index + 4;
-
- // Write ZERO
- header[index + 3] = (0 >> 24) & 0xff;
- header[index + 2] = (0 >> 16) & 0xff;
- header[index + 1] = (0 >> 8) & 0xff;
- header[index] = (0) & 0xff;
- index = index + 4;
-
- // Write collection name
- index = index + header.write(this.ns, index, 'utf8') + 1;
- header[index - 1] = 0;
-
- // Write ZERO
- header[index + 3] = (this.flags >> 24) & 0xff;
- header[index + 2] = (this.flags >> 16) & 0xff;
- header[index + 1] = (this.flags >> 8) & 0xff;
- header[index] = (this.flags) & 0xff;
- index = index + 4;
-
- // Return the buffers
- return buffers;
-}
-
-module.exports = {
- Insert: Insert
- , Update: Update
- , Remove: Remove
-}
generated by cgit v1.2.3 (git 2.25.1) at 2026-08-02 08:47:11 +0000