/*
 * ============LICENSE_START=======================================================
 * PNF-REGISTRATION-HANDLER
 * ================================================================================
 * Copyright (C) 2019 NOKIA 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.dcaegen2.services.prh.tasks;

import static org.mockito.ArgumentMatchers.any;
import static org.mockito.BDDMockito.given;
import static org.mockito.Mockito.atLeastOnce;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.verify;

import java.util.Collections;
import java.util.Map;
import javax.net.ssl.SSLException;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
import org.onap.dcaegen2.services.prh.adapter.aai.api.ConsumerDmaapModel;
import org.onap.dcaegen2.services.prh.adapter.aai.api.ImmutableConsumerDmaapModel;
import org.onap.dcaegen2.services.prh.exceptions.PrhTaskException;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

@ExtendWith(MockitoExtension.class)
class ScheduledTasksTest {
    private final static ConsumerDmaapModel DMAAP_MODEL =
            ImmutableConsumerDmaapModel
                    .builder()
                    .correlationId("SomeId")
                    .ipv4("ipv4")
                    .ipv6("ipv6")
                    .build();

    @Mock
    private DmaapPublisherTask readyPublisher;

    @Mock
    private DmaapPublisherTask updatePublisher;

    @Mock
    private DmaapConsumerTask consumer;

    @Mock
    private BbsActionsTask bbsActions;

    @Mock
    private AaiQueryTask aaiQuery;

    @Mock
    private AaiProducerTask aaiProducer;

    private final Map<String, String> context = Collections.emptyMap();

    private ScheduledTasks sut;

    @BeforeEach
    void setUp() {
        sut = new ScheduledTasks(
                consumer,
                readyPublisher,
                updatePublisher,
                aaiQuery,
                aaiProducer,
                bbsActions,
                context);
    }

    @Test
    void whenEmptyResultFromDMaaPConsumer_NotActionShouldBePerformed() throws SSLException, PrhTaskException {
        //given
        given(consumer.execute()).willReturn(Flux.empty());

        //when
        sut.scheduleMainPrhEventTask();

        //then
        verifyThatPnfUpdateWasNotSentToAai();
        verifyIfLogicalLinkWasNotCreated();
        verifyThatPnfModelWasNotSentDmaapPnfReadyTopic();
        verifyThatPnfModelWasNotSentDmaapPnfUpdateTopic();
    }

    @Test
    void whenPnfNotFoundInAai_NotActionShouldBePerformed() throws SSLException, PrhTaskException {
        //given
        given(consumer.execute()).willReturn(Flux.just(DMAAP_MODEL));
        given(aaiQuery.execute(any())).willReturn(Mono.error(new PrhTaskException("404 Not Found")));

        //when
        sut.scheduleMainPrhEventTask();

        verifyThatPnfUpdateWasNotSentToAai();
        verifyIfLogicalLinkWasNotCreated();
        verifyThatPnfModelWasNotSentDmaapPnfReadyTopic();
        verifyThatPnfModelWasNotSentDmaapPnfUpdateTopic();
    }

    @Test
    void whenPnfWithoutService_PatchToAaiAndPostToPnfReadyShouldBePerformed() throws SSLException, PrhTaskException {
        //given
        Mono<ConsumerDmaapModel> consumerModel = Mono.just(DMAAP_MODEL);

        given(aaiProducer.execute(DMAAP_MODEL)).willReturn(consumerModel);
        given(bbsActions.execute(DMAAP_MODEL)).willReturn(consumerModel);


        given(consumer.execute()).willReturn(Flux.just(DMAAP_MODEL));
        given(aaiQuery.execute(any())).willReturn(Mono.just(false));

        //when
        sut.scheduleMainPrhEventTask();

        //then
        verifyThatPnfUpdateWasSentToAai();
        verifyIfLogicalLinkWasCreated();
        verifyThatPnfModelWasSentDmaapPnfReadyTopic();
        verifyThatPnfModelWasNotSentDmaapPnfUpdateTopic();
    }

    @Test
    void whenPnfHasActiveService_OnlyPostToPnfUpdateShouldBePerformed() throws SSLException, PrhTaskException {
        //given
        Mono<ConsumerDmaapModel> consumerModel = Mono.just(DMAAP_MODEL);

        given(consumer.execute()).willReturn(Flux.just(DMAAP_MODEL));
        given(aaiQuery.execute(any())).willReturn(Mono.just(true));
        given(aaiProducer.execute(DMAAP_MODEL)).willReturn(consumerModel);

        //when
        sut.scheduleMainPrhEventTask();

        //then
        verifyThatPnfUpdateWasSentToAai();
        verifyIfLogicalLinkWasNotCreated();
        verifyThatPnfModelWasNotSentDmaapPnfReadyTopic();
        verifyThatPnfModelWasSentDmaapPnfUpdateTopic();
    }

    private void verifyThatPnfModelWasNotSentDmaapPnfReadyTopic() throws PrhTaskException {
        verify(readyPublisher, never()).execute(DMAAP_MODEL);
    }

    private void verifyThatPnfModelWasNotSentDmaapPnfUpdateTopic() throws PrhTaskException {
        verify(updatePublisher, never()).execute(DMAAP_MODEL);
    }

    private void verifyThatPnfModelWasSentDmaapPnfReadyTopic() throws PrhTaskException {
        verify(readyPublisher, atLeastOnce()).execute(DMAAP_MODEL);
    }

    private void verifyThatPnfModelWasSentDmaapPnfUpdateTopic() throws PrhTaskException {
        verify(updatePublisher, atLeastOnce()).execute(DMAAP_MODEL);
    }

    private void verifyThatPnfUpdateWasNotSentToAai() throws PrhTaskException, SSLException {
        verify(aaiProducer, never()).execute(DMAAP_MODEL);
    }

    private void verifyThatPnfUpdateWasSentToAai() throws PrhTaskException, SSLException {
        verify(aaiProducer, atLeastOnce()).execute(DMAAP_MODEL);
    }

    private void verifyIfLogicalLinkWasCreated(){
        verify(bbsActions, atLeastOnce()).execute(DMAAP_MODEL);
    }

    private void verifyIfLogicalLinkWasNotCreated(){
        verify(bbsActions, never()).execute(DMAAP_MODEL);
    }
}