server/apis/msg/v2/message.proto

syntax = "proto3";

package api.msg.v2;

import "google/api/annotations.proto";
//import "google/protobuf/any.proto";
import "validate/validate.proto";

option go_package = "w303a/server/apis/msg/v2;v2";
option java_multiple_files = true;
option java_package = "apis.msg.v2";

service Message {

    // 处理消息
    rpc Process(ProcessRequest) returns (ProcessResponse) {
        option (google.api.http) = {
            post: "/apis/v2/messagectx/message/process"
            body: "*"
        };
    }

    // 加载消息
    rpc Load(LoadRequest) returns (LoadResponse) {
        option (google.api.http) = {
            get: "/apis/v2/messagectx/message/load"
        };
    }

}

message ProcessRequest {
    // 消息类型
    int32 messageType = 1;
    // ack id
    int32 ackId = 2 [(validate.rules).int32.gt = 0];
    // 消息内容
    bytes content = 3;
    // 消息id
    int64 msgId = 4 [(validate.rules).int32.gt = 0];
    // 消息状态
    int32 status = 5;
    // 是否是群消息
    bool  isGroup = 6;
    // 接收者id
    string recvId = 7 [(validate.rules).string.uuid = true];
    // 发送者id
    string SendId = 8 [(validate.rules).string.uuid = true];
}

message ProcessResponse {
    int64 msgId = 1;
}

message LoadRequest {}
message LoadResponse {}