/*-
 * ============LICENSE_START=======================================================
 * appclcm
 * ================================================================================
 * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
 * Modifications Copyright (C) 2019 Nordix Foundation.
 * ================================================================================
 * 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.onap.policy.appclcm;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;

import java.util.HashMap;
import java.util.UUID;

import org.junit.Test;
import org.onap.policy.appclcm.util.Serialization;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class AppcLcmTest {

    private static final Logger logger = LoggerFactory.getLogger(AppcLcmTest.class);

    private static LcmRequestWrapper dmaapRequest;
    private static LcmResponseWrapper dmaapResponse;

    static {
        /*
         * Construct an APPCLCM Request to be Serialized
         */
        dmaapRequest = new LcmRequestWrapper();
        dmaapRequest.setCorrelationId("664be3d2-6c12-4f4b-a3e7-c349acced200" + "-" + "1");
        dmaapRequest.setRpcName("restart");
        dmaapRequest.setType("request");

        dmaapResponse = new LcmResponseWrapper();
        dmaapResponse.setCorrelationId("664be3d2-6c12-4f4b-a3e7-c349acced200" + "-" + "1");
        dmaapResponse.setRpcName("restart");
        dmaapResponse.setType("response");

        LcmRequest appcRequest = new LcmRequest();

        appcRequest.setAction("restart");

        HashMap<String, String> actionIdentifiers = new HashMap<>();
        actionIdentifiers.put("vnf-id", "trial-vnf-003");
        actionIdentifiers.put("vserver-id", "08f6c1f9-99e7-49f3-a662-c62b9f200d79");

        appcRequest.setActionIdentifiers(actionIdentifiers);

        LcmCommonHeader commonHeader = new LcmCommonHeader();
        commonHeader.setRequestId(UUID.fromString("664be3d2-6c12-4f4b-a3e7-c349acced200"));
        commonHeader.setSubRequestId("1");
        commonHeader.setOriginatorId("664be3d2-6c12-4f4b-a3e7-c349acced200");

        appcRequest.setCommonHeader(commonHeader);

        appcRequest.setPayload(null);

        dmaapRequest.setBody(appcRequest);

        /*
         * Construct an APPCLCM Response to be Serialized
         */
        LcmResponse appcResponse = new LcmResponse(appcRequest);
        appcResponse.getStatus().setCode(400);
        appcResponse.getStatus().setMessage("Restart Successful");
        appcResponse.setPayload(null);

        dmaapResponse.setBody(appcResponse);
    }

    @Test
    public void testRequestSerialization() {

        /*
         * Use the gson serializer to obtain json
         */
        String jsonRequest = Serialization.gson.toJson(dmaapRequest, LcmRequestWrapper.class);
        assertNotNull(jsonRequest);

        /*
         * The serializer should have added an extra sub-tag called "input" that wraps the request
         */
        assertTrue(jsonRequest.contains("input"));

        /*
         * The common-header, request-id, and sub-request-id should exist
         */
        assertTrue(jsonRequest.contains("common-header"));
        assertTrue(jsonRequest.contains("request-id"));
        assertTrue(jsonRequest.contains("sub-request-id"));

        /*
         * action-identifiers should exist and contain a vnf-id
         */
        assertTrue(jsonRequest.contains("action-identifiers"));
        assertTrue(jsonRequest.contains("vnf-id"));

        /*
         * The action sub-tag should exist
         */
        assertTrue(jsonRequest.contains("action"));

        logger.debug("Request as JSON: " + jsonRequest + "\n\n");
    }

    @Test
    public void testRequestDeserialization() {

        /*
         * Convert the LCM request object into json so we have a string of json to use for testing
         */
        String jsonRequest = Serialization.gson.toJson(dmaapRequest, LcmRequestWrapper.class);

        /*
         * Use the serializer to convert the json string into a java object
         */
        LcmRequestWrapper dmaapRequest = Serialization.gson.fromJson(jsonRequest, LcmRequestWrapper.class);
        assertNotNull(dmaapRequest);

        /*
         * The type of the DMAAP wrapper should be request
         */
        assertEquals("request", dmaapRequest.getType());

        /*
         * The DMAAP wrapper must have a body as that is the true APPC request
         */
        assertNotNull(dmaapRequest.getBody());
        LcmRequest appcRequest = dmaapRequest.getBody();
        assertNotNull(appcRequest);

        /*
         * The common header should not be null
         */
        assertNotNull(appcRequest.getCommonHeader());

        /*
         * The action should not be null and should be set to restart
         */
        assertNotNull(appcRequest.getAction());
        assertEquals("restart", appcRequest.getAction());

        /*
         * The action-identifiers should not be null and should contain a vnf-id
         */
        assertNotNull(appcRequest.getActionIdentifiers());
        assertNotNull(appcRequest.getActionIdentifiers().get("vnf-id"));

        logger.debug("Request as a Java Object: \n" + appcRequest.toString() + "\n\n");
    }

    @Test
    public void testResponseSerialization() {

        /*
         * Use the serializer to convert the object into json
         */
        String jsonResponse = Serialization.gson.toJson(dmaapResponse, LcmResponseWrapper.class);
        assertNotNull(jsonResponse);

        /*
         * The serializer should have added an extra sub-tag called "input" that wraps the request
         */
        assertTrue(jsonResponse.contains("output"));

        /*
         * The response should contain a common-header, request-id, sub-request-id, and status
         */
        assertTrue(jsonResponse.contains("common-header"));
        assertTrue(jsonResponse.contains("request-id"));
        assertTrue(jsonResponse.contains("sub-request-id"));
        assertTrue(jsonResponse.contains("status"));

        logger.debug("Response as JSON: " + jsonResponse + "\n\n");
    }

    @Test
    public void testResponseDeserialization() {
        /*
         * Convert the LCM response object into json so we have a string of json to use for testing
         */
        String jsonResponse = Serialization.gson.toJson(dmaapResponse, LcmResponseWrapper.class);

        /*
         * Use the serializer to convert the json string into a java object
         */
        LcmResponseWrapper dmaapResponse = Serialization.gson.fromJson(jsonResponse, LcmResponseWrapper.class);
        assertNotNull(dmaapResponse);

        /*
         * The type of the DMAAP wrapper should be response
         */
        assertEquals("response", dmaapResponse.getType());

        /*
         * The DMAAP wrapper must have a body as that is the true APPC response
         */
        assertNotNull(dmaapResponse.getBody());
        LcmResponse appcResponse = dmaapResponse.getBody();
        assertNotNull(appcResponse);

        /*
         * The common header should not be null
         */
        assertNotNull(appcResponse.getCommonHeader());

        /*
         * The status should not be null and the status code should be 400
         */
        assertNotNull(appcResponse.getStatus());
        assertEquals(400, appcResponse.getStatus().getCode());

        logger.debug("Response as a Java Object: \n" + appcResponse.toString() + "\n\n");
    }
}