syntax = "proto3";

option optimize_for = LITE_RUNTIME;

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;
	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 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;
	kMsgTypeRequest = 1;
	kMsgTypeReply = 2;
	kMsgTypePublish = 3;
	kMsgTypeSubscribe = 4;
	kMsgTypeUnsubscribe = 5;

	kMsgTypeProcQueryTopic = 6;
	kMsgTypeProcQueryTopicReply = 7;
	kMsgTypeProcRegisterTopics = 8;
	kMsgTypeProcHeartbeat = 9;
}

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

message DataSub {
	repeated bytes topics = 1;
}

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

message DataReply {
	bytes data = 1; 
}

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

message DataProcHeartbeat
{
	ProcInfo proc = 1;
}

message DataProcQueryTopic {
	bytes topic = 1;
}

message DataProcQueryTopicReply {
	BHAddress address = 1;
}

service TopicRequestReplyService {
	rpc Request (DataRequest) returns (DataReply);
}