// Term counter should be present in oplog entries under protocol version 1. import {ReplSetTest} from "jstests/libs/replsettest.js"; import {getLatestOp} from "jstests/replsets/rslib.js"; let name = "oplog_term"; let replSet = new ReplSetTest({name: name, nodes: 1}); replSet.startSet(); replSet.initiate(); replSet.waitForState(replSet.nodes[0], ReplSetTest.State.PRIMARY, 5 * 1000); // Default protocol version is 1 - 'term' field should present in oplog entry. let primary = replSet.getPrimary(); let collection = primary.getDB("test").getCollection(name); assert.commandWorked(collection.save({_id: 1})); let oplogEntry = getLatestOp(primary); assert(oplogEntry, "unexpected empty oplog"); assert.eq(collection.getFullName(), oplogEntry.ns, "unexpected namespace in oplog entry: " + tojson(oplogEntry)); assert.eq(1, oplogEntry.o._id, "oplog entry does not refer to most recently inserted document: " + tojson(oplogEntry)); assert(oplogEntry.hasOwnProperty("t"), "oplog entry must contain term: " + tojson(oplogEntry)); let status = assert.commandWorked(primary.adminCommand({replSetGetStatus: 1})); assert.eq(status.term, oplogEntry.t, "term in oplog entry does not match term in status: " + tojson(oplogEntry)); replSet.stopSet();