/**
 * Copyright 2016 ZTE, Inc. and others.
 *
 * 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 org.onap.msb.sdclient.health;

import org.apache.commons.lang3.StringUtils;
import org.onap.msb.sdclient.wrapper.util.HttpClientUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.codahale.metrics.health.HealthCheck;

public class ConsulLinkHealthCheck extends HealthCheck {


	private static final Logger LOGGER = LoggerFactory
			.getLogger(ConsulLinkHealthCheck.class);
	
	private String CHECK_IP="127.0.0.1";
	private String CHECK_PORT="8500";
	private String CHECK_URL = "http://"+CHECK_IP+":"+CHECK_PORT+"/v1/status/leader";


	@Override
	protected Result check() throws Exception {
		// TODO Auto-generated method stub
		
		if(!StringUtils.isBlank(System.getenv("CONSUL_IP")))
		{
			CHECK_IP=System.getenv("CONSUL_IP");
			CHECK_URL = "http://"+CHECK_IP+":"+CHECK_PORT+"/v1/status/leader";
			LOGGER.info("check consul URL:"+CHECK_URL);
		}
		
		int resultStatus = HttpClientUtil.httpGetStatus(CHECK_URL);

		if (resultStatus == 200) {
			return Result.healthy();
		} else {
			return Result
					.unhealthy("check consul link {} fail:{}",CHECK_URL,resultStatus);
		}

	}

}