package foundation.icall.callout;

import java.util.concurrent.TimeUnit;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import foundation.action.ActionContext;
import foundation.dao.bizlogic.IRequest;
import foundation.dao.bizlogic.ResponseType;
import foundation.icall.ICall;
import foundation.icall.ICallDirection;
import foundation.server.ObjectCreator;
import okhttp3.OkHttpClient;
import okhttp3.OkHttpClient.Builder;
import okhttp3.Request;
import okhttp3.Response;

public abstract class HttpServerSource implements IRemoteSource {

	public static boolean Test = false;
    protected static Logger logger;
	public static int ConnectTimeout = 60;
	public static int WriteTimeout = 60;
	public static int ReadTimeout = 60;
	
	protected HttpServerMeta meta;
	private static OkHttpClient httpClient = null;

	static {
		logger = LogManager.getLogger(HttpServerSource.class);
	}
	
	protected HttpServerSource() {
		Builder builder = new OkHttpClient.Builder();
		builder.connectTimeout(ConnectTimeout, TimeUnit.SECONDS);
		builder.writeTimeout(WriteTimeout, TimeUnit.SECONDS);
		builder.readTimeout(ReadTimeout, TimeUnit.SECONDS);
		
		httpClient = builder.build();
	}
	
	public void init(HttpServerMeta meta) {
		this.meta = meta;
	}

	public static HttpServerSource newInstance(HttpServerMeta meta) throws Exception {
		String className = meta.getClassName();
		HttpServerSource instance = ObjectCreator.create(className);
		instance.init(meta);
		
		return instance;
	}
	
	public abstract void login(ActionContext context, ICall iCall) throws Exception;
	
	public abstract void logout(ActionContext context, ICall iCall) throws Exception;

	public abstract ICallRequest createRequest(String url);
		
	
	@SuppressWarnings("unchecked")
	public <T> T post(IRequest request, ResponseType responseType) throws Exception {
		//1. 如果测试状态，直接退出
		if (Test) {
			if (ResponseType.JSON == responseType) {
				return (T) new JSONResponse(null);
			}
			else if (ResponseType.Stream == responseType) {
				return (T) new StreamResponse(null);
			}
		}
		
		//2. 构建请求
		T result = null;
		ICallRequest iRequest = (ICallRequest)request;
		Request.Builder builder = new Request.Builder();
		
		//3. 将  URL 设置到请求中
		String params = iRequest.paramsToURL();
		builder.url(iRequest.getURL() + params);
		
		//4. 将 headers 设置到请求中
		if (iRequest.existsHeaders()) {
			iRequest.applyHeaders(builder);
		}
		
		//5.  将 JSON Body 设置到请求中
		if (iRequest.existsJSONBody()) {
			iRequest.applyJSONBody(builder);
		}
		
		//6. 将 Form Body 设置到请求中
		if (iRequest.existsFormBody()) {
			iRequest.applyFormBody(builder);
		}
		
		//7. 发送请求
		Response response = httpClient.newCall(builder.build()).execute();
		
		if (ResponseType.JSON == responseType) {
			result = (T) new JSONResponse(response);
		}
		else if (ResponseType.Stream == responseType) {
			result = (T) new StreamResponse(response);
		}
		
		//8. 返回
		return result;
	}
	
	@SuppressWarnings("unchecked")
	public <T> T get(IRequest request, ResponseType responseType) throws Exception {
		ICallRequest iRequest = (ICallRequest)request;
		
		T result = null;
		Request.Builder builder = new Request.Builder().get();
		
		//1. 将  URL 设置到请求中
		String params = iRequest.paramsToURL();
		builder.url(iRequest.getURL() + params);
		
		//2. 将 headers 设置到请求中
		if (iRequest.existsHeaders()) {
			iRequest.applyHeaders(builder);
		}
		
		//3. 发送请求
		Response response = httpClient.newCall(builder.build()).execute();
		
		if (ResponseType.JSON == responseType) {
			result = (T) new JSONResponse(response);
		}
		else if (ResponseType.Stream == responseType) {
			result = (T) new StreamResponse(response);
		}
		
		//5. 返回
		return result;
	}
	
	@Override
	public Object get() {
		return this;
	}

	public ICallDirection getDirection() {
		return ICallDirection.RemoteServer;
	}
	
	public HttpServerMeta getMeta() {
		return meta;
	}

	@Override
	public String getName() {
		return meta.getName();
	}
	
}