/*-
 * ============LICENSE_START=======================================================
 * Copyright (C) 2021 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.
 *
 * SPDX-License-Identifier: Apache-2.0
 * ============LICENSE_END=========================================================
 */

package org.onap.policy.clamp.controlloop.models.controlloop.persistence.provider;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.junit.Assert.assertEquals;

import java.time.Instant;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ClElementStatistics;
import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ClElementStatisticsList;
import org.onap.policy.common.utils.coder.Coder;
import org.onap.policy.common.utils.coder.StandardCoder;
import org.onap.policy.common.utils.resources.ResourceUtils;
import org.onap.policy.models.provider.PolicyModelsProviderParameters;
import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;

public class ClElementStatisticsProviderTest {
    private static final String LIST_IS_NULL = ".*. is marked .*ull but is null";
    private static final Coder CODER = new StandardCoder();
    private static final String CL_ELEMENT_STATS_JSON =
        "src/test/resources/providers/TestClElementStatistics.json";

    private static AtomicInteger dbNameCounter = new AtomicInteger();

    private PolicyModelsProviderParameters parameters;
    private ClElementStatisticsProvider clElementStatisticsProvider;
    private ClElementStatisticsList inputClElementStats;
    private String originalJson = ResourceUtils.getResourceAsString(CL_ELEMENT_STATS_JSON);

    /**
     * Set up test ClElement statistics provider.
     */
    @Before
    public void setupDao() throws Exception {

        parameters = new PolicyModelsProviderParameters();
        parameters.setDatabaseDriver("org.h2.Driver");
        parameters.setName("PolicyProviderParameterGroup");
        parameters.setImplementation("org.onap.policy.models.provider.impl.DatabasePolicyModelsProviderImpl");
        parameters.setDatabaseUrl("jdbc:h2:mem:clElementTestDb" + dbNameCounter.getAndIncrement());
        parameters.setDatabaseUser("policy");
        parameters.setDatabasePassword("P01icY");
        parameters.setPersistenceUnit("ToscaConceptTest");

        clElementStatisticsProvider = new ClElementStatisticsProvider(parameters);
        inputClElementStats = CODER.decode(originalJson, ClElementStatisticsList.class);
    }

    @After
    public void teardown() {
        clElementStatisticsProvider.close();
    }

    @Test
    public void testClElementStatisticsCreate() throws Exception {
        assertThatThrownBy(() -> {
            clElementStatisticsProvider.createClElementStatistics(null);
        }).hasMessageMatching(LIST_IS_NULL);

        ClElementStatisticsList createdClElementStats = new ClElementStatisticsList();
        createdClElementStats.setClElementStatistics(clElementStatisticsProvider
            .createClElementStatistics(inputClElementStats.getClElementStatistics()));

        assertEquals(inputClElementStats.toString().replaceAll("\\s+", ""),
            createdClElementStats.toString().replaceAll("\\s+", ""));
    }

    @Test
    public void testGetClElementStatistics() throws Exception {

        List<ClElementStatistics> getResponse;

        //Return empty list when no data present in db
        getResponse = clElementStatisticsProvider.getClElementStatistics(null, null, null,
            null);
        assertThat(getResponse).isEmpty();

        clElementStatisticsProvider.createClElementStatistics(inputClElementStats
            .getClElementStatistics());
        ToscaConceptIdentifier identifier = inputClElementStats.getClElementStatistics().get(0)
            .getParticipantId();
        Instant instant = inputClElementStats.getClElementStatistics().get(0).getTimeStamp();
        String id = inputClElementStats.getClElementStatistics().get(0).getId().toString();
        assertEquals(1, clElementStatisticsProvider.getClElementStatistics(identifier.getName(),
            identifier.getVersion(), id, instant).size());

        assertEquals(1, clElementStatisticsProvider.getFilteredClElementStatistics("name2",
            "1.0.1", null, null, null,
            "DESC", 1).size());
    }
}