package com.dji.sample.manage.service.impl;

import com.dji.sample.common.util.SpringBeanUtils;
import com.dji.sample.component.mqtt.model.*;
import com.dji.sample.component.mqtt.service.IMessageSenderService;
import com.dji.sample.manage.model.receiver.RequestConfigReceiver;
import com.dji.sample.manage.service.IRequestsConfigService;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.MessageHeaders;
import org.springframework.stereotype.Service;

import java.util.Optional;

/**
 * @author sean
 * @version 1.3
 * @date 2022/11/10
 */
@Service
public class RequestConfigContext {

    @Autowired
    private IMessageSenderService messageSenderService;

    @Autowired
    private ObjectMapper objectMapper;


    /**
     * Handles the config method of the requests topic.
     * @param receiver
     * @param headers
     */
    @ServiceActivator(inputChannel = ChannelName.INBOUND_REQUESTS_CONFIG, outputChannel = ChannelName.OUTBOUND)
    void handleConfig(CommonTopicReceiver receiver, MessageHeaders headers) {
        RequestConfigReceiver configReceiver = objectMapper.convertValue(receiver.getData(), RequestConfigReceiver.class);
        Optional<ConfigScopeEnum> scopeEnumOpt = ConfigScopeEnum.find(configReceiver.getConfigScope());
        String topic = headers.get(MqttHeaders.RECEIVED_TOPIC) + TopicConst._REPLY_SUF;
        CommonTopicResponse.CommonTopicResponseBuilder<Object> build = CommonTopicResponse.builder()
                .tid(receiver.getTid())
                .bid(receiver.getBid())
                .timestamp(System.currentTimeMillis())
                .method(receiver.getMethod());
        if (scopeEnumOpt.isEmpty()) {
            messageSenderService.publish(topic, build.build());
            return;
        }

        IRequestsConfigService requestsConfigService = SpringBeanUtils.getBean(scopeEnumOpt.get().getClazz());
        build.data(requestsConfigService.getConfig());
        messageSenderService.publish(topic, build.build());
    }
}