package cn.iocoder.yudao.module.iot.gateway.service.device.message;

import cn.iocoder.yudao.module.iot.core.enums.IotSerializeTypeEnum;
import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;

/**
 * IoT 设备消息 Service 接口
 *
 * @author 芋道源码
 */
public interface IotDeviceMessageService {

    /**
     * 序列化消息
     *
     * @param message    消息
     * @param productKey 产品 Key
     * @param deviceName 设备名称
     * @return 序列化后的消息内容
     */
    byte[] serializeDeviceMessage(IotDeviceMessage message,
                                  String productKey, String deviceName);

    /**
     * 序列化消息
     *
     * @param message       消息
     * @param serializeType 序列化类型
     * @return 序列化后的消息内容
     */
    byte[] serializeDeviceMessage(IotDeviceMessage message,
                                  IotSerializeTypeEnum serializeType);

    /**
     * 反序列化消息
     *
     * @param bytes      消息内容
     * @param productKey 产品 Key
     * @param deviceName 设备名称
     * @return 反序列化后的消息内容
     */
    IotDeviceMessage deserializeDeviceMessage(byte[] bytes,
                                              String productKey, String deviceName);

    /**
     * 反序列化消息
     *
     * @param bytes         消息内容
     * @param serializeType 序列化类型
     * @return 反序列化后的消息内容
     */
    IotDeviceMessage deserializeDeviceMessage(byte[] bytes, IotSerializeTypeEnum serializeType);

    /**
     * 发送消息
     *
     * @param message    消息
     * @param productKey 产品 Key
     * @param deviceName 设备名称
     * @param serverId   设备连接的 serverId
     */
    void sendDeviceMessage(IotDeviceMessage message,
                           String productKey, String deviceName, String serverId);

}