| | |
| | | #include "bhome_msg_api.pb.h" |
| | | using namespace bhome_msg; |
| | | |
| | | static cproc* make_proc(const char* name, const char* id){ |
| | | cproc* pinfo = (cproc*)calloc(1,sizeof(cproc)); |
| | | auto assign = [](char** d, size_t* l, const char* tmp){ |
| | | *l = strlen(tmp); |
| | | *d = (char*)malloc(*l); |
| | | memcpy(*d, tmp, *l); |
| | | }; |
| | | assign(&pinfo->name.str, &pinfo->name.size, name); |
| | | assign(&pinfo->id.str, &pinfo->id.size, id); |
| | | |
| | | return pinfo; |
| | | } |
| | | |
| | | template <class F> void ignoref(F&& f){} |
| | | |
| | | static void pub(const vector<string>& topics){ |
| | | ignoref(pub); |
| | | |
| | | creg reg; |
| | | memset(®, 0, sizeof(reg)); |
| | | reg.pinfo = make_proc("pub", "pubid"); |
| | | reg.topic_pub = cstr_arr_new(topics.size()); |
| | | size_t i = 0; |
| | | for(; i < topics.size(); i++){ |
| | | cstr_arr_add(®.topic_pub, topics.at(0).data(), topics.at(0).size(), i); |
| | | } |
| | | void* handle = bus_client_init(NULL, 0, ®); |
| | | vector<const char*> tpc; |
| | | for(auto& t : topics) tpc.push_back(t.c_str()); |
| | | |
| | | creg* reg = make_creg(make_cproc("pub", "pubid"), |
| | | NULL, 0, &tpc[0], tpc.size(), NULL, 0, NULL, 0); |
| | | |
| | | void* handle = bus_client_init(NULL, 0, reg); |
| | | creg_free(reg); |
| | | |
| | | size_t count = 0; |
| | | string base_msg("test_pub_sub=="); |
| | | this_thread::sleep_for(chrono::seconds(3)); |
| | |
| | | |
| | | int ret = bus_client_publish(handle, i.data(), i.size(), msg.data(), msg.size()); |
| | | printf("======>> bus_client_pubmsg [%s] ret %d\n", msg.c_str(), ret); |
| | | this_thread::sleep_for(chrono::seconds{2}); |
| | | this_thread::sleep_for(chrono::seconds{1}); |
| | | } |
| | | } |
| | | } |
| | |
| | | static void sub(const vector<string>& topics){ |
| | | ignoref(sub); |
| | | |
| | | creg reg; |
| | | memset(®, 0, sizeof(reg)); |
| | | reg.pinfo = make_proc("sub", "subid"); |
| | | vector<const char*> tpc; |
| | | for(auto& t : topics) tpc.push_back(t.c_str()); |
| | | |
| | | reg.topic_sub = cstr_arr_new(topics.size()); |
| | | size_t i = 0; |
| | | for(; i < topics.size(); i++){ |
| | | cstr_arr_add(®.topic_sub, topics.at(0).data(), topics.at(0).size(), i); |
| | | } |
| | | creg* reg = make_creg(make_cproc("sub", "subid"), |
| | | NULL, 0, NULL, 0, &tpc[0], tpc.size(), NULL, 0); |
| | | |
| | | void* handle = bus_client_init(NULL, 0, ®); |
| | | void* handle = bus_client_init(NULL, 0, reg); |
| | | creg_free(reg); |
| | | |
| | | while (true) { |
| | | auto msg = bus_client_get_submsg(handle); |
| | | printf("SUB msg topic [%s] data [%s]\n", msg->topic.str, msg->msg.str); |
| | | printf("SUB msg topic [%s] data [%s]\n", msg->topic, msg->msg); |
| | | free_submsg(msg); |
| | | } |
| | | |
| | | bus_client_free(handle); |
| | |
| | | static void req(const char* topic){ |
| | | ignoref(req); |
| | | |
| | | string strtpc(topic); |
| | | creg reg; |
| | | memset(®, 0, sizeof(reg)); |
| | | reg.pinfo = make_proc("request", "requestid"); |
| | | // reg.channel = cstr_arr_new(1); |
| | | // size_t i = 0; |
| | | // for(; i < 1; i++){ |
| | | // cstr_arr_add(®.topic_pub, topic, strlen(topic), i); |
| | | // } |
| | | void* handle = bus_client_init(NULL, 0, ®); |
| | | const auto topicl = strlen(topic); |
| | | creg* reg = make_creg_from_cproc(make_cproc("request", "requestid")); |
| | | |
| | | void* handle = bus_client_init(NULL, 0, reg); |
| | | creg_free(reg); |
| | | |
| | | size_t count = 0; |
| | | string base_msg("test_request=="); |
| | | string base_msg("test_request==request message -> msg-"); |
| | | this_thread::sleep_for(chrono::seconds(3)); |
| | | while (true) { |
| | | auto msg = base_msg + "request message -> msg-"+to_string(count++); |
| | | auto reqmsg = make_req_msg(strtpc.data(), strtpc.size(), msg.data(), msg.size()); |
| | | auto msg = base_msg + to_string(count++); |
| | | auto reqmsg = make_req_msg(topic, topicl, msg.data(), msg.size()); |
| | | crepmsg* repmsg = NULL; |
| | | if (bus_client_request(handle, reqmsg, &repmsg)){ |
| | | printf("======>> bus_client_reqest [%s] get [%s]\n", msg.c_str(), repmsg->data.str); |
| | | printf("======>> bus_client_reqest [%s] get [%s]\n", msg.c_str(), repmsg->data); |
| | | } |
| | | free_reqmsg(reqmsg); |
| | | free_reply_msg(repmsg); |
| | |
| | | static void reply(const char* topic){ |
| | | ignoref(reply); |
| | | |
| | | creg reg; |
| | | memset(®, 0, sizeof(reg)); |
| | | reg.pinfo = make_proc("reply", "replyid"); |
| | | reg.channel = cstr_arr_new(1); |
| | | cstr_arr_add(®.channel, topic, strlen(topic), 0); |
| | | reg.topic_pub = cstr_arr_new(1); |
| | | cstr_arr_add(®.topic_pub, topic, strlen(topic), 0); |
| | | const auto topicl = strlen(topic); |
| | | vector<const char*> tpc{topic}; |
| | | |
| | | void* handle = bus_client_init(NULL, 0, ®); |
| | | // creg* reg = make_creg(make_cproc("reply", "replyid"), |
| | | // &tpc[0], tpc.size(), &tpc[0], tpc.size(), NULL, 0, NULL, 0); |
| | | |
| | | creg* reg = make_creg_from_cproc(make_cproc("reply", "replyid")); |
| | | creg_add_topic_reply(reg, tpc.data(), tpc.size()); |
| | | creg_add_topic_pub(reg, tpc.data(), tpc.size()); |
| | | |
| | | void* handle = bus_client_init(NULL, 0, reg); |
| | | creg_free(reg); |
| | | |
| | | size_t count = 0; |
| | | this_thread::sleep_for(chrono::seconds(3)); |
| | | while (true) { |
| | |
| | | auto repmsg = make_reply_msg(0, NULL, 0, "recv request", 12); |
| | | bus_client_reply_msg(handle, src, repmsg); |
| | | free_reply_msg(repmsg); |
| | | printf("REPREQ msg [%s] \n", msg->msg.str); |
| | | printf("REPREQ msg [%s] \n", msg->msg); |
| | | |
| | | free_reqmsg(msg); |
| | | this_thread::sleep_for(chrono::seconds{2}); |
| | | // this_thread::sleep_for(chrono::seconds{2}); |
| | | } |
| | | } |
| | | |
| | |
| | | reply(rrtopic); |
| | | |
| | | return 0; |
| | | } |
| | | } |