aboutsummaryrefslogtreecommitdiff
path: root/node_modules/mongodb-core/lib/connection/commands.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/mongodb-core/lib/connection/commands.js')
-rw-r--r--node_modules/mongodb-core/lib/connection/commands.js539
1 files changed, 0 insertions, 539 deletions
diff --git a/node_modules/mongodb-core/lib/connection/commands.js b/node_modules/mongodb-core/lib/connection/commands.js
deleted file mode 100644
index dba0d1e..0000000
--- a/node_modules/mongodb-core/lib/connection/commands.js
+++ /dev/null
@@ -1,539 +0,0 @@
-"use strict";
-
-var f = require('util').format
- , Long = require('bson').Long
- , setProperty = require('./utils').setProperty
- , getProperty = require('./utils').getProperty
- , getSingleProperty = require('./utils').getSingleProperty;
-
-// Incrementing request id
-var _requestId = 0;
-
-// Wire command operation ids
-var OP_QUERY = 2004;
-var OP_GETMORE = 2005;
-var OP_KILL_CURSORS = 2007;
-
-// Query flags
-var OPTS_NONE = 0;
-var OPTS_TAILABLE_CURSOR = 2;
-var OPTS_SLAVE = 4;
-var OPTS_OPLOG_REPLAY = 8;
-var OPTS_NO_CURSOR_TIMEOUT = 16;
-var OPTS_AWAIT_DATA = 32;
-var OPTS_EXHAUST = 64;
-var OPTS_PARTIAL = 128;
-
-// Response flags
-var CURSOR_NOT_FOUND = 0;
-var QUERY_FAILURE = 2;
-var SHARD_CONFIG_STALE = 4;
-var AWAIT_CAPABLE = 8;
-
-/**************************************************************
- * QUERY
- **************************************************************/
-var Query = function(bson, ns, query, options) {
- var self = this;
- // Basic options needed to be passed in
- if(ns == null) throw new Error("ns must be specified for query");
- if(query == null) throw new Error("query must be specified for query");
-
- // Validate that we are not passing 0x00 in the colletion name
- if(!!~ns.indexOf("\x00")) {
- throw new Error("namespace cannot contain a null character");
- }
-
- // Basic options
- this.bson = bson;
- this.ns = ns;
- this.query = query;
-
- // Ensure empty options
- this.options = options || {};
-
- // Additional options
- this.numberToSkip = options.numberToSkip || 0;
- this.numberToReturn = options.numberToReturn || 0;
- this.returnFieldSelector = options.returnFieldSelector || null;
- this.requestId = _requestId++;
-
- // Serialization option
- this.serializeFunctions = typeof options.serializeFunctions == 'boolean' ? options.serializeFunctions : false;
- this.ignoreUndefined = typeof options.ignoreUndefined == 'boolean' ? options.ignoreUndefined : false;
- this.maxBsonSize = options.maxBsonSize || 1024 * 1024 * 16;
- this.checkKeys = typeof options.checkKeys == 'boolean' ? options.checkKeys : true;
- this.batchSize = self.numberToReturn;
-
- // Flags
- this.tailable = false;
- this.slaveOk = typeof options.slaveOk == 'boolean'? options.slaveOk : false;
- this.oplogReplay = false;
- this.noCursorTimeout = false;
- this.awaitData = false;
- this.exhaust = false;
- this.partial = false;
-}
-
-//
-// Assign a new request Id
-Query.prototype.incRequestId = function() {
- this.requestId = _requestId++;
-}
-
-//
-// Assign a new request Id
-Query.nextRequestId = function() {
- return _requestId + 1;
-}
-
-//
-// Uses a single allocated buffer for the process, avoiding multiple memory allocations
-Query.prototype.toBin = function() {
- var self = this;
- var buffers = [];
- var projection = null;
-
- // Set up the flags
- var flags = 0;
- if(this.tailable) {
- flags |= OPTS_TAILABLE_CURSOR;
- }
-
- if(this.slaveOk) {
- flags |= OPTS_SLAVE;
- }
-
- if(this.oplogReplay) {
- flags |= OPTS_OPLOG_REPLAY;
- }
-
- if(this.noCursorTimeout) {
- flags |= OPTS_NO_CURSOR_TIMEOUT;
- }
-
- if(this.awaitData) {
- flags |= OPTS_AWAIT_DATA;
- }
-
- if(this.exhaust) {
- flags |= OPTS_EXHAUST;
- }
-
- if(this.partial) {
- flags |= OPTS_PARTIAL;
- }
-
- // If batchSize is different to self.numberToReturn
- if(self.batchSize != self.numberToReturn) self.numberToReturn = self.batchSize;
-
- // Allocate write protocol header buffer
- var header = new Buffer(
- 4 * 4 // Header
- + 4 // Flags
- + Buffer.byteLength(self.ns) + 1 // namespace
- + 4 // numberToSkip
- + 4 // numberToReturn
- );
-
- // Add header to buffers
- buffers.push(header);
-
- // Serialize the query
- var query = self.bson.serialize(this.query
- , this.checkKeys
- , true
- , this.serializeFunctions
- , 0, this.ignoreUndefined);
-
- // Add query document
- buffers.push(query);
-
- if(self.returnFieldSelector && Object.keys(self.returnFieldSelector).length > 0) {
- // Serialize the projection document
- projection = self.bson.serialize(this.returnFieldSelector, this.checkKeys, true, this.serializeFunctions, this.ignoreUndefined);
- // Add projection document
- buffers.push(projection);
- }
-
- // Total message size
- var totalLength = header.length + query.length + (projection ? projection.length : 0);
-
- // Set up the index
- var index = 4;
-
- // Write total document length
- header[3] = (totalLength >> 24) & 0xff;
- header[2] = (totalLength >> 16) & 0xff;
- header[1] = (totalLength >> 8) & 0xff;
- header[0] = (totalLength) & 0xff;
-
- // Write header information 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;
-
- // Write header information responseTo
- 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 header information OP_QUERY
- header[index + 3] = (OP_QUERY >> 24) & 0xff;
- header[index + 2] = (OP_QUERY >> 16) & 0xff;
- header[index + 1] = (OP_QUERY >> 8) & 0xff;
- header[index] = (OP_QUERY) & 0xff;
- index = index + 4;
-
- // Write header information flags
- header[index + 3] = (flags >> 24) & 0xff;
- header[index + 2] = (flags >> 16) & 0xff;
- header[index + 1] = (flags >> 8) & 0xff;
- header[index] = (flags) & 0xff;
- index = index + 4;
-
- // Write collection name
- index = index + header.write(this.ns, index, 'utf8') + 1;
- header[index - 1] = 0;
-
- // Write header information flags numberToSkip
- header[index + 3] = (this.numberToSkip >> 24) & 0xff;
- header[index + 2] = (this.numberToSkip >> 16) & 0xff;
- header[index + 1] = (this.numberToSkip >> 8) & 0xff;
- header[index] = (this.numberToSkip) & 0xff;
- index = index + 4;
-
- // Write header information flags numberToReturn
- header[index + 3] = (this.numberToReturn >> 24) & 0xff;
- header[index + 2] = (this.numberToReturn >> 16) & 0xff;
- header[index + 1] = (this.numberToReturn >> 8) & 0xff;
- header[index] = (this.numberToReturn) & 0xff;
- index = index + 4;
-
- // Return the buffers
- return buffers;
-}
-
-Query.getRequestId = function() {
- return ++_requestId;
-}
-
-/**************************************************************
- * GETMORE
- **************************************************************/
-var GetMore = function(bson, ns, cursorId, opts) {
- opts = opts || {};
- this.numberToReturn = opts.numberToReturn || 0;
- this.requestId = _requestId++;
- this.bson = bson;
- this.ns = ns;
- this.cursorId = cursorId;
-}
-
-//
-// Uses a single allocated buffer for the process, avoiding multiple memory allocations
-GetMore.prototype.toBin = function() {
- var length = 4 + Buffer.byteLength(this.ns) + 1 + 4 + 8 + (4 * 4);
- // Create command buffer
- var index = 0;
- // Allocate buffer
- var _buffer = new Buffer(length);
-
- // Write header information
- // index = write32bit(index, _buffer, length);
- _buffer[index + 3] = (length >> 24) & 0xff;
- _buffer[index + 2] = (length >> 16) & 0xff;
- _buffer[index + 1] = (length >> 8) & 0xff;
- _buffer[index] = (length) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, requestId);
- _buffer[index + 3] = (this.requestId >> 24) & 0xff;
- _buffer[index + 2] = (this.requestId >> 16) & 0xff;
- _buffer[index + 1] = (this.requestId >> 8) & 0xff;
- _buffer[index] = (this.requestId) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, 0);
- _buffer[index + 3] = (0 >> 24) & 0xff;
- _buffer[index + 2] = (0 >> 16) & 0xff;
- _buffer[index + 1] = (0 >> 8) & 0xff;
- _buffer[index] = (0) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, OP_GETMORE);
- _buffer[index + 3] = (OP_GETMORE >> 24) & 0xff;
- _buffer[index + 2] = (OP_GETMORE >> 16) & 0xff;
- _buffer[index + 1] = (OP_GETMORE >> 8) & 0xff;
- _buffer[index] = (OP_GETMORE) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, 0);
- _buffer[index + 3] = (0 >> 24) & 0xff;
- _buffer[index + 2] = (0 >> 16) & 0xff;
- _buffer[index + 1] = (0 >> 8) & 0xff;
- _buffer[index] = (0) & 0xff;
- index = index + 4;
-
- // Write collection name
- index = index + _buffer.write(this.ns, index, 'utf8') + 1;
- _buffer[index - 1] = 0;
-
- // Write batch size
- // index = write32bit(index, _buffer, numberToReturn);
- _buffer[index + 3] = (this.numberToReturn >> 24) & 0xff;
- _buffer[index + 2] = (this.numberToReturn >> 16) & 0xff;
- _buffer[index + 1] = (this.numberToReturn >> 8) & 0xff;
- _buffer[index] = (this.numberToReturn) & 0xff;
- index = index + 4;
-
- // Write cursor id
- // index = write32bit(index, _buffer, cursorId.getLowBits());
- _buffer[index + 3] = (this.cursorId.getLowBits() >> 24) & 0xff;
- _buffer[index + 2] = (this.cursorId.getLowBits() >> 16) & 0xff;
- _buffer[index + 1] = (this.cursorId.getLowBits() >> 8) & 0xff;
- _buffer[index] = (this.cursorId.getLowBits()) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, cursorId.getHighBits());
- _buffer[index + 3] = (this.cursorId.getHighBits() >> 24) & 0xff;
- _buffer[index + 2] = (this.cursorId.getHighBits() >> 16) & 0xff;
- _buffer[index + 1] = (this.cursorId.getHighBits() >> 8) & 0xff;
- _buffer[index] = (this.cursorId.getHighBits()) & 0xff;
- index = index + 4;
-
- // Return buffer
- return _buffer;
-}
-
-/**************************************************************
- * KILLCURSOR
- **************************************************************/
-var KillCursor = function(bson, cursorIds) {
- this.requestId = _requestId++;
- this.cursorIds = cursorIds;
-}
-
-//
-// Uses a single allocated buffer for the process, avoiding multiple memory allocations
-KillCursor.prototype.toBin = function() {
- var length = 4 + 4 + (4 * 4) + (this.cursorIds.length * 8);
-
- // Create command buffer
- var index = 0;
- var _buffer = new Buffer(length);
-
- // Write header information
- // index = write32bit(index, _buffer, length);
- _buffer[index + 3] = (length >> 24) & 0xff;
- _buffer[index + 2] = (length >> 16) & 0xff;
- _buffer[index + 1] = (length >> 8) & 0xff;
- _buffer[index] = (length) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, requestId);
- _buffer[index + 3] = (this.requestId >> 24) & 0xff;
- _buffer[index + 2] = (this.requestId >> 16) & 0xff;
- _buffer[index + 1] = (this.requestId >> 8) & 0xff;
- _buffer[index] = (this.requestId) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, 0);
- _buffer[index + 3] = (0 >> 24) & 0xff;
- _buffer[index + 2] = (0 >> 16) & 0xff;
- _buffer[index + 1] = (0 >> 8) & 0xff;
- _buffer[index] = (0) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, OP_KILL_CURSORS);
- _buffer[index + 3] = (OP_KILL_CURSORS >> 24) & 0xff;
- _buffer[index + 2] = (OP_KILL_CURSORS >> 16) & 0xff;
- _buffer[index + 1] = (OP_KILL_CURSORS >> 8) & 0xff;
- _buffer[index] = (OP_KILL_CURSORS) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, 0);
- _buffer[index + 3] = (0 >> 24) & 0xff;
- _buffer[index + 2] = (0 >> 16) & 0xff;
- _buffer[index + 1] = (0 >> 8) & 0xff;
- _buffer[index] = (0) & 0xff;
- index = index + 4;
-
- // Write batch size
- // index = write32bit(index, _buffer, this.cursorIds.length);
- _buffer[index + 3] = (this.cursorIds.length >> 24) & 0xff;
- _buffer[index + 2] = (this.cursorIds.length >> 16) & 0xff;
- _buffer[index + 1] = (this.cursorIds.length >> 8) & 0xff;
- _buffer[index] = (this.cursorIds.length) & 0xff;
- index = index + 4;
-
- // Write all the cursor ids into the array
- for(var i = 0; i < this.cursorIds.length; i++) {
- // Write cursor id
- // index = write32bit(index, _buffer, cursorIds[i].getLowBits());
- _buffer[index + 3] = (this.cursorIds[i].getLowBits() >> 24) & 0xff;
- _buffer[index + 2] = (this.cursorIds[i].getLowBits() >> 16) & 0xff;
- _buffer[index + 1] = (this.cursorIds[i].getLowBits() >> 8) & 0xff;
- _buffer[index] = (this.cursorIds[i].getLowBits()) & 0xff;
- index = index + 4;
-
- // index = write32bit(index, _buffer, cursorIds[i].getHighBits());
- _buffer[index + 3] = (this.cursorIds[i].getHighBits() >> 24) & 0xff;
- _buffer[index + 2] = (this.cursorIds[i].getHighBits() >> 16) & 0xff;
- _buffer[index + 1] = (this.cursorIds[i].getHighBits() >> 8) & 0xff;
- _buffer[index] = (this.cursorIds[i].getHighBits()) & 0xff;
- index = index + 4;
- }
-
- // Return buffer
- return _buffer;
-}
-
-var Response = function(bson, data, opts) {
- opts = opts || {promoteLongs: true};
- this.parsed = false;
-
- //
- // Parse Header
- //
- this.index = 0;
- this.raw = data;
- this.data = data;
- this.bson = bson;
- this.opts = opts;
-
- // Read the message length
- this.length = data[this.index] | data[this.index + 1] << 8 | data[this.index + 2] << 16 | data[this.index + 3] << 24;
- this.index = this.index + 4;
-
- // Fetch the request id for this reply
- this.requestId = data[this.index] | data[this.index + 1] << 8 | data[this.index + 2] << 16 | data[this.index + 3] << 24;
- this.index = this.index + 4;
-
- // Fetch the id of the request that triggered the response
- this.responseTo = data[this.index] | data[this.index + 1] << 8 | data[this.index + 2] << 16 | data[this.index + 3] << 24;
- this.index = this.index + 4;
-
- // Skip op-code field
- this.index = this.index + 4;
-
- // Unpack flags
- this.responseFlags = data[this.index] | data[this.index + 1] << 8 | data[this.index + 2] << 16 | data[this.index + 3] << 24;
- this.index = this.index + 4;
-
- // Unpack the cursor
- var lowBits = data[this.index] | data[this.index + 1] << 8 | data[this.index + 2] << 16 | data[this.index + 3] << 24;
- this.index = this.index + 4;
- var highBits = data[this.index] | data[this.index + 1] << 8 | data[this.index + 2] << 16 | data[this.index + 3] << 24;
- this.index = this.index + 4;
- // Create long object
- this.cursorId = new Long(lowBits, highBits);
-
- // Unpack the starting from
- this.startingFrom = data[this.index] | data[this.index + 1] << 8 | data[this.index + 2] << 16 | data[this.index + 3] << 24;
- this.index = this.index + 4;
-
- // Unpack the number of objects returned
- this.numberReturned = data[this.index] | data[this.index + 1] << 8 | data[this.index + 2] << 16 | data[this.index + 3] << 24;
- this.index = this.index + 4;
-
- // Preallocate document array
- this.documents = new Array(this.numberReturned);
-
- // Flag values
- this.cursorNotFound = (this.responseFlags & CURSOR_NOT_FOUND) != 0;
- this.queryFailure = (this.responseFlags & QUERY_FAILURE) != 0;
- this.shardConfigStale = (this.responseFlags & SHARD_CONFIG_STALE) != 0;
- this.awaitCapable = (this.responseFlags & AWAIT_CAPABLE) != 0;
- this.promoteLongs = typeof opts.promoteLongs == 'boolean' ? opts.promoteLongs : true;
-}
-
-Response.prototype.isParsed = function() {
- return this.parsed;
-}
-
-// Validation buffers
-var firstBatch = new Buffer('firstBatch', 'utf8');
-var nextBatch = new Buffer('nextBatch', 'utf8');
-var cursorId = new Buffer('id', 'utf8').toString('hex');
-
-var documentBuffers = {
- firstBatch: firstBatch.toString('hex'),
- nextBatch: nextBatch.toString('hex')
-};
-
-Response.prototype.parse = function(options) {
- // Don't parse again if not needed
- if(this.parsed) return;
- options = options || {};
-
- // Allow the return of raw documents instead of parsing
- var raw = options.raw || false;
- var documentsReturnedIn = options.documentsReturnedIn || null;
-
- //
- // Single document and documentsReturnedIn set
- //
- if(this.numberReturned == 1 && documentsReturnedIn != null && raw) {
- // Calculate the bson size
- var bsonSize = this.data[this.index] | this.data[this.index + 1] << 8 | this.data[this.index + 2] << 16 | this.data[this.index + 3] << 24;
- // Slice out the buffer containing the command result document
- var document = this.data.slice(this.index, this.index + bsonSize);
- // Set up field we wish to keep as raw
- var fieldsAsRaw = {}
- fieldsAsRaw[documentsReturnedIn] = true;
- // Set up the options
- var _options = {promoteLongs: this.opts.promoteLongs, fieldsAsRaw: fieldsAsRaw};
-
- // Deserialize but keep the array of documents in non-parsed form
- var doc = this.bson.deserialize(document, _options);
-
- // Get the documents
- this.documents = doc.cursor[documentsReturnedIn];
- this.numberReturned = this.documents.length;
- // Ensure we have a Long valie cursor id
- this.cursorId = typeof doc.cursor.id == 'number'
- ? Long.fromNumber(doc.cursor.id)
- : doc.cursor.id;
-
- // Adjust the index
- this.index = this.index + bsonSize;
-
- // Set as parsed
- this.parsed = true
- return;
- }
-
- //
- // Parse Body
- //
- for(var i = 0; i < this.numberReturned; i++) {
- var bsonSize = this.data[this.index] | this.data[this.index + 1] << 8 | this.data[this.index + 2] << 16 | this.data[this.index + 3] << 24;
- // Parse options
- var _options = {promoteLongs: this.opts.promoteLongs};
-
- // If we have raw results specified slice the return document
- if(raw) {
- this.documents[i] = this.data.slice(this.index, this.index + bsonSize);
- } else {
- this.documents[i] = this.bson.deserialize(this.data.slice(this.index, this.index + bsonSize), _options);
- }
-
- // Adjust the index
- this.index = this.index + bsonSize;
- }
-
- // Set parsed
- this.parsed = true;
-}
-
-module.exports = {
- Query: Query
- , GetMore: GetMore
- , Response: Response
- , KillCursor: KillCursor
-}
generated by cgit v1.2.3 (git 2.25.1) at 2026-08-02 14:04:55 +0000