/*-
 * ========================LICENSE_START=================================
 * org.etsi.osl.tmf.api
 * %%
 * Copyright (C) 2019 openslice.io
 * %%
 * 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.etsi.osl.services.api;

import static org.assertj.core.api.Assertions.assertThat;
import static org.springframework.security.test.web.servlet.setup.SecurityMockMvcConfigurers.springSecurity;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.content;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.net.URI;
import java.time.OffsetDateTime;
import java.time.ZoneOffset;
import java.util.ArrayList;
import java.util.List;

import org.apache.camel.CamelContext;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.commons.io.IOUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import org.etsi.osl.tmf.OpenAPISpringBoot;
import org.etsi.osl.tmf.common.model.Any;
import org.etsi.osl.tmf.common.model.UserPartRoleType;
import org.etsi.osl.tmf.common.model.service.Characteristic;
import org.etsi.osl.tmf.common.model.service.Note;
import org.etsi.osl.tmf.common.model.service.ServiceRef;
import org.etsi.osl.tmf.common.model.service.ServiceSpecificationRef;
import org.etsi.osl.tmf.prm669.model.RelatedParty;
import org.etsi.osl.tmf.rcm634.model.LogicalResourceSpecification;
import org.etsi.osl.tmf.rcm634.model.ResourceSpecificationCreate;
import org.etsi.osl.tmf.rcm634.model.ResourceSpecificationRef;
import org.etsi.osl.tmf.scm633.model.ServiceSpecification;
import org.etsi.osl.tmf.scm633.model.ServiceSpecificationCreate;
import org.etsi.osl.tmf.scm633.reposervices.CatalogRepoService;
import org.etsi.osl.tmf.scm633.reposervices.CategoryRepoService;
import org.etsi.osl.tmf.scm633.reposervices.ServiceSpecificationRepoService;
import org.etsi.osl.tmf.sim638.model.Service;
import org.etsi.osl.tmf.sim638.model.ServiceCreate;
import org.etsi.osl.tmf.sim638.model.ServiceOrderRef;
import org.etsi.osl.tmf.sim638.service.ServiceRepoService;
import org.etsi.osl.tmf.so641.model.ServiceOrder;
import org.etsi.osl.tmf.so641.model.ServiceOrderCreate;
import org.etsi.osl.tmf.so641.model.ServiceOrderItem;
import org.etsi.osl.tmf.so641.model.ServiceOrderStateType;
import org.etsi.osl.tmf.so641.model.ServiceOrderUpdate;
import org.etsi.osl.tmf.so641.model.ServiceRestriction;
import org.etsi.osl.tmf.so641.reposervices.ServiceOrderRepoService;
import org.etsi.osl.tmf.JsonUtils;

import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.http.MediaType;
import org.springframework.security.test.context.support.WithMockUser;
import org.springframework.security.test.web.servlet.request.SecurityMockMvcRequestPostProcessors;
import org.springframework.security.web.FilterChainProxy;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.test.web.servlet.MockMvc;
import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
import org.springframework.test.web.servlet.setup.MockMvcBuilders;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.context.WebApplicationContext;

@RunWith(SpringRunner.class)
@Transactional
@SpringBootTest(
		webEnvironment = SpringBootTest.WebEnvironment.MOCK, 
		classes = OpenAPISpringBoot.class
		)
//@AutoConfigureTestDatabase //this automatically uses h2
@AutoConfigureMockMvc
@ActiveProfiles("testing")
//@TestPropertySource(
//		  locations = "classpath:application-testing.yml")
public class ServiceOrderIntegrationTest {

	private static final transient Log logger = LogFactory.getLog(ServiceOrderIntegrationTest.class.getName());

	@Autowired
	private MockMvc mvc;

	@Autowired
	CatalogRepoService catalogRepoService;

	@Autowired
	CategoryRepoService categRepoService;

	@Autowired
	ServiceSpecificationRepoService specRepoService;

	@Autowired
	ServiceOrderRepoService serviceOrderRepoService;

	@Autowired
	ServiceRepoService serviceRepoService;

	@Autowired
	private WebApplicationContext context;
	

    @Autowired
    private FilterChainProxy springSecurityFilterChain;
    
    private class UserMocked {
    	public String getUserByUsername( String username) {
    		
    		return "{\"id\":\"001\"}";
    	}
    }
    
    UserMocked userMocked = new UserMocked();
    
	@Autowired
	private CamelContext camelContext;

	@Before
	public void setup() throws Exception {
		mvc = MockMvcBuilders.webAppContextSetup(context).
				apply(springSecurity(springSecurityFilterChain)).build();
		
	}

	@Test
	public void _countDefaultProperties() {

		assertThat(serviceOrderRepoService.findAll().size()).isEqualTo(0);

	}

	@WithMockUser(username="osadmin", roles = {"USER","ADMIN"})
	@Test
	public void testServiceOrderCreateAndUpdate() throws UnsupportedEncodingException, IOException, Exception {

		RoutesBuilder builder = new RouteBuilder() {
			@Override
			public void configure() {
				from("direct:get_user_byusername").bean( userMocked, "getUserByUsername");
				
			};
		};

		camelContext.addRoutes(builder);
		/**
		 * first add 2 specs
		 */

		File sspec = new File("src/test/resources/testServiceSpec.json");
		InputStream in = new FileInputStream(sspec);
		String sspectext = IOUtils.toString(in, "UTF-8");

		ServiceSpecificationCreate sspeccr1 = JsonUtils.toJsonObj(sspectext, ServiceSpecificationCreate.class);
		sspeccr1.setName("Spec1");
		ServiceSpecification responsesSpec1 = createServiceSpec( sspeccr1);

		sspec = new File("src/test/resources/testServiceSpec2.json");
		in = new FileInputStream(sspec);
		sspectext = IOUtils.toString(in, "UTF-8");
		// service 2 is an RFS
		ServiceSpecificationCreate sspeccr2 = JsonUtils.toJsonObj(sspectext, ServiceSpecificationCreate.class);
		sspeccr2.setName("Spec2");
		ResourceSpecificationRef resourceSpecificationItem = new ResourceSpecificationRef();
		resourceSpecificationItem.setId("resourceid");
		resourceSpecificationItem.setName("resourceName");
		sspeccr2.addResourceSpecificationItem(resourceSpecificationItem);
		ServiceSpecification responsesSpec2 = createServiceSpec( sspeccr2);
		/**
		 * add them as bundle
		 */

		ServiceSpecificationCreate sspeccr3 = JsonUtils.toJsonObj(sspectext, ServiceSpecificationCreate.class);
		sspeccr3.setName("BundleExampleSpec");
		sspeccr3.isBundle(true);
		sspeccr3.addServiceSpecRelationshipWith(responsesSpec1);
		sspeccr3.addServiceSpecRelationshipWith(responsesSpec2);
		ServiceSpecification responsesSpec3 = createServiceSpec( sspeccr3);
		

		/**
		 * the bundle service characteristics must be same with the total of characteristics of each service in the bundle
		 * here 1+2 + the 2 characteristics of the service itself total 5
		 */
		
		assertThat( responsesSpec3.getServiceSpecCharacteristic().size() ).isEqualTo( 4 );

		ServiceOrderCreate servOrder = new ServiceOrderCreate();
		servOrder.setCategory("Experimentation");
		servOrder.setDescription("Experimentation Descr");
		servOrder.setRequestedStartDate(OffsetDateTime.now(ZoneOffset.UTC).toString());
		servOrder.setRequestedCompletionDate(OffsetDateTime.now(ZoneOffset.UTC).toString());

		Note noteItem = new Note();
		noteItem.text("test note");
		servOrder.addNoteItem(noteItem);

		ServiceOrderItem soi = new ServiceOrderItem();
		servOrder.getOrderItem().add(soi);
		soi.setState(ServiceOrderStateType.ACKNOWLEDGED);

		ServiceRestriction serviceRestriction = new ServiceRestriction();
		ServiceSpecificationRef aServiceSpecificationRef = new ServiceSpecificationRef();
		aServiceSpecificationRef.setId(responsesSpec3.getId());
		aServiceSpecificationRef.setName(responsesSpec3.getName());

		serviceRestriction.setServiceSpecification(aServiceSpecificationRef);
		serviceRestriction.setName("aserviceRestriction");
		soi.setService(serviceRestriction);
		
		Characteristic charitem = new Characteristic();
		charitem.setName("Spec2Attribute1");
		charitem.setValue( new Any("3", "Indoor"));
		serviceRestriction.addServiceCharacteristicItem(charitem );

		String responseSorder = mvc
				.perform(MockMvcRequestBuilders.post("/serviceOrdering/v4/serviceOrder")
			            .with( SecurityMockMvcRequestPostProcessors.csrf())
						.contentType(MediaType.APPLICATION_JSON).content(JsonUtils.toJson(servOrder)))
				.andExpect(status().isOk()).andExpect(content().contentTypeCompatibleWith(MediaType.APPLICATION_JSON))
				.andExpect(status().isOk()).andReturn().getResponse().getContentAsString();
		logger.info("testServiceOrderCreate = " + responseSorder);
		ServiceOrder responseSO = JsonUtils.toJsonObj(responseSorder, ServiceOrder.class);

		logger.info("BundleExampleSpec  = " + JsonUtils.toJsonString(responsesSpec3));
		logger.info("responsesSpec1 = " + JsonUtils.toJsonString(responsesSpec1));
		logger.info("responsesSpec2 = " + JsonUtils.toJsonString(responsesSpec2));
		logger.info("testServiceOrderCreate = " + JsonUtils.toJsonString(responseSO));

		assertThat(responseSO.getCategory()).isEqualTo("Experimentation");
		assertThat(responseSO.getDescription()).isEqualTo("Experimentation Descr");
		assertThat(responseSO.getRequestedStartDate()).isNotNull();
		assertThat(responseSO.getRequestedCompletionDate()).isNotNull();

		assertThat(responseSO.getOrderItem().size()).isEqualTo(1);
		

		assertThat( responsesSpec1.getServiceSpecCharacteristic().size() ).isEqualTo( 2 );
		assertThat( responsesSpec2.getServiceSpecCharacteristic().size() ).isEqualTo( 4 );
		assertThat( responsesSpec3.getServiceSpecCharacteristic().size() ).isEqualTo( 4 );
	
		
		responseSO.getOrderItem().stream().forEach(soiElement -> {
			assertThat(soiElement.getState()).isEqualTo(ServiceOrderStateType.ACKNOWLEDGED);
			assertThat(soiElement.getService().getServiceSpecification()).isNotNull();
			assertThat(soiElement.getService().getServiceSpecification().getName()).isEqualTo( "BundleExampleSpec" );

			/**
			 * the ordered service characteristics must be same with the total of characteristics of service
			 *  with ONLY user configurable values (This changed on 20/8/2021 with the implementation of rules) 
			 *  (and NO with default values from non configurable attributes)
			 *  Therefore the service should have only 1 characteristic (the Spec2Attribute1 name)
			 */
			assertThat( soiElement.getService().getServiceCharacteristic().size() ).isEqualTo( 1 );
			assertThat( soiElement.getService().getServiceCharacteristic().stream().findFirst().get().getName()  ).isEqualTo( "Spec2Attribute1" );
			
			
		});
		assertThat(responseSO.getNote().size()).isEqualTo(3);

		boolean userPartyRoleexists = false;
		for (RelatedParty r : responseSO.getRelatedParty()) {
			if (r.getName().equals("osadmin") && r.getRole().equals(UserPartRoleType.REQUESTER.toString())) {
				userPartyRoleexists = true;
			}
		}

		assertThat(userPartyRoleexists).isTrue();

		assertThat(serviceOrderRepoService.findAll().size()).isEqualTo(1);

		ServiceCreate s = new ServiceCreate();
		s.setDescription("A Service for ");
		s.setServiceDate(OffsetDateTime.now(ZoneOffset.UTC).toString());
		s.hasStarted(false);
		s.setIsServiceEnabled(false);
		s.setName("Servicename");
		s.setStartMode("0");

		Note anoteItem = new Note();
		anoteItem.setText("Service Created by OSOM:AutomationCheck");
		s.addNoteItem(anoteItem);

		ServiceOrderRef serviceOrderref = new ServiceOrderRef();
		serviceOrderref.setId(responseSO.getId());
		serviceOrderref.setServiceOrderItemId((new ArrayList<>(responseSO.getOrderItem())).get(0).getId());
		s.addServiceOrderItem(serviceOrderref);
		s.setServiceCharacteristic( new ArrayList<>());

		Service createdServ = serviceRepoService.addService(s);

		ServiceOrderUpdate servOrderUpd = new ServiceOrderUpdate();
		servOrderUpd.setExpectedCompletionDate(OffsetDateTime.now(ZoneOffset.UTC).toString());
		responseSO.getNote().stream().forEach(n -> servOrderUpd.addNoteItem(n));
		Note en = new Note();
		en.text("test note2");
		servOrderUpd.addNoteItem(en);
		servOrderUpd.addOrderItemItem((new ArrayList<>(responseSO.getOrderItem())).get(0));
		servOrderUpd.getOrderItem().get(0).setState(ServiceOrderStateType.INPROGRESS);
		ServiceRef supportingServiceItem = new ServiceRef();
		supportingServiceItem.setId(createdServ.getId());
		supportingServiceItem.setReferredType(createdServ.getName());
		supportingServiceItem.setName(createdServ.getName());
		servOrderUpd.getOrderItem().get(0).getService().addSupportingServiceItem(supportingServiceItem);

		String responseSorderUpd = mvc
				.perform(MockMvcRequestBuilders.patch("/serviceOrdering/v4/serviceOrder/" + responseSO.getId())
			            .with( SecurityMockMvcRequestPostProcessors.csrf())
						.contentType(MediaType.APPLICATION_JSON).content(JsonUtils.toJson(servOrderUpd)))
				.andExpect(status().isOk()).andExpect(content().contentTypeCompatibleWith(MediaType.APPLICATION_JSON))
				.andExpect(status().isOk()).andReturn().getResponse().getContentAsString();
		logger.info("testServiceOrderUpdate = " + responseSorderUpd);
		ServiceOrder responseSOUpd = JsonUtils.toJsonObj(responseSorderUpd, ServiceOrder.class);

		assertThat(serviceOrderRepoService.findAll().size()).isEqualTo(1);

		assertThat(responseSOUpd.getOrderItem().size()).isEqualTo(1);
		responseSOUpd.getOrderItem().stream().forEach(soiElement -> {
			assertThat(soiElement.getState()).isEqualTo(ServiceOrderStateType.INPROGRESS);
			assertThat(soiElement.getService().getServiceSpecification()).isNotNull();
			assertThat(soiElement.getService().getServiceSpecification().getName()).isEqualTo("BundleExampleSpec");
			assertThat(soiElement.getService().getSupportingService().size()).isEqualTo(1);
		});

		assertThat(responseSOUpd.getExpectedCompletionDate()).isNotNull();
		assertThat(responseSOUpd.getNote().size()).isEqualTo( 4 );

		File sspecSO = new File("src/test/resources/TestServiceOrderDates.json");
		InputStream inSO = new FileInputStream(sspecSO);
		String sspectextSO = IOUtils.toString(inSO, "UTF-8");

		ServiceOrder sspeccr1SO = JsonUtils.toJsonObj(sspectextSO, ServiceOrder.class);

		assertThat(sspeccr1SO).isNotNull();

		// Ensure that all Services' end dates were updated correctly
		boolean allSupportingServicesEndDatesUpdatedToServiceOrderExpectedCompletionDate = true;
		List<String> services = serviceRepoService.getServicesFromOrderID(responseSO.getId());

		for (String serviceId : services) {
			Service service = serviceRepoService.findByUuid(serviceId);
			if (!service.getEndDate().equals(responseSOUpd.getExpectedCompletionDate())) {
				allSupportingServicesEndDatesUpdatedToServiceOrderExpectedCompletionDate = false;
				break;
			}
		}
		assertThat(allSupportingServicesEndDatesUpdatedToServiceOrderExpectedCompletionDate).isTrue();
	}

	@WithMockUser(username="osadmin", roles = {"USER"})
	@Test
	public void testVINNISpecServiceOrderCreateAndUpdate() throws UnsupportedEncodingException, IOException, Exception {
		String responseSpecClonedVINNI = mvc.perform(MockMvcRequestBuilders.get("/serviceCatalogManagement/v4/serviceSpecification/cloneVINNI?serviceName=aVINNIService")
				.contentType(MediaType.APPLICATION_JSON)
				.param("addServiceTopology", "true")
				.param("addServiceRequirements", "true")
				.param("addServiceExposureLevel1", "true")
				.param("addServiceExposureLevel2", "true")
				.param("addServiceExposureLevel3", "true")
				.param("addServiceExposureLevel4", "true")
				.param("addServiceMonitoring", "true")
				.param("addServiceTesting", "true")
				.param("addServiceVNF", "true")
				.param("addServiceNSD", "true")
				.content( JsonUtils.toJson( "" ) ))
			    .andExpect(status().isOk())
			    .andExpect(content().contentTypeCompatibleWith(MediaType.APPLICATION_JSON))
	    	    .andExpect(status().isOk())
	    	    .andReturn().getResponse().getContentAsString();

		ServiceSpecification clonedSpec = JsonUtils.toJsonObj( responseSpecClonedVINNI,  ServiceSpecification.class);
		assertThat( clonedSpec.getName() ).isEqualTo( "aVINNIService" );	
		
	}
	
	
	private ServiceSpecification createServiceSpec( ServiceSpecificationCreate sspeccr1)
			throws Exception {

		String responseSpec = mvc
				.perform(MockMvcRequestBuilders.post("/serviceCatalogManagement/v4/serviceSpecification")
			            .with( SecurityMockMvcRequestPostProcessors.csrf())
						.contentType(MediaType.APPLICATION_JSON).content(JsonUtils.toJson(sspeccr1)))
				.andExpect(status().isOk()).andExpect(content().contentTypeCompatibleWith(MediaType.APPLICATION_JSON))
				.andExpect(status().isOk()).andReturn().getResponse().getContentAsString();
		ServiceSpecification responsesSpec1 = JsonUtils.toJsonObj(responseSpec, ServiceSpecification.class);
		logger.info("createServiceSpec = " + responseSpec);
		return responsesSpec1;
	}

	private LogicalResourceSpecification createLogicalResourceSpec() throws Exception {
		File sspec = new File("src/test/resources/testResourceSpec.json");
		InputStream in = new FileInputStream(sspec);
		String sspectext = IOUtils.toString(in, "UTF-8");
		ResourceSpecificationCreate sspeccr1 = JsonUtils.toJsonObj(sspectext, ResourceSpecificationCreate.class);

		URI url = new URI("/resourceCatalogManagement/v4/logicalResourceSpec");

		String responseSpec = mvc
				.perform(MockMvcRequestBuilders.post(url).contentType(MediaType.APPLICATION_JSON)
						.content(JsonUtils.toJson(sspeccr1)))
				.andExpect(status().isOk()).andExpect(content().contentTypeCompatibleWith(MediaType.APPLICATION_JSON))
				.andExpect(status().isOk()).andReturn().getResponse().getContentAsString();

		LogicalResourceSpecification responsesSpec1;

		responsesSpec1 = JsonUtils.toJsonObj(responseSpec, LogicalResourceSpecification.class);

		logger.info("createResourceSpec = " + responseSpec);
		return responsesSpec1;
	}


}
