#ifndef __NBRPC_H
#define __NBRPC_H

#include <netbytes.h>

#include "mq_cmd.h"
#include "mq_ntf.h"

typedef struct rpc_request
{
	char *method;
	char *params;
	int id;
} rpc_request;

typedef struct rpc_response
{
	char *result;
	char *error;
	int id;
} rpc_response;

rpc_request*  rpc_req_new(char *method, char *params, int id);
rpc_response* rpc_resp_new(char *result, char *error, int id);
int rpc_req_free(rpc_request   *req);
int rpc_resp_free(rpc_response *resp);
int rpc_req_marsh(   rpc_request   *req,     netbyte_store **nb_req);
int rpc_resp_marsh(  rpc_response  *resp,    netbyte_store **nb_resp);
int rpc_req_unmarsh( netbyte_store *nb_req,  rpc_request   **req);
int rpc_resp_unmarsh(netbyte_store *nb_resp, rpc_response  **resp);

#endif