/*
 * Copyright 2016-2017, Nokia Corporation
 *
 * 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.
 */

package org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.ct;

import com.google.gson.JsonObject;
import com.nokia.cbam.lcm.v32.model.*;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.NokiaSvnfmApplication;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.onap.direct.AAIExternalSystemInfoProvider;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.onap.direct.notification.AAINotificationProcessor;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.vnfm.notification.ReportedAffectedConnectionPoints;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.vnfm.notification.ReportedAffectedCp;
import org.onap.vnfmdriver.model.VimInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.ArrayList;

import static java.util.Optional.of;

@RunWith(value = SpringRunner.class)
@SpringBootTest(classes = NokiaSvnfmApplication.class, webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT)
@ActiveProfiles("direct")
public class CTDirectReal {
    @Autowired
    private AAIExternalSystemInfoProvider externalSystemInfoProvider;
    @Autowired
    private AAINotificationProcessor notificationProcessor;

    /**
     * The following is not a real test, but only start the driver locally.
     * It takes parameters from application-real.properties
     */
    @Test
    public void testBasicWorkflow() throws Exception {
        VimInfo nokia_regionOne = externalSystemInfoProvider.getVimInfo("Nokia_RegionOne");

        VnfLifecycleChangeNotification recievedNot = new VnfLifecycleChangeNotification();
        recievedNot.setVnfInstanceId("CBAM-d8deb02a7a51449dba576ac9eabb55b8");
        ReportedAffectedConnectionPoints affectedConnectionPoints = new ReportedAffectedConnectionPoints();
        recievedNot.setAffectedVirtualLinks(new ArrayList<>());
        AffectedVirtualLink link = new AffectedVirtualLink();
        recievedNot.getAffectedVirtualLinks().add(link);
        link.setId("vlid1");
        link.setChangeType(ChangeType.REMOVED);
        link.setVirtualLinkDescId("vldId1");
        link.setResource(new ResourceHandle());
        link.getResource().setResourceId("netProviderId1");
        link.getResource().setAdditionalData(additionalData("name", "networkName"));
        recievedNot.setAffectedVnfcs(new ArrayList<>());
        AffectedVnfc vnfc = new AffectedVnfc();
        vnfc.setId("myVnfcId1");
        vnfc.setChangeType(ChangeType.ADDED);
        vnfc.setVduId("myVduId");
        vnfc.setStorageResourceIds(new ArrayList<>());
        vnfc.setComputeResource(new ResourceHandle());
        vnfc.getComputeResource().setResourceId("serverProvId1");
        JsonObject additionalData = additionalData("name", "serverName");
        additionalData.addProperty("tenantId", "de8fd0d1d5874503a47b920c10f4322a");
        vnfc.getComputeResource().setAdditionalData(additionalData);
        recievedNot.getAffectedVnfcs().add(vnfc);
        ReportedAffectedCp addedCp = new ReportedAffectedCp();
        addedCp.setCpId("cpId");
        addedCp.setIpAddress("1.2.3.4");
        addedCp.setMacAddress("a:b:c:d:e:f");
        addedCp.setNetworkProviderId("netProviderId1");
        addedCp.setServerProviderId("serverProvId1");
        addedCp.setProviderId("portId");
        addedCp.setTenantId("de8fd0d1d5874503a47b920c10f4322a");
        addedCp.setCpdId("cpdId");
        affectedConnectionPoints.getPost().add(addedCp);
        notificationProcessor.processNotification(recievedNot, null, of(affectedConnectionPoints), "Nokia_RegionOne");
        Thread.sleep(10000000 * 1000L);
    }

    JsonObject additionalData(String key, String value) {
        JsonObject jsonObject = new JsonObject();
        jsonObject.addProperty(key, value);
        return jsonObject;
    }


}