/*
 * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
 * or more contributor license agreements. Licensed under the "Elastic License
 * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
 * Public License v 1"; you may not use this file except in compliance with, at
 * your election, the "Elastic License 2.0", the "GNU Affero General Public
 * License v3.0 only", or the "Server Side Public License, v 1".
 */

package org.elasticsearch.cluster.coordination;

import org.elasticsearch.cluster.node.DiscoveryNode;
import org.elasticsearch.cluster.node.DiscoveryNodeUtils;
import org.elasticsearch.core.TimeValue;
import org.elasticsearch.test.ESTestCase;
import org.elasticsearch.test.EqualsHashCodeTestUtils;

import java.util.UUID;
import java.util.concurrent.TimeUnit;

public class JoinStatusTests extends ESTestCase {

    public void testSerialization() throws Exception {
        JoinStatus joinStatus = new JoinStatus(
            DiscoveryNodeUtils.create(UUID.randomUUID().toString()),
            randomLongBetween(0, 1000),
            randomAlphaOfLengthBetween(0, 100),
            randomNonNegativeTimeValue()
        );
        EqualsHashCodeTestUtils.checkEqualsAndHashCode(
            joinStatus,
            history -> copyWriteable(joinStatus, writableRegistry(), JoinStatus::new),
            this::mutateJoinStatus
        );
    }

    private JoinStatus mutateJoinStatus(JoinStatus originalJoinStatus) {
        switch (randomIntBetween(1, 4)) {
            case 1 -> {
                return new JoinStatus(
                    originalJoinStatus.remoteNode(),
                    originalJoinStatus.term() + 1,
                    originalJoinStatus.message(),
                    originalJoinStatus.age()
                );
            }
            case 2 -> {
                return new JoinStatus(
                    originalJoinStatus.remoteNode(),
                    originalJoinStatus.term(),
                    randomValueOtherThan(originalJoinStatus.message(), () -> randomAlphaOfLengthBetween(0, 30)),
                    originalJoinStatus.age()
                );
            }
            case 3 -> {
                return new JoinStatus(
                    originalJoinStatus.remoteNode(),
                    originalJoinStatus.term(),
                    originalJoinStatus.message(),
                    randomValueOtherThan(originalJoinStatus.age(), this::randomNonNegativeTimeValue)
                );
            }
            case 4 -> {
                DiscoveryNode newNode = DiscoveryNodeUtils.create(UUID.randomUUID().toString());
                return new JoinStatus(newNode, originalJoinStatus.term(), originalJoinStatus.message(), originalJoinStatus.age());
            }
            default -> throw new IllegalStateException();
        }
    }

    private TimeValue randomNonNegativeTimeValue() {
        return new TimeValue(randomIntBetween(0, 1000), randomFrom(TimeUnit.values()));
    }
}