@@ -76,12 +76,10 @@ export class OpQueryRequest {
76
76
partial : boolean ;
77
77
/** moreToCome is an OP_MSG only concept */
78
78
moreToCome = false ;
79
+ databaseName : string ;
80
+ query : Document ;
79
81
80
- constructor (
81
- public databaseName : string ,
82
- public query : Document ,
83
- options : OpQueryOptions
84
- ) {
82
+ constructor ( databaseName : string , query : Document , options : OpQueryOptions ) {
85
83
// Basic options needed to be passed in
86
84
// TODO(NODE-3483): Replace with MongoCommandError
87
85
const ns = `${ databaseName } .$cmd` ;
@@ -97,7 +95,9 @@ export class OpQueryRequest {
97
95
throw new MongoRuntimeError ( 'Namespace cannot contain a null character' ) ;
98
96
}
99
97
100
- // Basic options
98
+ // Basic optionsa
99
+ this . databaseName = databaseName ;
100
+ this . query = query ;
101
101
this . ns = ns ;
102
102
103
103
// Additional options
@@ -496,17 +496,18 @@ export class OpMsgRequest {
496
496
checksumPresent : boolean ;
497
497
moreToCome : boolean ;
498
498
exhaustAllowed : boolean ;
499
+ databaseName : string ;
500
+ command : Document ;
501
+ options : OpQueryOptions ;
499
502
500
- constructor (
501
- public databaseName : string ,
502
- public command : Document ,
503
- public options : OpQueryOptions
504
- ) {
503
+ constructor ( databaseName : string , command : Document , options : OpQueryOptions ) {
505
504
// Basic options needed to be passed in
506
505
if ( command == null )
507
506
throw new MongoInvalidArgumentError ( 'Query document must be specified for query' ) ;
508
507
509
- // Basic options
508
+ // Basic optionsa
509
+ this . databaseName = databaseName ;
510
+ this . command = command ;
510
511
this . command . $db = databaseName ;
511
512
512
513
// Ensure empty options
@@ -730,10 +731,19 @@ const COMPRESSION_DETAILS_SIZE = 9; // originalOpcode + uncompressedSize, compre
730
731
* An OP_COMPRESSED request wraps either an OP_QUERY or OP_MSG message.
731
732
*/
732
733
export class OpCompressedRequest {
734
+ private command : WriteProtocolMessageType ;
735
+ private options : { zLibCompressionLevel : number ; agreedCompressor : CompressorName } ;
736
+
733
737
constructor (
734
- private command : WriteProtocolMessageType ,
735
- private options : { zlibCompressionLevel : number ; agreedCompressor : CompressorName }
736
- ) { }
738
+ command : WriteProtocolMessageType ,
739
+ options : { zlibCompressionLevel : number ; agreedCompressor : CompressorName }
740
+ ) {
741
+ this . command = command ;
742
+ this . options = {
743
+ zLibCompressionLevel : options . zlibCompressionLevel ,
744
+ agreedCompressor : options . agreedCompressor
745
+ } ;
746
+ }
737
747
738
748
// Return whether a command contains an uncompressible command term
739
749
// Will return true if command contains no uncompressible command terms
@@ -752,7 +762,13 @@ export class OpCompressedRequest {
752
762
const originalCommandOpCode = concatenatedOriginalCommandBuffer . readInt32LE ( 12 ) ;
753
763
754
764
// Compress the message body
755
- const compressedMessage = await compress ( this . options , messageToBeCompressed ) ;
765
+ const compressedMessage = await compress (
766
+ {
767
+ zlibCompressionLevel : this . options . zLibCompressionLevel ,
768
+ agreedCompressor : this . options . agreedCompressor
769
+ } ,
770
+ messageToBeCompressed
771
+ ) ;
756
772
// Create the msgHeader of OP_COMPRESSED
757
773
const msgHeader = Buffer . alloc ( MESSAGE_HEADER_SIZE ) ;
758
774
msgHeader . writeInt32LE (
0 commit comments