package org.onap.so.multicloudsimulator.controller;

import javax.servlet.http.HttpServletRequest;
import javax.ws.rs.core.MediaType;

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.json.simple.JSONArray;
import org.json.simple.JSONObject;
import org.onap.so.multicloudsimulator.beans.InstanceResponse;
import org.onap.so.multicloudsimulator.beans.MulticloudInstanceRequest;
import org.onap.so.multicloudsimulator.beans.MulticloudCreateResponse;
import org.onap.so.multicloudsimulator.beans.MulticloudRequest;
import org.onap.so.openstack.beans.HeatStatus;

import org.springframework.http.ResponseEntity;

import org.springframework.web.bind.annotation.*;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.net.URI;

import static org.onap.so.multicloudsimulator.utils.Constants.BASE_URL;
@RestController
@RequestMapping(path = BASE_URL)
public class MultiCloudController {

	public static final String X_HTTP_METHOD_OVERRIDE = "X-HTTP-Method-Override";
	private static final Logger LOGGER = LoggerFactory.getLogger(MultiCloudController.class);
	public MulticloudCreateResponse multicloudCreateResponse = new MulticloudCreateResponse();

	@PostMapping(value="/v1/instance")
	public ResponseEntity<?> createInstance(@RequestBody MulticloudInstanceRequest req){
	   System.out.println("MultiCloud createInstance ");
		InstanceResponse InstanceResponse = new InstanceResponse();
		
		return ResponseEntity.ok(InstanceResponse);
	}
	
	@GetMapping(value = "/{cloud-owner}/{cloud-region-id}/infra_workload", produces = {
			MediaType.APPLICATION_JSON })
    public ResponseEntity<?> getInstance(
		@PathVariable("cloud-owner") String cloudOwner, @PathVariable("cloud-region-id") String cloudRegionId,
		@RequestParam(value = "depth", required = false, defaultValue = "0") Integer depth,
		@RequestParam(name = "format", required = false) final String name, final HttpServletRequest request) throws IOException {
		
		LOGGER.info("found CloudOwner {} in cache", cloudOwner);
		LOGGER.info("found cloudRegionId {} in cache", cloudRegionId);
		LOGGER.info("found name {} in cache", name);
			JSONObject json = new JSONObject();

			json.put("template_type", "heat");
			json.put("workload_id", "");
			json.put("workload_status", "GET_COMPLETE");
			JSONObject workload = new JSONObject();
			workload.put("stacks", HeatStatus.NOTFOUND);
			json.put("workload_status_reason", workload);

			return ResponseEntity.ok(json);
	}

