/*
 * Copyright Hyperledger Besu Contributors.
 *
 * Licensed 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.
 *
 * SPDX-License-Identifier: Apache-2.0
 */
package org.hyperledger.besu.ethstats.util;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;

import java.nio.file.Path;

import org.junit.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.ValueSource;

public class EthStatsConnectOptionsTest {

  private final String VALID_NETSTATS_URL = "Dev-Node-1:secret-with-dashes@127.0.0.1:3001";

  private final String CONTACT = "contact@mail.fr";

  private final String ERROR_MESSAGE =
      "Invalid ethstats URL syntax. Ethstats URL should have the following format '[ws://|wss://]nodename:secret@host[:port]'.";

  @Test
  public void buildWithValidParams() {
    final Path caCert = Path.of("./test.pem");
    final EthStatsConnectOptions ethStatsConnectOptions =
        EthStatsConnectOptions.fromParams(VALID_NETSTATS_URL, CONTACT, caCert);
    assertThat(ethStatsConnectOptions.getScheme()).isNull();
    assertThat(ethStatsConnectOptions.getHost()).isEqualTo("127.0.0.1");
    assertThat(ethStatsConnectOptions.getNodeName()).isEqualTo("Dev-Node-1");
    assertThat(ethStatsConnectOptions.getPort()).isEqualTo(3001);
    assertThat(ethStatsConnectOptions.getSecret()).isEqualTo("secret-with-dashes");
    assertThat(ethStatsConnectOptions.getContact()).isEqualTo(CONTACT);
    assertThat(ethStatsConnectOptions.getCaCert()).isEqualTo(caCert);
  }

  @ParameterizedTest(name = "#{index} - With Host {0}")
  @ValueSource(strings = {"url-test.test.com", "url.test.com", "test.com", "10.10.10.15"})
  public void buildWithValidHost(final String host) {
    final EthStatsConnectOptions ethStatsConnectOptions =
        EthStatsConnectOptions.fromParams("Dev-Node-1:secret@" + host + ":3001", CONTACT, null);
    assertThat(ethStatsConnectOptions.getScheme()).isNull();
    assertThat(ethStatsConnectOptions.getHost()).isEqualTo(host);
    assertThat(ethStatsConnectOptions.getPort()).isEqualTo(3001);
  }

  @ParameterizedTest(name = "#{index} - With Host {0}")
  @ValueSource(strings = {"url-test.test.com", "url.test.com", "test.com", "10.10.10.15"})
  public void buildWithValidHostWithoutPort(final String host) {
    final EthStatsConnectOptions ethStatsConnectOptions =
        EthStatsConnectOptions.fromParams("Dev-Node-1:secret@" + host, CONTACT, null);
    assertThat(ethStatsConnectOptions.getScheme()).isNull();
    assertThat(ethStatsConnectOptions.getHost()).isEqualTo(host);
    assertThat(ethStatsConnectOptions.getPort()).isEqualTo(-1);
  }

  @ParameterizedTest(name = "#{index} - With Scheme {0}")
  @ValueSource(strings = {"ws", "wss", "WSS", "WS"})
  public void buildWithValidScheme(final String scheme) {
    final EthStatsConnectOptions ethStatsConnectOptions =
        EthStatsConnectOptions.fromParams(
            scheme + "://Dev-Node-1:secret@url-test.test.com:3001", CONTACT, null);
    assertThat(ethStatsConnectOptions.getScheme()).isEqualTo(scheme);
    assertThat(ethStatsConnectOptions.getHost()).isEqualTo("url-test.test.com");
    assertThat(ethStatsConnectOptions.getPort()).isEqualTo(3001);
  }

  @ParameterizedTest(name = "#{index} - With Scheme {0}")
  @ValueSource(strings = {"http", "https", "ftp"})
  public void shouldRaiseErrorOnInvalidScheme(final String scheme) {
    // missing node name
    assertThatThrownBy(
            () ->
                EthStatsConnectOptions.fromParams(
                    scheme + "://Dev-Node-1:secret@url-test.test.com:3001", CONTACT, null))
        .isInstanceOf(IllegalArgumentException.class)
        .hasMessageEndingWith(ERROR_MESSAGE);
  }

  @Test
  public void shouldDetectEmptyParams() {
    assertThatThrownBy(() -> EthStatsConnectOptions.fromParams("", CONTACT, null))
        .isInstanceOf(IllegalArgumentException.class)
        .hasMessageEndingWith(ERROR_MESSAGE);
  }

  @Test
  public void shouldDetectMissingParams() {
    // missing node name
    assertThatThrownBy(
            () -> EthStatsConnectOptions.fromParams("secret@127.0.0.1:3001", CONTACT, null))
        .isInstanceOf(IllegalArgumentException.class)
        .hasMessageEndingWith(ERROR_MESSAGE);

    // missing host
    assertThatThrownBy(() -> EthStatsConnectOptions.fromParams("Dev-Node-1:secret@", CONTACT, null))
        .isInstanceOf(IllegalArgumentException.class)
        .hasMessageEndingWith(ERROR_MESSAGE);

    // missing port in URL should default to -1
    EthStatsConnectOptions ethStatsConnectOptions =
        EthStatsConnectOptions.fromParams("Dev-Node-1:secret@127.0.0.1:", CONTACT, null);
    assertThat(ethStatsConnectOptions.getPort()).isEqualTo(-1);
  }

  @Test
  public void shouldDetectInvalidParams() {
    // invalid host
    assertThatThrownBy(
            () ->
                EthStatsConnectOptions.fromParams(
                    "Dev-Node-1:secret@127.0@0.1:3001", CONTACT, null))
        .isInstanceOf(IllegalArgumentException.class)
        .hasMessageEndingWith(ERROR_MESSAGE);

    // invalid port
    assertThatThrownBy(
            () ->
                EthStatsConnectOptions.fromParams(
                    "Dev-Node-1:secret@127.0.0.1:A001", CONTACT, null))
        .isInstanceOf(IllegalArgumentException.class)
        .hasMessageEndingWith(ERROR_MESSAGE);
  }
}
