/*-
 * ============LICENSE_START=======================================================
 * ONAP - SO
 * ================================================================================
 * 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.onap.so.client.aai;

import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
import static com.github.tomakehurst.wiremock.client.WireMock.delete;
import static com.github.tomakehurst.wiremock.client.WireMock.equalTo;
import static com.github.tomakehurst.wiremock.client.WireMock.get;
import static com.github.tomakehurst.wiremock.client.WireMock.post;
import static com.github.tomakehurst.wiremock.client.WireMock.put;
import static com.github.tomakehurst.wiremock.client.WireMock.urlPathEqualTo;
import static com.github.tomakehurst.wiremock.core.WireMockConfiguration.wireMockConfig;
import static com.shazam.shazamcrest.matcher.Matchers.sameBeanAs;
import static org.hamcrest.CoreMatchers.containsString;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertThat;
import static org.mockito.Mockito.doReturn;
import javax.ws.rs.BadRequestException;
import org.junit.Before;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.ExpectedException;
import org.junit.runner.RunWith;
import org.mockito.InjectMocks;
import org.mockito.Spy;
import org.mockito.junit.MockitoJUnitRunner;
import org.onap.aai.domain.yang.Relationship;
import org.onap.so.client.aai.entities.AAIEdgeLabel;
import org.onap.so.client.aai.entities.AAIResultWrapper;
import org.onap.so.client.aai.entities.uri.AAIResourceUri;
import org.onap.so.client.aai.entities.uri.AAIUriFactory;
import org.onap.so.client.defaultproperties.DefaultAAIPropertiesImpl;
import com.github.tomakehurst.wiremock.admin.NotFoundException;
import com.github.tomakehurst.wiremock.junit.WireMockRule;

@RunWith(MockitoJUnitRunner.class)
public class AAIResourcesClientTest {


    @Rule
    public WireMockRule wireMockRule = new WireMockRule(wireMockConfig().dynamicPort());

    @Rule
    public ExpectedException thrown = ExpectedException.none();


    @Spy
    public AAIClient client;

    @InjectMocks
    public AAIResourcesClient aaiClient = new AAIResourcesClient();

    private String AAI_JSON_FILE_LOCATION = "src/test/resources/__files/aai/query/";

    @Before
    public void beforeTest() {
        doReturn(new DefaultAAIPropertiesImpl(wireMockRule.port())).when(client).getRestProperties();
    }

    @Test
    public void verifyNotExists() {
        AAIResourceUri path = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test");
        wireMockRule.stubFor(get(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build()))
                .willReturn(aResponse().withHeader("Content-Type", "text/plain").withBody("hello").withStatus(404)));
        AAIResourcesClient client = aaiClient;
        boolean result = client.exists(path);
        assertEquals("path not found", false, result);
    }

    @Test
    public void verifyDelete() {
        AAIResourceUri path = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test2");
        wireMockRule.stubFor(get(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build()))
                .willReturn(aResponse().withHeader("Content-Type", "application/json")
                        .withBodyFile("aai/resources/mockObject.json").withStatus(200)));
        wireMockRule.stubFor(delete(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build()))
                .withQueryParam("resource-version", equalTo("1234")).willReturn(aResponse().withStatus(204)));
        AAIResourcesClient client = aaiClient;
        client.delete(path);
    }

    @Test
    public void verifyBasicAuth() {
        AAIResourceUri path = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test3");
        wireMockRule.stubFor(get(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build().toString()))
                .withHeader("Authorization", equalTo("Basic dGVzdDp0ZXN0"))
                .willReturn(aResponse().withHeader("Content-Type", "application/json")
                        .withBodyFile("aai/resources/mockObject.json").withStatus(200)));
        AAIResourcesClient client = aaiClient;
        client.get(path);
    }

    @Test
    public void verifyConnect() {
        AAIResourceUri path = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test2");
        AAIResourceUri path2 = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test3");
        wireMockRule.stubFor(
                put(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build() + "/relationship-list/relationship"))
                        .willReturn(aResponse().withHeader("Content-Type", "application/json").withStatus(200)));

        AAIResourceUri pathClone = path.clone();
        AAIResourcesClient client = aaiClient;
        client.connect(path, path2);
        assertEquals("uri not modified", pathClone.build().toString(), path.build().toString());
    }

    @Test
    public void verifyDisconnect() {
        AAIResourceUri path = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test2");
        AAIResourceUri path2 = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test3");

        wireMockRule.stubFor(
                delete(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build() + "/relationship-list/relationship"))
                        .willReturn(aResponse().withStatus(204)));

        AAIResourceUri pathClone = path.clone();
        AAIResourcesClient client = aaiClient;
        client.disconnect(path, path2);
        assertEquals("uri not modified", pathClone.build().toString(), path.build().toString());
    }

    @Test
    public void verifyPatch() {
        AAIResourceUri path = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test2");

        wireMockRule.stubFor(post(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build()))
                .willReturn(aResponse().withStatus(200)));

        AAIResourcesClient client = aaiClient;

        client.update(path, "{}");
    }

    @Test
    public void verifyNotExistsGet() {
        AAIResourceUri path = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test");
        wireMockRule.stubFor(get(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build()))
                .willReturn(aResponse().withHeader("Content-Type", "text/plain").withBody("hello").withStatus(404)));
        AAIResourcesClient client = aaiClient;
        AAIResultWrapper result = client.get(path);
        assertEquals("is empty", true, result.isEmpty());
    }

    @Test
    public void verifyNotExistsGetException() {
        AAIResourceUri path = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test");
        wireMockRule.stubFor(get(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build()))
                .willReturn(aResponse().withHeader("Content-Type", "text/plain").withBody("hello").withStatus(404)));
        AAIResourcesClient client = aaiClient;
        thrown.expect(NotFoundException.class);
        thrown.expectMessage(containsString(path.build() + " not found in A&AI"));
        AAIResultWrapper result = client.get(path, NotFoundException.class);
    }

    @Test
    public void verifyFailedCallException() {
        AAIResourceUri path = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test");
        wireMockRule.stubFor(get(urlPathEqualTo("/aai/" + AAIVersion.LATEST + path.build())).willReturn(aResponse()
                .withHeader("Content-Type", "text/plain").withBodyFile("aai/error-message.json").withStatus(400)));
        AAIResourcesClient client = aaiClient;

        thrown.expect(BadRequestException.class);
        thrown.expectMessage(containsString(
                "Invalid input performing PUT on url (msg=Precondition Required:resource-version not passed for update of url"));
        AAIResultWrapper result = client.get(path);
    }

    @Test
    public void buildRelationshipTest() {
        AAIResourcesClient client = aaiClient;
        AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, "test");
        Relationship relationship = new Relationship();
        relationship.setRelatedLink(uri.build().toString());
        Relationship actual = client.buildRelationship(uri);
        assertThat("expect equal no label", actual, sameBeanAs(relationship));

        relationship.setRelationshipLabel(AAIEdgeLabel.USES.toString());
        actual = client.buildRelationship(uri, AAIEdgeLabel.USES);
        assertThat("expect equal has label", actual, sameBeanAs(relationship));

    }

}