package xiaozhi.modules.parent.mqtt;

import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

import lombok.RequiredArgsConstructor;
import xiaozhi.modules.parent.service.ParentTaskService;

@Component
@RequiredArgsConstructor
public class ParentDeviceOfflineListener {
    private final ParentTaskService parentTaskService;

    @Async("taskExecutor")
    @EventListener
    public void onOffline(ParentDeviceOfflineEvent event) {
        if (event == null) {
            return;
        }
        parentTaskService.closeRunningForOffline(event.macAddress());
    }
}