#ifndef _c_bus_client_h_
#define _c_bus_client_h_

#include <stddef.h>
#include <stdint.h>

#include "message.h"

#ifdef __cplusplus
extern "C"{
#endif

void* bus_client_init(const char* srvid, const size_t sidsize, const creg* rinfo);
void bus_client_free(void* handle);

struct csubmsg* bus_client_get_submsg(void* handle);

struct creqmsg* bus_client_get_reqmsg(void* handle, void** src);
int bus_client_request(void* handle, struct creqmsg* msg, struct crepmsg** repmsg);
int bus_client_reply_msg(void* handle, void* src, const struct crepmsg* msg);

// test
int bus_client_pubmsg(void* handle, void* data, const size_t size);

#ifdef __cplusplus
}
#endif
#endif