#ifndef _DS_PROCESS_H_
#define _DS_PROCESS_H_

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

#include "dataserver_inner.h"

#ifdef __cplusplus
extern "C" {
#endif

extern ds_data_callback_fn_t ds_data_fn;

int process_control_msg(ds_connection_t *conn,
        uint8_t *msg_body, size_t size_body, uint8_t *b_resp, size_t b_size);

int process_response_msg(ds_connection_t *conn, uint8_t *msg_body, size_t size_body);

int process_event_msg(ds_connection_t *conn, uint8_t *msg_body, size_t size_body);

int process_data_msg(ds_connection_t *conn, uint8_t *msg_body, size_t size_body);

#ifdef __cplusplus
}
#endif

#endif