syntax = "proto3";

option optimize_for = LITE_RUNTIME;

import "google/protobuf/descriptor.proto";
import "error_msg.proto";

package bhome.msg;


// message format : header(BHMsgHead) + body(variable types)
message BHAddress {
	bytes mq_id = 1; // mqid, uuid
	bytes ip = 2;   //
	int32 port = 3;
}

message ProcInfo
{
	bytes id = 1; // serial number, maybe managed
	bytes name = 2;
	bytes public_info = 3;
	bytes private_info = 4;
}

message BHMsgHead {
	bytes msg_id = 1;
	repeated BHAddress route = 2; // for reply and proxy.
	int64 timestamp = 3;
	int32 type = 4;
	ProcInfo proc = 5;
	bytes topic = 6; // for request route
}

message BHMsgBody {
	bytes data = 1;
}

message BHMsg { // deprecated
	bytes msg_id = 1;
	int64 timestamp = 2;
	int32 type = 3;
	repeated BHAddress route = 4; // for reply and proxy.
	bytes body = 5;
}

enum MsgType {
	kMsgTypeInvalid = 0;

	kMsgTypeCommonReply = 2;

	kMsgTypeRegister= 10;
	// kMsgTypeRegisterReply= 11;
	kMsgTypeHeartbeat = 12;
	// kMsgTypeHeartbeatReply = 13;
	kMsgTypeQueryTopic = 14;
	kMsgTypeQueryTopicReply = 15;
	kMsgTypeRequestTopic = 16;
	kMsgTypeRequestTopicReply = 17;

	kMsgTypePublish = 100;
	// kMsgTypePublishReply = 101;
	kMsgTypeSubscribe = 102;
	// kMsgTypeSubscribeReply = 103;
	kMsgTypeUnsubscribe = 104;
	// kMsgTypeUnsubscribeReply = 105;

}

message MsgPub {
	bytes topic = 1;
	bytes data = 2; 
}

message MsgSub {
	repeated bytes topics = 1;
}

message MsgCommonReply {
	ErrorMsg errmsg = 1;
}

message MsgRequestTopic {
	bytes topic = 1;
	bytes data = 2; 
}

message MsgRequestTopicReply {
	ErrorMsg errmsg = 1;
	bytes data = 2; 
}

message MsgRegister
{
	ProcInfo proc = 1;
	repeated bytes topics = 2;
}

message MsgHeartbeat
{
	ProcInfo proc = 1;
}

message MsgQueryTopic {
	bytes topic = 1;
}

message MsgQueryTopicReply {
	ErrorMsg errmsg = 1;
	BHAddress address = 2;
}

service TopicRPC {
	rpc Query (MsgQueryTopic) returns (MsgQueryTopicReply);
	rpc Request (MsgRequestTopic) returns (MsgQueryTopicReply);
}