package com.zy.influxdb.config;

import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.InfluxDBClientFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@ConditionalOnProperty(value = "influxdb3.enabled", havingValue = "true", matchIfMissing = true)
@EnableConfigurationProperties(InfluxDBProperties.class)
public class InfluxDBAutoConfiguration {

    private static final Logger logger = LoggerFactory.getLogger(InfluxDBAutoConfiguration.class);


    @Bean(destroyMethod = "close")
    public InfluxDBClient influxDBClient(InfluxDBProperties influxDBProperties) throws Exception{
        return InfluxDBClientFactory.create(influxDBProperties.getUrl(), influxDBProperties.getToken().toCharArray(), influxDBProperties.getDatabase());
    }
}