syntax = "proto3";

package aiot;

// 协议格式：
// |  int32  | | enum int32 | |    int32   | |                      []byte                     | |  enum int32  | |  enum int32  | |        []byte        | |  []byte   |
// ----------- -------------- -------------- --------------------------------------------------- ---------------- ---------------- ------------------------ --------------
//   length      receiver        senderId                        deviceProto                           msgType          reqType            msgIdProto            data
//  数据包长度     接受者身份        发送者ID                           设备信息                             消息类型           请求类型               消息ID             消息体
//    4byte
//                                          {|    string    | |     string     | |    string   |}                                 {|  string  | | string  |}
//                                           ---------------- ------------------ ---------------                                   ------------ -----------
//                                               clusterId       masterDeviceId      DeviceIds                                         msgId     PreMsgId
//                                                 集群ID        集群Master设备ID    消息指向的设备ID                                       消息ID     原始消息ID
// 消息接收者
enum RECEIVER {
    // 发送给saas
    TO_SAAS = 0;
    // 发送给集群master
    TO_MASTER = 1;
    // 发送给集群全部成员
    TO_CLUSTER = 2;
    // 发送给集群某一个节点
    TO_NODE = 3;
    // 发送给集群中部分节点
    TO_NODE_LIST = 4;
}

// 消息类型
enum MSG_TYPE {
    // 心跳
    HEART_BEAT = 0;
    // 注册
    REGISTER = 1;
    // 数据上报
    DATA_REPORT = 2;
    // 设备控制
    CONTROL = 3;
    // 业务消息
    BUSINESS = 9;
}

// 请求类型
enum REQ_TYPE {
    // 收到请求
    REQUEST = 0;
    // 收到应答
    RESPONSE = 1;
}

// 设备信息组成
message DeviceProto {
    // 集群ID
    string clusterId = 1;
    // 主节点ID
    string masterDeviceId = 2;
    // 消息接收者
    repeated string deviceIds = 3;
}

// 消息ID
message MsgIdProto {
    string msgId = 1;
    string preMsgId = 2;
}

// 消息体
message BusinessProto {
    string topic = 1;
    bytes request = 2;
    string authorization = 3;
}

// 消息体组成
message Protocol {
    RECEIVER receiver = 1;
    string senderId = 2;
    DeviceProto deviceProto = 3;
    MSG_TYPE msgType = 4;
    REQ_TYPE reqType = 5;
    MsgIdProto msgProto = 6;
    bytes data = 7;
}

// 心跳包
message HeartBeatProto {}

// 注册节点ID
message DeviceNode {
    string deviceId = 1;
}

// 设备注册包
message DeviceRegister {
    // 设备ID
    string deviceId = 1;
    //设备名称
    string serverName = 2;
    // 集群ID
    string clusterId = 3;
    // 集群名称
    string clusterName = 4;
    // 漂移IP
    string virtualIp = 5;
    // 集群节点列表
    repeated DeviceNode deviceList = 6;
}

// 数据上报
message DataReport {
    string dataKey = 1;
    bytes data = 2;
}