package com.walker.remote.support;

import com.walker.api.client.ResponseData;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.remote.AbstractByteCoder;
import com.walker.remote.Constants;
import com.walker.remote.DoubleTrust;
import com.walker.remote.RemoteAccessor;
import org.apache.hc.client5.http.cookie.CookieStore;

import java.util.Map;

/**
 * 一个<code>RemoteAccessor</code>对象负责一个链接到某个ip的状态；<br>
 * 如果连接不同的服务端，需要使用多个此对象。
 * @author shikeying
 * @date 2015年12月11日
 *
 */
public class DefaultRemoteAccessor implements RemoteAccessor {

	private AbstractByteCoder contentCoder = null;
	
	private String baseUrl; // 应用程序存储本地文件的根路径
	
	private DoubleTrust doubleTrust;
	
	@Override
	public <T> T requestSync(String methodName, Map<String, String> simpleData
			, String jsonParameter, String methodType, String contentType, Map<String, String> header
			, ResponseData<T> responseData){
		checkRequired();
		HttpRemoteTask<T> remoteTask = new HttpRemoteTask<T>();
		remoteTask.setDoubleTrust(doubleTrust);
		remoteTask.setContentCoder(contentCoder);
		remoteTask.setResponseData(responseData);
		// 设置简单参数，并优先处理
		if(simpleData != null && simpleData.size() > 0){
			remoteTask.setSimpleData(simpleData);
		}
//		((HttpRemoteTask<T>)remoteTask).setTimeRecorder(timeRecorder);
		return remoteTask.execute(baseUrl+methodName, simpleData, jsonParameter, methodType, contentType, header);
	}
	
	@Override
	public <T> T requestSyncWithoutGet(String methodName
			, String jsonParameter, String methodType, Map<String, String> header
			, ResponseData<T> responseData){
		return this.requestSync(methodName, null, jsonParameter, methodType, Constants.APPLICATION_JSON, header, responseData);
	}
	
	@Override
	public <T> T requestSyncPost(String methodName
			, String jsonParameter, Map<String, String> header
			, ResponseData<T> responseData){
		return this.requestSyncWithoutGet(methodName, jsonParameter, Constants.HTTP_METHOD_POST, header, responseData);
	}
	@Override
	public <T> T requestSyncPut(String methodName
			, String jsonParameter, Map<String, String> header
			, ResponseData<T> responseData){
		return this.requestSyncWithoutGet(methodName, jsonParameter, Constants.HTTP_METHOD_PUT, header, responseData);
	}
	@Override
	public <T> T requestSyncDelete(String methodName
			, String jsonParameter, Map<String, String> header
			, ResponseData<T> responseData){
		return this.requestSyncWithoutGet(methodName, jsonParameter, Constants.HTTP_METHOD_DELETE, header, responseData);
	}
	
	/**
	 * 同步远程服务调用。
	 * @param methodName
	 * @param simpleData
	 * @param jsonParameter
	 * @param responseData 给定一个响应对象的实例，如：new ResponseLogin()
	 * @return
	 */
	@Override
	public <T> T requestTextSync(String methodName, Map<String, String> simpleData
			, String jsonParameter, ResponseData<T> responseData){
		checkRequired();
		HttpRemoteTask<T> remoteTask = new HttpRemoteTask<T>();
		remoteTask.setDoubleTrust(doubleTrust);
		remoteTask.setContentCoder(contentCoder);
		remoteTask.setResponseData(responseData);
		// 设置简单参数，并优先处理
		if(simpleData != null && simpleData.size() > 0){
			remoteTask.setSimpleData(simpleData);
		}
//		((HttpRemoteTask<T>)remoteTask).setTimeRecorder(timeRecorder);
		return remoteTask.execute(baseUrl+methodName, jsonParameter);
	}
	
	/**
	 * 带cookie的请求，请求后可以从输入的cookie中获取数据
	 * @param methodName
	 * @param simpleData
	 * @param jsonParameter
	 * @param responseData
	 * @param cookieStore
	 * @return
	 */
	@Override
	public <T> T requestTextSyncWithCookie(String methodName, Map<String, String> simpleData
			, String jsonParameter, ResponseData<T> responseData
			, CookieStore cookieStore){
		checkRequired();
		HttpRemoteTask<T> remoteTask = new HttpRemoteTask<T>();
		remoteTask.setDoubleTrust(doubleTrust);
		remoteTask.setContentCoder(contentCoder);
		remoteTask.setResponseData(responseData);
		// 设置简单参数，并优先处理
		if(simpleData != null && simpleData.size() > 0){
			remoteTask.setSimpleData(simpleData);
		}
//		return remoteTask.execute(baseUrl+methodName, jsonParameter);
		return remoteTask.execute(baseUrl+methodName, jsonParameter, cookieStore);
	}
	
	private void checkRequired(){
//		if(contentCoder == null || context == null || StringUtils.isEmpty(baseUrl)){
//			throw new IllegalArgumentException();
//		}
		
		//contentCoder 可以为空，为空时不进行加解密，李润冬2015-07-28
		if(StringUtils.isEmpty(baseUrl)){
			throw new IllegalArgumentException();
		}
	}

	@Override
	public void setContentEncoder(AbstractByteCoder byteCoder) {
		this.contentCoder = byteCoder;
	}

	@Override
	public void setBaseUrl(String baseUrl) {
		this.baseUrl = baseUrl;
	}

	@Override
	public void setDoubleTrust(DoubleTrust doubleTrust) {
		this.doubleTrust = doubleTrust;
	}

}