/** @file proto.h
 *
 * @brief Library to implement simple network protocol
 *
 * CRSP is a protocol to send requests to CRSP server. CRSP server stores
 * information about CDPs, periodically renews CRLs.
 *
 * The CRSP protocol supposes request/answer method. Each request must have an
 * answer. The CRSP server is synchronous. It means that server will answer
 * immediately or nearly immediately. It can plans a long-time operations but
 * it sends answer to client immediately. For example client asks for status
 * of specified CDP but server has no such CDP in its database. So server will
 * answer with status something like "has no such CDP yet" immediately but it
 * schedules the long-time task to get CDP information. Later client can send
 * the same request but now server already has a status for specified CDP and
 * answers with correspondent status.
 *
 * Each CRSP protocol message (request or answer) has the same structure:
 *
 * [ CRSP header ]
 * [ CRSP first parameter's header ]
 * [ ... ]
 * [ CRSP n-th parameter's header ]
 * [ First parameter's data ]
 * [ ... ]
 * [ N-th parameter's data ]
 *
 * The length of CRSP message can vary. CRSP header has constant length and
 * contains total length of whole message and number of parameters. It also
 * contains magic number, CRSP version number, CRSP command, status and
 * request ID (to identify request/answer). There are parameter header for each
 * parameter. Parameter's header contains parameter type and length of
 * parameter. After parameter headers array the parameter's data follows in
 * a sequence.
 */


#ifndef _faux_msg_h
#define _faux_msg_h

#include <stdint.h>
#include <signal.h>
#include <faux/faux.h>
#include <faux/list.h>
#include <faux/net.h>

typedef struct faux_msg_s faux_msg_t;

// Debug variable. BOOL_TRUE for debug and BOOL_FALSE to switch debug off
extern bool_t faux_msg_debug_flag;


/** @brief Parameter header
 */
typedef struct faux_phdr_s {
	uint16_t param_type; // Parameter type
	uint8_t reserved[2];
	uint32_t param_len; // Length of parameter (not including header)
} faux_phdr_t;


/** @brief Message header
 */
typedef struct faux_hdr_s {
	uint32_t magic; // Magic number
	uint8_t major; // Major protocol version number
	uint8_t minor; // Minor protocol version number
	uint16_t cmd; // Command
	uint32_t status; // Status
	uint32_t req_id; // Some abstract ID of request. Identifies request/answer
	uint32_t param_num; // Number of parameters
	uint32_t len; // Length of whole message (including header)
	faux_phdr_t phdr[]; // Parameter headers (unknown length)
} faux_hdr_t;


C_DECL_BEGIN

// Parameter functions
void faux_phdr_set_type(faux_phdr_t *phdr, uint16_t param_type);
uint16_t faux_phdr_get_type(const faux_phdr_t *phdr);
void faux_phdr_set_len(faux_phdr_t *phdr, uint32_t param_len);
uint32_t faux_phdr_get_len(const faux_phdr_t *phdr);

// Message functions
faux_msg_t *faux_msg_new(uint32_t magic, uint8_t major, uint8_t minor);
void faux_msg_free(faux_msg_t *msg);
void faux_msg_set_cmd(faux_msg_t *msg, uint16_t cmd);
uint16_t faux_msg_get_cmd(const faux_msg_t *msg);
void faux_msg_set_status(faux_msg_t *msg, uint32_t status);
uint32_t faux_msg_get_status(const faux_msg_t *msg);
void faux_msg_set_req_id(faux_msg_t *msg, uint32_t req_id);
uint32_t faux_msg_get_req_id(const faux_msg_t *msg);
uint32_t faux_msg_get_param_num(const faux_msg_t *msg);
int faux_msg_get_len(const faux_msg_t *msg);
uint32_t faux_msg_get_magic(const faux_msg_t *msg);
int faux_msg_get_major(const faux_msg_t *msg);
int faux_msg_get_minor(const faux_msg_t *msg);
ssize_t faux_msg_add_param(faux_msg_t *msg, uint16_t type,
	const void *buf, size_t len);
faux_list_node_t *faux_msg_init_param_iter(const faux_msg_t *msg);
faux_phdr_t *faux_msg_get_param_each(faux_list_node_t **node,
	uint16_t *param_type, void **param_data, uint32_t *param_len);
faux_phdr_t *faux_msg_get_param_by_index(const faux_msg_t *msg, unsigned int index,
	uint16_t *param_type, void **param_data, uint32_t *param_len);
faux_phdr_t *faux_msg_get_param_by_type(const faux_msg_t *msg,
	uint16_t param_type, void **param_data, uint32_t *param_len);
ssize_t faux_msg_send(faux_msg_t *msg, faux_net_t *faux_net);
faux_msg_t *faux_msg_recv(faux_net_t *faux_net);
void faux_msg_debug(faux_msg_t *msg);

C_DECL_END

#endif // _faux_msg_h