/*-
 * ============LICENSE_START=======================================================
 * openECOMP : SDN-C
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property. All rights
 * 						reserved.
 * ================================================================================
 * 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.
 * ============LICENSE_END=========================================================
 */

package org.openecomp.sdnc.sli.aai;

import java.io.UnsupportedEncodingException;
import java.lang.annotation.Annotation;
import java.lang.reflect.Field;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;

import javax.xml.bind.annotation.XmlElement;

import org.openecomp.sdnc.sli.aai.data.AAIDatum;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.base.Joiner;

import org.openecomp.aai.inventory.v10.L3Network;
import org.openecomp.aai.inventory.v10.L3Networks;

public class GenericRequest extends AAIRequest {


	protected Class<? extends AAIDatum> model;

	public GenericRequest(Class<? extends AAIDatum> clazz) {
		model = clazz;
	}

	@Override
	public URL getRequestUrl(String method, String resourceVersion) throws UnsupportedEncodingException, MalformedURLException {

		String request_url = null;
		String originalPath = null;
		String pathSubstitute = null;

		request_url = target_uri + getRequestPath();

		Map<String, String> queryParams = new HashMap<String, String> ();
		if(resourceVersion != null) {
			queryParams.put("resource-version",resourceVersion);
		}

		Set<String> uniqueResources = extractUniqueResourceSetFromKeys(requestProperties.stringPropertyNames());

		String[] keys = requestProperties.keySet().toArray(new String[0]);
		for(String key : keys) {
			if("cloud-region.cloud-region-id".equals(key))
				continue;
			if("entitlement.resource-uuid".equals(key))
				continue;
			if("license.resource-uuid".equals(key))
				continue;


			String value = requestProperties.getProperty(key);
			if(key.contains(".")) {
				String[] splitKey = key.split("\\.");
				if("cloud-region".equals(splitKey[0])){
					String cloudRegionId =  requestProperties.getProperty("cloud-region.cloud-region-id");
					aaiService.LOGwriteDateTrace("cloud-region-id", cloudRegionId);
					String token = String.format("%s/{%s}/{cloud-region-id}", splitKey[0], splitKey[1] );
					String encoded_owner = encodeQuery(value);
					String encoded_region = encodeQuery(cloudRegionId);
					request_url = request_url.replace(token, String.format("%s/%s/%s", splitKey[0], encoded_owner, encoded_region));
				} else 	if("entitlement".equals(splitKey[0])){
					String cloudRegionId =  requestProperties.getProperty("entitlement.resource-uuid");
					aaiService.LOGwriteDateTrace("resource-uuid", cloudRegionId);
					String token = String.format("%s/{%s}/{resource-uuid}", splitKey[0], splitKey[1] );
					String encoded_owner = encodeQuery(value);
					String encoded_region = encodeQuery(cloudRegionId);
					request_url = request_url.replace(token, String.format("%s/%s/%s", splitKey[0], encoded_owner, encoded_region));
				} else 	if("license".equals(splitKey[0])){
					String cloudRegionId =  requestProperties.getProperty("license.resource-uuid");
					aaiService.LOGwriteDateTrace("resource-uuid", cloudRegionId);
					String token = String.format("%s/{%s}/{resource-uuid}", splitKey[0], splitKey[1] );
					String encoded_owner = encodeQuery(value);
					String encoded_region = encodeQuery(cloudRegionId);
					request_url = request_url.replace(token, String.format("%s/%s/%s", splitKey[0], encoded_owner, encoded_region));
				} else {
					Class<? extends AAIDatum> clazz = null;
					try {
						clazz = getClassFromResource(splitKey[0]);
					} catch (ClassNotFoundException exc) {
						LOG.warn("AAIRequest does not support class: " + exc.getMessage());
						return null;
					}

					if(clazz != null) {
						if(clazz == this.model) {
							Field[] fields = this.model.getDeclaredFields();
							Field field = fields[0];
							String fieldName = field.getName();
							XmlElement annotation = field.getAnnotation(XmlElement.class);
							String primaryId = annotation.name();
							if("##default".equals(primaryId)) {
								primaryId = fieldName;
							}

							String token = String.format("%s/{%s}", splitKey[0], primaryId);

							if(splitKey[1].equals(primaryId)) {
								String encoded_vnf = encodeQuery(value);
								request_url = request_url.replace(token, String.format("%s/%s", splitKey[0], encoded_vnf));
							} else {
								queryParams.put(splitKey[1], encodeQuery(value));
								originalPath = token;
								pathSubstitute = String.format("%s", splitKey[0]);
							}
						} else if(L3Networks.class == this.model) {
							Field[] fields = L3Network.class.getDeclaredFields();
							Field field = fields[0];
							String fieldName = field.getName();
							XmlElement annotation = field.getAnnotation(XmlElement.class);
							String primaryId = annotation.name();
							if("##default".equals(primaryId)) {
								primaryId = fieldName;
							}

							String token = String.format("%s/{%s}", splitKey[0], primaryId);
							originalPath = token;
							pathSubstitute = String.format("");

							queryParams.put(splitKey[1], encodeQuery(value));
						} else {
							String token = String.format("%s/{%s}", splitKey[0], splitKey[1]);
							String encoded_vnf = encodeQuery(value);
							request_url = request_url.replace(token, String.format("%s/%s", splitKey[0], encoded_vnf));
						}
					}

				}
				aaiService.LOGwriteDateTrace(splitKey[1], value);
			}
		}

		if(originalPath != null && pathSubstitute != null)
			request_url = request_url.replace(originalPath, pathSubstitute);

		if(!queryParams.isEmpty()) {
			Joiner.MapJoiner mapJoiner = Joiner.on("&").withKeyValueSeparator("=");
			String queryString = mapJoiner.join(queryParams);
			request_url = String.format("%s?%s", request_url, queryString);
		}

		URL http_req_url =	new URL(request_url);

		aaiService.LOGwriteFirstTrace(method, http_req_url.toString());


		return http_req_url;
	}


