/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.solr.cloud;

import org.apache.solr.client.solrj.embedded.JettySolrRunner;
import org.apache.solr.client.solrj.impl.CloudSolrClient;
import org.apache.solr.client.solrj.request.CollectionAdminRequest;
import org.apache.solr.common.cloud.Replica;
import org.apache.solr.util.TestInjection;
import org.junit.BeforeClass;
import org.junit.Test;

/**
 * Tests for PREPRECOVERY CoreAdmin API
 */
public class TestPrepRecovery extends SolrCloudTestCase {

  @BeforeClass
  public static void setupCluster() throws Exception {
    System.setProperty("solr.directoryFactory", "solr.StandardDirectoryFactory");
    System.setProperty("solr.ulog.numRecordsToKeep", "1000");
    // the default is 180s and our waitForState times out in 90s
    // so we lower this to 10s so that we can still test timeouts
    System.setProperty("leaderConflictResolveWait", "10000");

    configureCluster(2)
        .addConfig("config", TEST_PATH().resolve("configsets").resolve("cloud-minimal").resolve("conf"))
        .withSolrXml(TEST_PATH().resolve("solr.xml"))
        .configure();
  }

  public static void tearCluster() throws Exception {
    System.clearProperty("leaderConflictResolveWait");
  }

  @Test
// 12-Jun-2018   @BadApple(bugUrl="https://issues.apache.org/jira/browse/SOLR-12028")
  public void testLeaderUnloaded() throws Exception {
    CloudSolrClient solrClient = cluster.getSolrClient();

    String collectionName = "testLeaderUnloaded";
    CollectionAdminRequest.createCollection(collectionName, 1, 2)
        .process(solrClient);

    waitForState("Expected collection: testLeaderUnloaded to be live with 1 shard and 2 replicas",
        collectionName, clusterShape(1, 2));

    JettySolrRunner newNode = cluster.startJettySolrRunner();
    String newNodeName = newNode.getNodeName();

    // add a replica to the new node so that it starts watching the collection
    CollectionAdminRequest.addReplicaToShard(collectionName, "shard1")
        .setNode(newNodeName)
        .process(solrClient);

    // now delete the leader
    Replica leader = solrClient.getZkStateReader().getLeaderRetry(collectionName, "shard1");
    CollectionAdminRequest.deleteReplica(collectionName, "shard1", leader.getName())
        .process(solrClient);

    // add another replica to the new node. When it starts recovering, it will likely have stale state
    // and ask the erstwhile leader to PREPRECOVERY which will hang for about 30 seconds
    CollectionAdminRequest.addReplicaToShard(collectionName, "shard1")
        .setNode(newNodeName)
        .process(solrClient);

    // in the absence of the fixes made in SOLR-10914, this statement will timeout after 90s
    waitForState("Expected collection: testLeaderUnloaded to be live with 1 shard and 3 replicas",
        collectionName, clusterShape(1, 3));
  }

  @Test
  // 12-Jun-2018 @BadApple(bugUrl="https://issues.apache.org/jira/browse/SOLR-12028")
  public void testLeaderNotResponding() throws Exception {
    CloudSolrClient solrClient = cluster.getSolrClient();

    String collectionName = "testLeaderNotResponding";
    CollectionAdminRequest.createCollection(collectionName, 1, 1)
        .process(solrClient);

    waitForState("Expected collection: testLeaderNotResponding to be live with 1 shard and 1 replicas",
        collectionName, clusterShape(1, 1));

    TestInjection.prepRecoveryOpPauseForever = "true:100";
    try {
      CollectionAdminRequest.addReplicaToShard(collectionName, "shard1")
          .process(solrClient);

      // in the absence of fixes made in SOLR-9716, prep recovery waits forever and the following statement
      // times out in 90 seconds
      waitForState("Expected collection: testLeaderNotResponding to be live with 1 shard and 2 replicas",
          collectionName, clusterShape(1, 2));
    } finally {
      TestInjection.reset();
    }
  }
}