readConcern

lib/helpers/schema/applyReadConcern.js

@@ -0,0 +1,27 @@
+'use strict';
+
+const get = require('../get');
+
+module.exports = function applyReadConcern(schema, options) {
+  if (options.readConcern != null) {
+    return;
+  }
+  // Don't apply default write concern to operations in transactions,
+  // because setting write concern on an operation in a transaction is an error
+  // See: https://www.mongodb.com/docs/manual/reference/write-concern/
+  if (options && options.session && options.session.transaction) {
+    return;
+  }
+  const readConcern = get(schema, 'options.readConcern', {});
+  if (Object.keys(readConcern).length != 0) {
+    options.readConcern = {};
+    if (!('majority' in options) && readConcern.level != null) {
+      options.readConcern.level = readConcern.level;
+    }
+  }
+  else {
+    if (!('majority' in options) && readConcern.level != null) {
+      options.readConcern.level = readConcern.level;
+    }
+  }
+};

lib/helpers/schema/applyWriteConcern.js

@@ -25,15 +25,4 @@ module.exports = function applyWriteConcern(schema, options) {
       options.writeConcern.wtimeout = writeConcern.wtimeout;
     }
   }
-  else {
-    if (!('w' in options) && writeConcern.w != null) {
-      options.w = writeConcern.w;
-    }
-    if (!('j' in options) && writeConcern.j != null) {
-      options.j = writeConcern.j;
-    }
-    if (!('wtimeout' in options) && writeConcern.wtimeout != null) {
-      options.wtimeout = writeConcern.wtimeout;
-    }
-  }
 };

lib/model.js

@@ -68,6 +68,7 @@ const util = require('util');
 const utils = require('./utils');
 const MongooseBulkWriteError = require('./error/bulkWriteError');
 const minimize = require('./helpers/minimize');
+const applyReadConcern = require('./helpers/schema/applyReadConcern');
 
 const VERSION_WHERE = 1;
 const VERSION_INC = 2;
@@ -1982,6 +1983,7 @@ function _ensureIndexes(model, options, callback) {
     delete indexOptions._autoIndex;
     decorateDiscriminatorIndexOptions(model.schema, indexOptions);
     applyWriteConcern(model.schema, indexOptions);
+    applyReadConcern(model.schema, indexOptions);
     applySchemaCollation(indexFields, indexOptions, model.schema.options);
 
     indexSingleStart(indexFields, options);

lib/query.js

@@ -39,6 +39,7 @@ const specialProperties = require('./helpers/specialProperties');
 const updateValidators = require('./helpers/updateValidators');
 const util = require('util');
 const utils = require('./utils');
+const applyReadConcern = require('./helpers/schema/applyReadConcern');
 const queryMiddlewareFunctions = require('./constants').queryMiddlewareFunctions;
 
 const queryOptionMethods = new Set([
@@ -1946,7 +1947,7 @@ Query.prototype._optionsForExec = function(model) {
   }
   // Apply schema-level `writeConcern` option
   applyWriteConcern(model.schema, options);
-
+  applyReadConcern(model.schema, options);
   const readPreference = model &&
   model.schema &&
   model.schema.options &&

test/helpers/applyReadConcern.test.js

@@ -0,0 +1,22 @@
+'use strict';
+
+const assert = require('assert');
+const applyReadConcern = require('../../lib/helpers/schema/applyReadConcern');
+const start = require('../common');
+const mongoose = start.mongoose;
+
+describe('applyReadConcern', function() {
+  let db;
+  before(function() {
+    db = start();
+  });
+  after(async function() {
+    await db.close();
+  });
+  it('should not overwrite user specified read options (gh-14511)', async function() {
+    const options = { readConcern: { level: 'majority' } };
+    const testSchema = new mongoose.Schema({ name: String }, { readConcern: { level: 'majority ' } });
+    applyReadConcern(testSchema, options);
+    assert.deepStrictEqual({ readConcern: { level: 'majority' } }, options);
+  });
+});

test/query.test.js

@@ -1221,6 +1221,23 @@ describe('Query', function() {
       });
     });
 
+    it('applies schema-level readConcern option', function() {
+      const q = new Query();
+
+      const options = q._optionsForExec({
+        schema: {
+          options: {
+            readConcern: { level: 'majority' }
+          }
+        }
+      });
+      assert.deepEqual(options, {
+        readConcern: {
+          level: 'majority'
+        }
+      });
+    });
+
     it('session() (gh-6663)', function() {
       const q = new Query();
 
@@ -3412,6 +3429,18 @@ describe('Query', function() {
 
     assert.deepEqual(q.options.writeConcern, { w: 'majority', wtimeout: 1000 });
   });
+
+  it('sets `readConcer` option correctly (gh-14511)', function() {
+    const testSchema = new mongoose.Schema({
+      name: String
+    });
+    const Test = db.model('Test', testSchema);
+
+    const q = Test.find();
+    q.readConcern({ level: 'majority' });
+
+    assert.deepEqual(q.options.readConcern, { level: 'majority' });
+  });
   it('no longer has the deprecation warning message with writeConcern gh-10083', async function() {
     const MySchema = new mongoose.Schema(
       {