/*
 * Copyright 1999-2018 Alibaba Group Holding Ltd.
 *
 * 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.
 */
package com.alibaba.csp.sentinel.dashboard.discovery;

import com.alibaba.csp.sentinel.dashboard.config.DashboardConfig;

import java.util.*;
import java.util.concurrent.ConcurrentHashMap;

public class AppInfo {

	private String app = "";

	private Integer appType = 0;

	private Set<MachineInfo> machines = ConcurrentHashMap.newKeySet();

	public AppInfo() {
	}

	public AppInfo(String app) {
		this.app = app;
	}

	public AppInfo(String app, Integer appType) {
		this.app = app;
		this.appType = appType;
	}

	public String getApp() {
		return app;
	}

	public void setApp(String app) {
		this.app = app;
	}

	public Integer getAppType() {
		return appType;
	}

	public void setAppType(Integer appType) {
		this.appType = appType;
	}

	/**
	 * Get the current machines.
	 * @return a new copy of the current machines.
	 */
	public Set<MachineInfo> getMachines() {
		return new HashSet<>(machines);
	}

	@Override
	public String toString() {
		return "AppInfo{" + "app='" + app + ", machines=" + machines + '}';
	}

	public boolean addMachine(MachineInfo machineInfo) {
		machines.remove(machineInfo);
		return machines.add(machineInfo);
	}

	public synchronized boolean removeMachine(String ip, int port) {
		Iterator<MachineInfo> it = machines.iterator();
		while (it.hasNext()) {
			MachineInfo machine = it.next();
			if (machine.getIp().equals(ip) && machine.getPort() == port) {
				it.remove();
				return true;
			}
		}
		return false;
	}

	public Optional<MachineInfo> getMachine(String ip, int port) {
		return machines.stream().filter(e -> e.getIp().equals(ip) && e.getPort().equals(port)).findFirst();
	}

	private boolean heartbeatJudge(final int threshold) {
		if (machines.size() == 0) {
			return false;
		}
		if (threshold > 0) {
			long healthyCount = machines.stream().filter(MachineInfo::isHealthy).count();
			if (healthyCount == 0) {
				// No healthy machines.
				return machines.stream().max(Comparator.comparingLong(MachineInfo::getLastHeartbeat))
						.map(e -> System.currentTimeMillis() - e.getLastHeartbeat() < threshold).orElse(false);
			}
		}
		return true;
	}

	/**
	 * Check whether current application has no healthy machines and should not be
	 * displayed.
	 * @return true if the application should be displayed in the sidebar, otherwise false
	 */
	public boolean isShown() {
		return heartbeatJudge(DashboardConfig.getHideAppNoMachineMillis());
	}

	/**
	 * Check whether current application has no healthy machines and should be removed.
	 * @return true if the application is dead and should be removed, otherwise false
	 */
	public boolean isDead() {
		return !heartbeatJudge(DashboardConfig.getRemoveAppNoMachineMillis());
	}

}
