package archaius;

import com.netflix.config.*;
import com.netflix.config.sources.JDBCConfigurationSource;
import com.netflix.config.sources.URLConfigurationSource;
import org.postgresql.ds.PGPoolingDataSource;

import java.net.URL;

public class Main {
    public static void main(String[] args) throws Exception {

        PGPoolingDataSource dataSource1 = new PGPoolingDataSource();
        PGPoolingDataSource dataSource2 = new PGPoolingDataSource();

        AbstractPollingScheduler scheduler = new FixedDelayPollingScheduler();
        URL githubUrlProperties = new URL("https://raw.githubusercontent.com/Stason1o/Java-SpringBoot-App/master/src/main/resources/application.properties");

//        dataSource.setUrl("jdbc:postgresql://localhost:5432/archaius");
        dataSource1.setServerName("localhost");
        dataSource1.setDatabaseName("archaius");
        dataSource1.setUser("root");
        dataSource1.setPassword("1111");
        dataSource1.setPortNumber(5432);

        dataSource2.setServerName("localhost");
        dataSource2.setDatabaseName("archaius2");
        dataSource2.setUser("root");
        dataSource2.setPassword("1111");
        dataSource2.setPortNumber(5432);

        PolledConfigurationSource databaseConfigurationSource2 = new JDBCConfigurationSource(dataSource1,
                "Select distinct key, value from archaius_properties", "key", "value");

        PolledConfigurationSource databaseConfigurationSource1 = new JDBCConfigurationSource(dataSource1,
                "Select distinct key, value from archaius_properties", "key", "value");


        PolledConfigurationSource fileSource =
                new URLConfigurationSource(githubUrlProperties);

        DynamicConfiguration fileConfig = new DynamicConfiguration(fileSource, scheduler);
        DynamicConfiguration databaseConfig = new DynamicConfiguration(databaseConfigurationSource1, scheduler);
        DynamicConfiguration databaseConfig2 = new DynamicConfiguration(databaseConfigurationSource2, scheduler);

        ConcurrentCompositeConfiguration finalConfiguration = new ConcurrentCompositeConfiguration();
        finalConfiguration.addConfiguration(databaseConfig2);
        finalConfiguration.addConfiguration(databaseConfig);
        finalConfiguration.addConfiguration(fileConfig);

        ConfigurationManager.install(finalConfiguration);

        System.out.println(DynamicPropertyFactory.getInstance().getStringProperty("MyNewProperty", "NULL").get());

//        System.out.println(finalConfiguration.getProperty("spring.datasource.username"));

//        System.out.println(databaseConfig.getProperty("test"));
        DynamicStringProperty myProp = DynamicPropertyFactory.getInstance().getStringProperty("spring.datasource.username", "NULL");
        System.out.println(myProp.get());
//        while (true) {
//        scheduler.startPolling(finalConfiguration, finalConfiguration);
//        System.out.println(myProp.getValue());
//            Thread.sleep(10000);
//        }
    }
}