/*******************************************************************************
 *  ============LICENSE_START=======================================================
 *  kpi-computation-ms
 *  ================================================================================
 *   Copyright (C) 2020 Wipro Limited.
 *   Copyright (C) 2022 Wipro Limited.
 *   ==============================================================================
 *     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.kpi.models;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.junit.Test;
import org.onap.dcaegen2.kpi.computation.FileUtils;

import com.google.gson.JsonObject;
import com.google.gson.JsonParser;


public class ConfigurationTest {
    Configuration configuration = Configuration.getInstance();
    private static final String KPI_CONFIG_FILE = "kpi/kpi_config.json";
    private static final String CBS_CONFIG_FILE = "kpi/cbs_config4.json";

    @Test
    public void configurationTest() {

        List<String> list = new ArrayList<String>();
        list.add("server");
        Map<String, Object> subscribes = new HashMap<>();
        configuration.setStreamsSubscribes(subscribes);
        configuration.setStreamsPublishes(subscribes);
        configuration.setDmaapServers(list);
        configuration.setCg("cg");
        configuration.setCid("cid");
        configuration.setAafPassword("password");
        configuration.setAafUsername("user");
        configuration.setPollingInterval(30);
        configuration.setPollingTimeout(100);
        configuration.setHost("192.168.1.1");
        configuration.setPort(21);
        configuration.setPassword("password");
        configuration.setUsername("user");
        configuration.setDatabasename("database");
        configuration.setEnablessl(true);
        configuration.setCbsPollingInterval(10);
        configuration.setKpiConfig("kpi config");
        assertEquals("cg", configuration.getCg());
        assertEquals("cid", configuration.getCid());
        assertEquals("user", configuration.getAafUsername());
        assertEquals("password", configuration.getAafPassword());
        assertEquals(30, configuration.getPollingInterval());
        assertEquals(100, configuration.getPollingTimeout());
        assertEquals(list, configuration.getDmaapServers());
        assertEquals("192.168.1.1", configuration.getHost());
        assertEquals(21, configuration.getPort());
        assertEquals("user", configuration.getUsername());
        assertEquals("password", configuration.getPassword());
        assertEquals("database", configuration.getDatabasename());
        assertEquals(true, configuration.isEnablessl());
        assertEquals("kpi config", configuration.getKpiConfig());
        assertEquals(10, configuration.getCbsPollingInterval());
    }
    @Test
    public void updateConfigFromPolicyTest() {
        String strKpiConfig = FileUtils.getFileContents(KPI_CONFIG_FILE);
        configuration.setKpiConfig(strKpiConfig);
        assertEquals(strKpiConfig, configuration.getKpiConfig());
    }
    @Test
    public void testNullFields() {
        String strCbsConfig = FileUtils.getFileContents(CBS_CONFIG_FILE);
        JsonObject jsonObject = new JsonParser().parse(strCbsConfig).getAsJsonObject().getAsJsonObject("config");
        Configuration config = new Configuration();
        config.updateConfigurationFromJsonObject(jsonObject);
        assertNull(config.getAafUsername());
        assertNull(config.getAafPassword());
    }
}