package cn.flightfeather.supervision.common.utils;

import cn.flightfeather.supervision.common.executor.BgTaskStatus;
import cn.flightfeather.supervision.socket.WebSocketMessage;
import cn.flightfeather.supervision.socket.WebSocketMessageUtil;
import cn.flightfeather.supervision.socket.WebSocketSenderHandler;

public class SendSocketMessageUtil {

    /**
     * 发送后台任务的socket消息
     * @param bgTaskStatus 消息的内容
     */
    public static void sendBgTaskMessage(BgTaskStatus bgTaskStatus) {
        WebSocketMessage webSocketMessage = new WebSocketMessage(Constant.SocketMessageType.BG_TASK.getValue(),
                bgTaskStatus);
        String message = WebSocketMessageUtil.encodeMessage(webSocketMessage);
        WebSocketSenderHandler.getInstance().broadcast(message);
    }
}