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

import com.dji.sample.component.websocketWmm.WebSocketServerPlayBack;
import com.dji.sdk.cloudapi.airsense.AirsenseWarning;
import com.dji.sdk.cloudapi.airsense.api.AbstractAirsenseService;
import com.dji.sdk.mqtt.MqttReply;
import com.dji.sdk.mqtt.events.TopicEventsRequest;
import com.dji.sdk.mqtt.events.TopicEventsResponse;
import lombok.extern.slf4j.Slf4j;
import org.springframework.messaging.MessageHeaders;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author wmm
 * @version 0.1
 * @date 2024/5/8
 */
@Service
@Slf4j
public class SDKAirsenseService extends AbstractAirsenseService {

//
//    @Autowired
//    private AbstractLivestreamService livestreamService;
//
//    @Autowired
//    private ObjectMapper mapper;




    @Override
    public TopicEventsResponse<MqttReply> airsenseWarning(TopicEventsRequest<List<AirsenseWarning>> request, MessageHeaders headers){

        WebSocketServerPlayBack.sendInfo(request.toString());
        return new TopicEventsResponse<MqttReply>().setData(MqttReply.success());
    }
}