	public URL OriginalgetRequestUrl(String method, String resourceVersion) throws UnsupportedEncodingException, MalformedURLException {

		String request_url = null;

		request_url = target_uri + getRequestPath();

		Map<String, String> keyValuepairs = new HashMap<String, String> ();
		Set<String> uniqueResources = extractUniqueResourceSetFromKeys(requestProperties.stringPropertyNames());

		String[] keys = requestProperties.keySet().toArray(new String[0]);
		for(String key : keys) {
			if("cloud-region.cloud-region-id".equals(key))
				continue;
			if("entitlement.resource-uuid".equals(key))
				continue;
			if("license.resource-uuid".equals(key))
				continue;


			String value = requestProperties.getProperty(key);
			if(key.contains(".")) {
				String[] splitKey = key.split("\\.");
				if("cloud-region".equals(splitKey[0])){
					String cloudRegionId =  requestProperties.getProperty("cloud-region.cloud-region-id");
					aaiService.LOGwriteDateTrace("cloud-region-id", cloudRegionId);
					String token = String.format("%s/{%s}/{cloud-region-id}", splitKey[0], splitKey[1] );
					String encoded_owner = encodeQuery(value);
					String encoded_region = encodeQuery(cloudRegionId);
					request_url = request_url.replace(token, String.format("%s/%s/%s", splitKey[0], encoded_owner, encoded_region));
				} else 	if("entitlement".equals(splitKey[0])){
					String cloudRegionId =  requestProperties.getProperty("entitlement.resource-uuid");
					aaiService.LOGwriteDateTrace("resource-uuid", cloudRegionId);
					String token = String.format("%s/{%s}/{resource-uuid}", splitKey[0], splitKey[1] );
					String encoded_owner = encodeQuery(value);
					String encoded_region = encodeQuery(cloudRegionId);
					request_url = request_url.replace(token, String.format("%s/%s/%s", splitKey[0], encoded_owner, encoded_region));
				} else 	if("license".equals(splitKey[0])){
					String cloudRegionId =  requestProperties.getProperty("license.resource-uuid");
					aaiService.LOGwriteDateTrace("resource-uuid", cloudRegionId);
					String token = String.format("%s/{%s}/{resource-uuid}", splitKey[0], splitKey[1] );
					String encoded_owner = encodeQuery(value);
					String encoded_region = encodeQuery(cloudRegionId);
					request_url = request_url.replace(token, String.format("%s/%s/%s", splitKey[0], encoded_owner, encoded_region));
				} else {
					Class<? extends AAIDatum> clazz = null;
					try {
						clazz = getClassFromResource(splitKey[0]);
					} catch (ClassNotFoundException exc) {
						LOG.warn("AAIRequest does not support class: " + exc.getMessage());
						return null;
					}

					if(clazz != null) {
						if(clazz == this.model) {
							Field[] fields = this.model.getDeclaredFields();
							Field field = fields[0];
							String fieldName = field.getName();
							XmlElement annotation = field.getAnnotation(XmlElement.class);
							String primaryId = annotation.name();
							if("##default".equals(primaryId)) {
								primaryId = fieldName;
							}

							String token = String.format("%s/{%s}", splitKey[0], primaryId);

							if(splitKey[1].equals(primaryId)) {
								String encoded_vnf = encodeQuery(value);
								request_url = request_url.replace(token, String.format("%s/%s", splitKey[0], encoded_vnf));
							} else {
								String replacement = String.format("%s?%s=%s", splitKey[0], splitKey[1], encodeQuery(value));
								if(request_url.contains(token))
									request_url = request_url.replace(token, replacement);
							}
						} else {
							String token = String.format("%s/{%s}", splitKey[0], splitKey[1]);
							String encoded_vnf = encodeQuery(value);
							request_url = request_url.replace(token, String.format("%s/%s", splitKey[0], encoded_vnf));
						}
					}

				}
				aaiService.LOGwriteDateTrace(splitKey[1], value);
			}
		}


		if(resourceVersion != null) {
			request_url = request_url +"?resource-version="+resourceVersion;
		}
		URL http_req_url =	new URL(request_url);

		aaiService.LOGwriteFirstTrace(method, http_req_url.toString());


		return http_req_url;
	}

	@Override
	public URL getRequestQueryUrl(String method) throws UnsupportedEncodingException, MalformedURLException {
		return this.getRequestUrl(method, null);
	}


	@Override
	public String toJSONString() {
		ObjectMapper mapper = getObjectMapper();

		String json_text = null;
		try {
			json_text = mapper.writeValueAsString(requestDatum);
		} catch (JsonProcessingException exc) {
			handleException(this, exc);
			return null;
		}
		return json_text;
	}

	@Override
	public String[] getArgsList() {
		String[] args = {};
		return args;
	}

	@Override
	public Class<? extends AAIDatum> getModelClass() {
		return model;
	}

	public void processRequestPathValues(Map<String, String> nameValues) {
		// identify unique resources
		Set<String> uniqueResources = AAIRequest.extractUniqueResourceSetFromKeys(nameValues.keySet());

		String[] arguments = nameValues.keySet().toArray(new String[0]);
		for(String name : arguments) {
			String tmpName = name.replaceAll("-", "_");
			String value = nameValues.get(tmpName);
			if(value != null && !value.isEmpty()) {
				value = value.trim().replace("'", "").replace("$", "").replace("'", "");
				tmpName = name.replaceAll("_", "-");
				this.addRequestProperty(tmpName, value);
			}
		}
	}
}