package org.onap.msb.apiroute.wrapper.util;

import java.io.IOException;

import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class HttpClientUtil {

  private static final Logger logger = LoggerFactory.getLogger(HttpClientUtil.class);
  
  private static int connectionTimeOut = 2*1000;
  

  public static String httpGet(String url){
    String result = null;
    CloseableHttpClient httpClient = HttpClients.createDefault();
    HttpGet httpGet = new HttpGet(url);
    httpGet.addHeader("Content-type", "application/json; charset=utf-8");
    httpGet.setHeader("Accept", "application/json");
    try {
      CloseableHttpResponse res = httpClient.execute(httpGet);
      result = EntityUtils.toString(res.getEntity());
      if (res.getStatusLine().getStatusCode() != CommonUtil.SC_OK) {
        logger.error(result);
      }
      res.close();
    } catch (ClientProtocolException e) {
      logger.error(url + ":httpGetWithJSON connect faild");
    } catch (IOException e) {
      logger.error( url + ":httpGetWithJSON connect faild");
    } finally {
      try {
        httpClient.close();
      } catch (IOException e) {
        logger.error(url + ":close  httpClient faild");
      }
    }

    return result;

  }
  
  public static HttpGetResult httpGetStatusAndBody(String url){
	    HttpGetResult result= new HttpGetResult();
	    String body = null;
	    CloseableHttpClient httpClient = HttpClients.createDefault();
	    HttpGet httpGet = new HttpGet(url);
	    httpGet.addHeader("Content-type", "application/json; charset=utf-8");
	    httpGet.setHeader("Accept", "application/json");
	    
	    RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(connectionTimeOut).build();
	    httpGet.setConfig(requestConfig);
	    
	    try {
	      CloseableHttpResponse res = httpClient.execute(httpGet);
	      body = EntityUtils.toString(res.getEntity());
	      if (res.getStatusLine().getStatusCode() != CommonUtil.SC_OK) {
	        logger.error(body);
	      }
	      result.setBody(body);
	      result.setStatusCode(res.getStatusLine().getStatusCode());
	      res.close();
	    } catch (ClientProtocolException e) {
	      logger.error(url + ":httpGetWithJSON connect faild",e);
	    } catch (IOException e) {
	      logger.error( url + ":httpGetWithJSON connect faild",e);
	    } finally {
	      try {
	        httpClient.close();
	      } catch (IOException e) {
	        logger.error(url + ":close  httpClient faild");
	      }
	    }

	    return result;

	  }

  public static int httpGetStatus(String url)  throws Exception{
    int iStatus=500;
    CloseableHttpClient httpClient = HttpClients.createDefault();


    HttpGet httpGet = new HttpGet(url);
    RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(10000).setConnectTimeout(10000).build();//设置请求和传输超时时间
    httpGet.setConfig(requestConfig);
    httpGet.addHeader("Content-type", "application/json; charset=utf-8");
    httpGet.setHeader("Accept", "application/json");
    try {
      CloseableHttpResponse res = httpClient.execute(httpGet);
    
      iStatus=res.getStatusLine().getStatusCode();
      res.close();
    } catch (ClientProtocolException e) {
      logger.error(url + " httpGet connect faild:"+e.getMessage());
    } catch (IOException e) {
      logger.error(url + " httpGet connect faild:"+e.getMessage());
    } finally {
      try {
        httpClient.close();
      } catch (IOException e) {
        logger.error(url + " httpGet close faild:"+e.getMessage());
      }
    }

    return iStatus;

  }
}