load("jstests/replsets/rslib.js");

// Tests that the replica set's term increases once per election, and persists across a restart of
// the entire set.
//
// If all data-bearing nodes in a replica set are using an ephemeral storage engine, the set will
// not be able to survive a scenario where all data-bearing nodes are down simultaneously. In such a
// scenario, none of the members will have any replica set configuration document after a restart,
// so cannot elect a primary. This test induces such a scenario, so cannot be run on ephemeral
// storage engines.
// @tags: [requires_persistence]
(function() {
    "use strict";

    function getCurrentTerm(primary) {
        var res = primary.adminCommand({replSetGetStatus: 1});
        assert.commandWorked(res);
        return res.term;
    }

    var name = "restore_term";
    var rst = new ReplSetTest({name: name, nodes: 2});

    rst.startSet();
    // Initiate the replset in protocol version 1.
    var conf = rst.getReplSetConfig();
    conf.settings = conf.settings || {};
    conf.settings.electionTimeoutMillis = 2000;
    conf.protocolVersion = 1;
    rst.initiate(conf);
    rst.awaitSecondaryNodes();

    var primary = rst.getPrimary();
    var primaryColl = primary.getDB("test").coll;

    // Current term may be greater than 1 if election race happens.
    var firstSuccessfulTerm = getCurrentTerm(primary);
    assert.gte(firstSuccessfulTerm, 1);
    assert.writeOK(primaryColl.insert({x: 1}, {writeConcern: {w: "majority"}}));
    assert.eq(getCurrentTerm(primary), firstSuccessfulTerm);

    // Check that the insert op has the initial term.
    var latestOp = getLatestOp(primary);
    assert.eq(latestOp.op, "i");
    assert.eq(latestOp.t, firstSuccessfulTerm);

    // Step down to increase the term.
    try {
        var res = primary.adminCommand({replSetStepDown: 0});
    } catch (err) {
        print("caught: " + err + " on stepdown");
    }
    rst.awaitSecondaryNodes();
    // The secondary became the new primary now with a higher term.
    // Since there's only one secondary who may run for election, the new term is higher by 1.
    assert.eq(getCurrentTerm(rst.getPrimary()), firstSuccessfulTerm + 1);

    // Restart the replset and verify the term is the same.
    rst.stopSet(null /* signal */, true /* forRestart */);
    rst.startSet({restart: true});
    rst.awaitSecondaryNodes();
    primary = rst.getPrimary();

    assert.eq(primary.getDB("test").coll.find().itcount(), 1);
    // After restart, the new primary stands up with the newer term.
    assert.gte(getCurrentTerm(primary), firstSuccessfulTerm + 1);

})();