/** * Tests that oplog writes are forbidden on replica set members. In standalone mode, it is permitted * to insert oplog entries, which will be applied during replication recovery. This behavior is * needed for point-in-time restores, which are supported on 4.2+. * @tags: [ * requires_persistence, * requires_replication, * ] */ (function() { "use strict"; const rst = new ReplSetTest({nodes: 1}); rst.startSet(); rst.initiateWithHighElectionTimeout(); let conn = rst.getPrimary(); assert.commandWorked( conn.getDB("test").coll.insert({_id: 0, a: 0}, {writeConcern: {w: "majority"}})); let oplog = conn.getDB("local").oplog.rs; // Construct a valid oplog entry. function constructOplogEntry(oplog) { const lastOplogEntry = oplog.find().sort({ts: -1}).limit(1).toArray()[0]; const testCollOplogEntry = oplog.find({op: "i", ns: "test.coll"}).sort({ts: -1}).limit(1).toArray()[0]; const highestTS = lastOplogEntry.ts; const toInsertTS = Timestamp(highestTS.getTime(), highestTS.getInc() + 1); return Object.extend( testCollOplogEntry, {op: "u", ns: "test.coll", o: {$set: {a: 1}}, o2: {_id: 0}, ts: toInsertTS}); } let toInsert = constructOplogEntry(oplog); jsTestLog("Test that oplog writes are banned when replication is enabled."); assert.commandFailedWithCode(oplog.insert(toInsert), ErrorCodes.InvalidNamespace); jsTestLog("Restart the node in standalone mode."); rst.stop(0, undefined /*signal*/, undefined /*opts*/, {forRestart: true}); conn = rst.start(0, {noReplSet: true, noCleanData: true}); oplog = conn.getDB("local").oplog.rs; // Construct a valid oplog entry using the highest timestamp in the oplog. The highest timestamp may // differ from the one above due to concurrent internal writes when the node was a primary. toInsert = constructOplogEntry(oplog); jsTestLog(`Test that oplog writes are permitted in standalone mode. Inserting oplog entry: ${ tojson(toInsert)}`); assert.commandWorked(oplog.insert(toInsert)); jsTestLog("Restart the node with replication enabled."); rst.stop(0, undefined /*signal*/, undefined /*opts*/, {forRestart: true}); rst.start(0, {noCleanData: true}); conn = rst.getPrimary(); jsTestLog("The added oplog entry is applied as part of replication recovery."); assert.eq({_id: 0, a: 1}, conn.getDB("test").coll.findOne()); rst.stopSet(); }());