#ifndef __AGNI_NBRPC_H
#define __AGNI_NBRPC_H

#include <netbytes.h>

#include <mq_ntf.h>

#include "mmm.h"

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

typedef struct rpc_response
{
	char *result;
	char *error;
  int id;
  char *user;
  char *mask;
  char *server;
} 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);

int rpc_req_set_user(rpc_request *req);
int rpc_resp_set_user(rpc_response *resp);

int rpc_req_set_mask(rpc_request *req);
int rpc_resp_set_mask(rpc_response *resp);

int rpc_req_set_server(rpc_request *req);
int rpc_resp_set_server(rpc_response *resp);

#endif