package com.infoloop.tianting.config;

import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.profile.DefaultProfile;
import com.fasterxml.jackson.dataformat.xml.XmlMapper;
import com.infoloop.tianting.server.StorageService;
import com.infoloop.tianting.server.StorageServiceFactory;
import com.infoloop.tianting.store.LoginCodeStore;
import com.infoloop.tianting.store.WeeklyTaskStore;
import com.infoloop.tianting.store.WxAccessTokenStore;
import com.infoloop.tianting.utils.SmsUtil;
import io.lettuce.core.api.StatefulRedisConnection;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.http.converter.xml.MappingJackson2XmlHttpMessageConverter;

import java.time.Duration;

import static com.infoloop.tianting.constant.ConfigConstants.REDIS_CONNECTION;

@Configuration
@Import({TracingConfig.class})
public class AppConfig {

    // store
    @Bean
    public LoginCodeStore codeStore(@Autowired @Qualifier(REDIS_CONNECTION) final StatefulRedisConnection<String, String> connection) {
        final var commands = connection.sync();
        return new LoginCodeStore(commands, 300);
    }

    @Bean
    public WxAccessTokenStore wxAccessTokenStore(@Autowired @Qualifier(REDIS_CONNECTION) final StatefulRedisConnection<String, String> connection) {
        final var commands = connection.sync();
        return new WxAccessTokenStore(commands);
    }

    @Bean
    public WeeklyTaskStore weeklyTaskStore(@Autowired @Qualifier(REDIS_CONNECTION) final StatefulRedisConnection<String, String> connection) {
        final var commands = connection.sync();
        final var expireSeconds = Duration.ofDays(8).getSeconds();
        return new WeeklyTaskStore(commands, expireSeconds);
    }

    // init bean
    @Bean
    public SmsUtil smsUtil(@Autowired SmsConfig smsConfig) {
        final var profile = DefaultProfile.getProfile(smsConfig.getRegionId(), smsConfig.getAccessKeyId(), smsConfig.getAccessKeySecret());
        DefaultProfile.addEndpoint(smsConfig.getRegionId(), smsConfig.getProduct(), smsConfig.getEndpoint());
        return new SmsUtil(smsConfig, new DefaultAcsClient(profile));
    }

    @Bean
    @ConditionalOnProperty(name = "aliyun.oss.endpoint")
    public StorageService storageService(@Autowired OssConfig ossConfig) {
        return StorageServiceFactory.createStorageService(ossConfig.getEndpoint(), ossConfig.getAccessKeyId(), ossConfig.getAccessKeySecret());
    }

    @Bean
    public MappingJackson2XmlHttpMessageConverter mappingJackson2XmlHttpMessageConverter() {
        return new MappingJackson2XmlHttpMessageConverter(new XmlMapper());
    }

}