/**
 * Tests that resharding succeeds even its oplog application runs on a newly elected primary of a
 * recipient shard.
 *
 * @tags: [
 *   uses_atclustertime,
 * ]
 */
(function() {
"use strict";

load("jstests/sharding/libs/resharding_test_fixture.js");

const reshardingTest = new ReshardingTest({enableElections: true});

reshardingTest.setup();

const donorShardNames = reshardingTest.donorShardNames;
const sourceCollection = reshardingTest.createShardedCollection({
    ns: "reshardingDb.coll",
    shardKeyPattern: {oldKey: 1},
    chunks: [{min: {oldKey: MinKey}, max: {oldKey: MaxKey}, shard: donorShardNames[0]}],
});

const recipientShardNames = reshardingTest.recipientShardNames;
reshardingTest.withReshardingInBackground(  //
    {
        newShardKeyPattern: {newKey: 1},
        newChunks: [{min: {newKey: MinKey}, max: {newKey: MaxKey}, shard: recipientShardNames[0]}],
    },
    () => {
        // We wait until cloneTimestamp has been chosen to guarantee that any subsequent writes will
        // be applied by the ReshardingOplogApplier.
        reshardingTest.awaitCloneTimestampChosen();

        // A secondary member of the recipient shard isn't guaranteed to know the collection
        // metadata for the temporary resharding collection. We step one up to become the new
        // primary to test that resharding succeeds even when the collection metadata must be
        // recovered from the config server.
        reshardingTest.stepUpNewPrimaryOnShard(recipientShardNames[0]);
        assert.commandWorked(sourceCollection.insert({oldKey: 1, newKey: 2}));

        reshardingTest.stepUpNewPrimaryOnShard(recipientShardNames[0]);
        assert.commandWorked(sourceCollection.update({oldKey: 1, newKey: 2}, {$set: {extra: 3}}));

        reshardingTest.stepUpNewPrimaryOnShard(recipientShardNames[0]);
        assert.commandWorked(sourceCollection.remove({oldKey: 1, newKey: 2}, {justOne: true}));
    });

reshardingTest.teardown();
})();