	@PostMapping(value = "/{cloud-owner}/{cloud-region-id}/infra_workload",
			consumes = {MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML},
			produces = {MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML})
	public ResponseEntity<?> postCreateInstance(
			@RequestBody final MulticloudRequest inputRequest, @PathVariable("cloud-owner") final String cloudOwner,
			@PathVariable("cloud-region-id") final String cloudRegionId,
			@RequestHeader(value = X_HTTP_METHOD_OVERRIDE, required = false) final String xHttpHeaderOverride,
			final HttpServletRequest request) throws IOException {

			LOGGER.info("input request {}: ",inputRequest.toString());
		String input = "{\n" +
				"   \"template_type\": \"heat\",\n" +
				"   \"workload_id\": \"sad_sammet\",\n" +
				"   \"template_response\": [\n" +
				"      {\n" +
				"         \"GVK\": {\n" +
				"            \"Group\": \"k8s.plugin.opnfv.org\",\n" +
				"            \"Version\": \"v1alpha1\",\n" +
				"            \"Kind\": \"Network\"\n" +
				"         },\n" +
				"         \"Name\": \"k8s-region-2-onap-nf-20210120t221126760z-management-network\"\n" +
				"      },\n" +
				"      {\n" +
				"         \"GVK\": {\n" +
				"            \"Group\": \"k8s.plugin.opnfv.org\",\n" +
				"            \"Version\": \"v1alpha1\",\n" +
				"            \"Kind\": \"Network\"\n" +
				"         },\n" +
				"         \"Name\": \"k8s-region-2-onap-nf-20210120t221126760z-protected-network\"\n" +
				"      },\n" +
				"      {\n" +
				"         \"GVK\": {\n" +
				"            \"Group\": \"k8s.plugin.opnfv.org\",\n" +
				"            \"Version\": \"v1alpha1\",\n" +
				"            \"Kind\": \"Network\"\n" +
				"         },\n" +
				"         \"Name\": \"k8s-region-2-onap-nf-20210120t221126760z-unprotected-network\"\n" +
				"      },\n" +
				"      {\n" +
				"         \"GVK\": {\n" +
				"            \"Group\": \"k8s.cni.cncf.io\",\n" +
				"            \"Version\": \"v1\",\n" +
				"            \"Kind\": \"NetworkAttachmentDefinition\"\n" +
				"         },\n" +
				"         \"Name\": \"k8s-region-2-onap-nf-20210120t221126760z-ovn-nat\"\n" +
				"      }\n" +
				"   ],\n" +
				"   \"workload_status\": \"CREATE_COMPLETE\",\n" +
				"   \"workload_status_reason\": \"test\"\n" +
				"}";

		ObjectMapper objectMapper = new ObjectMapper();
		JSONObject workload = new JSONObject();

		workload.put("stack",true);

		JsonNode jsonNode = objectMapper.readTree(workload.toJSONString());
		MulticloudCreateResponse multiResponse = objectMapper.readValue(input, MulticloudCreateResponse.class);
		multiResponse.setWorkloadStatusReason(null);

		LOGGER.info("workload reason: {}",multiResponse.getWorkloadStatusReason());
		multiResponse.setWorkloadId("sad_sammet");
		multiResponse.setTemplateType("heat");
		multiResponse.setWorkloadStatus("CREATE_COMPLETE");

		return ResponseEntity.status(201).body(multiResponse);
	}

	@GetMapping(value = "/{cloud-owner}/{cloud-region-id}/infra_workload/{workload-id}", produces = {
			MediaType.APPLICATION_JSON })
	public ResponseEntity<?> getInstanceName(
			@PathVariable("cloud-owner") String cloudOwner, @PathVariable("cloud-region-id") String cloudRegionId,
			@PathVariable("workload-id") String workloadId,
			@RequestParam(value = "depth", required = false, defaultValue = "0") Integer depth,
			@RequestParam(name = "format", required = false) final String name, final HttpServletRequest request) throws IOException {

		LOGGER.info("Calling getInstanceName");
		LOGGER.info("found CloudOwner {} in cache", cloudOwner);
		LOGGER.info("found cloudRegionId {} in cache", cloudRegionId);
		LOGGER.info("found name {} in cache", name);
		JSONObject json = new JSONObject();

			json.put("template_type", "heat");
			json.put("workload_id", "sad_sammet");
			json.put("workload_status", "CREATE_COMPLETE");
			JSONObject workload = new JSONObject();
			workload.put("stacks", true);
			json.put("workload_status_reason", null);

			return ResponseEntity.ok(json);
	}

	@PostMapping(value = "/{cloud-owner}/{cloud-region-id}/infra_workload/{workload-id}",
			consumes = {MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML},
			produces = {MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML})
	public ResponseEntity<?> postCreateInstanceName(
			@RequestBody final MulticloudRequest inputRequest, @PathVariable("cloud-owner") final String cloudOwner,
			@PathVariable("workload-id") String workloadId,
			@PathVariable("cloud-region-id") final String cloudRegionId,
			@RequestHeader(value = X_HTTP_METHOD_OVERRIDE, required = false) final String xHttpHeaderOverride,
			final HttpServletRequest request) throws IOException {

			LOGGER.info("Calling postCreateInstanceName");

			return ResponseEntity.status(405).build();
	}
}