/*
 * Copyright 2020 Red Hat, Inc.
 *
 * Red Hat 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 io.vertx.spi.cluster.ignite;

import io.vertx.codegen.annotations.DataObject;
import io.vertx.core.VertxException;
import io.vertx.core.json.JsonArray;
import io.vertx.core.json.JsonObject;
import org.apache.ignite.spi.discovery.DiscoverySpi;
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
import org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;

import java.util.stream.Collectors;

import static org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi.*;
import static org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder.*;

Author:
Lukas Prettenthaler/**
 * @author Lukas Prettenthaler
 */
@DataObject(generateConverter = true)
public class IgniteDiscoveryOptions {
  private String type;
  private JsonObject properties;

  
Default constructor
/**
   * Default constructor
   */
  public IgniteDiscoveryOptions() {
    type = "TcpDiscoveryMulticastIpFinder";
    properties = new JsonObject();
  }

  
Copy constructor
Params:
options – the one to copy/**
   * Copy constructor
   *
   * @param options the one to copy
   */
  public IgniteDiscoveryOptions(IgniteDiscoveryOptions options) {
    this.type = options.type;
  }

  
Constructor from JSON
Params:
options – the JSON/**
   * Constructor from JSON
   *
   * @param options the JSON
   */
  public IgniteDiscoveryOptions(JsonObject options) {
    this();
    IgniteDiscoveryOptionsConverter.fromJson(options, this);
  }

  
Get the discovery implementation type.
Returns:
Type of the implementation./**
   * Get the discovery implementation type.
   *
   * @return Type of the implementation.
   */
  public String getType() {
    return type;
  }

  
Sets the discovery implementation type.
Defaults to TcpDiscoveryMulticastIpFinder
Params:
type – Implemenation type.
Returns:
reference to this, for fluency/**
   * Sets the discovery implementation type.
   * Defaults to TcpDiscoveryMulticastIpFinder
   *
   * @param type Implemenation type.
   * @return reference to this, for fluency
   */
  public IgniteDiscoveryOptions setType(String type) {
    this.type = type;
    return this;
  }

  
Get the discovery implementation properties.
Returns:
Properties of the discovery implementation./**
   * Get the discovery implementation properties.
   *
   * @return Properties of the discovery implementation.
   */
  public JsonObject getProperties() {
    return properties;
  }

  
Sets the properties used to configure the discovery implementation.
Params:
properties – Properties for the discovery implementation.
Returns:
reference to this, for fluency/**
   * Sets the properties used to configure the discovery implementation.
   *
   * @param properties Properties for the discovery implementation.
   * @return reference to this, for fluency
   */
  public IgniteDiscoveryOptions setProperties(JsonObject properties) {
    this.properties = properties;
    return this;
  }

  
Convert to JSON
Returns:
the JSON/**
   * Convert to JSON
   *
   * @return the JSON
   */
  public JsonObject toJson() {
    JsonObject json = new JsonObject();
    IgniteDiscoveryOptionsConverter.toJson(this, json);
    return json;
  }

  
Convert to IgniteConfiguration
Returns:
the DiscoverySpi/**
   * Convert to IgniteConfiguration
   *
   * @return the DiscoverySpi
   */
  public DiscoverySpi toConfig() {
    switch (type) {
      case "TcpDiscoveryVmIpFinder":
        return new TcpDiscoverySpi()
          .setJoinTimeout(properties.getLong("joinTimeout", DFLT_JOIN_TIMEOUT))
          .setLocalAddress(properties.getString("localAddress", null))
          .setLocalPort(properties.getInteger("localPort", DFLT_PORT))
          .setLocalPortRange(properties.getInteger("localPortRange", DFLT_PORT_RANGE))
          .setIpFinder(new TcpDiscoveryVmIpFinder()
            .setAddresses(properties.getJsonArray("addresses", new JsonArray()).stream()
              .map(Object::toString)
              .collect(Collectors.toList())
            )
          );
      case "TcpDiscoveryMulticastIpFinder":
        return new TcpDiscoverySpi()
          .setJoinTimeout(properties.getLong("joinTimeout", DFLT_JOIN_TIMEOUT))
          .setLocalAddress(properties.getString("localAddress", null))
          .setLocalPort(properties.getInteger("localPort", DFLT_PORT))
          .setLocalPortRange(properties.getInteger("localPortRange", DFLT_PORT_RANGE))
          .setIpFinder(new TcpDiscoveryMulticastIpFinder()
            .setAddressRequestAttempts(properties.getInteger("addressRequestAttempts", DFLT_ADDR_REQ_ATTEMPTS))
            .setLocalAddress(properties.getString("localAddress", null))
            .setMulticastGroup(properties.getString("multicastGroup", DFLT_MCAST_GROUP))
            .setMulticastPort(properties.getInteger("multicastPort", DFLT_MCAST_PORT))
            .setResponseWaitTime(properties.getInteger("responseWaitTime", DFLT_RES_WAIT_TIME))
            .setTimeToLive(properties.getInteger("timeToLive", -1))
            .setAddresses(properties.getJsonArray("addresses", new JsonArray()).stream()
              .map(Object::toString)
              .collect(Collectors.toList())
            )
          );
      default:
        throw new VertxException("not discovery spi found");
    }
  }
}