initial commit

Author: aditi-khare-mongoDB

src/cmap/commands.ts

@@ -450,7 +450,7 @@ export class OpMsgRequest {
 
     // flags
     this.checksumPresent = false;
-    this.moreToCome = options.moreToCome || false;
+    this.moreToCome = options.moreToCome || options.writeConcern?.w === 0 || false;
     this.exhaustAllowed =
       typeof options.exhaustAllowed === 'boolean' ? options.exhaustAllowed : false;
   }

test/integration/read-write-concern/write_concern.test.ts

@@ -11,7 +11,7 @@ import {
 import * as mock from '../../tools/mongodb-mock/index';
 import { filterForCommands } from '../shared';
 
-describe('Write Concern', function () {
+describe.only('Write Concern', function () {
   context('when the WriteConcern is set in the uri', function () {
     let client;
     const events: CommandStartedEvent[] = [];
@@ -29,7 +29,8 @@ describe('Write Concern', function () {
       expect(events[0]).to.containSubset({
         commandName: 'insert',
         command: {
-          writeConcern: { w: 0 }
+          writeConcern: { w: 0 },
+          moreToCome: true
         }
       });
     });

test/unit/commands.test.ts

@@ -6,6 +6,8 @@ import * as compression from '../../src/cmap/wire_protocol/compression';
 import {
   compress,
   Compressor,
+  Connection,
+  MongoClient,
   OP_MSG,
   OP_QUERY,
   OpCompressedRequest,
@@ -109,3 +111,14 @@ describe('class OpCompressedRequest', () => {
     }
   });
 });
+
+describe.only('fire-and-forget', () => {
+  describe('OpMsgRequest', () => {
+    context('when writeConcern.w is 0', () => {
+      it('moreToCome is set to true', async () => {
+        const request = new OpMsgRequest('db', { a: 1 }, { writeConcern: { w: 0 } });
+        expect(request.moreToCome).to.be.true;
+      });
+    });
+  });
+});