message_json.c File Reference

#include "asterisk.h"
#include "asterisk/json.h"
#include "asterisk/res_aeap_message.h"

Include dependency graph for message_json.c:

Go to the source code of this file.

Data Structures
struct	message_json
	Asterisk external application JSON message type. More...

Macros
#define	JSON_MSG(lvalue, rvalue)

Functions
static int	message_json_construct1 (struct ast_aeap_message *self, const void *params)
static int	message_json_construct2 (struct ast_aeap_message *self, const char *msg_type, const char *name, const char *id, const void *params)
static void *	message_json_data (struct ast_aeap_message *self)
static int	message_json_deserialize (struct ast_aeap_message *self, const void *buf, intmax_t size)
static void	message_json_destruct (struct ast_aeap_message *self)
static const char *	message_json_error_msg (const struct ast_aeap_message *self)
static int	message_json_error_msg_set (struct ast_aeap_message *self, const char *error_msg)
static const char *	message_json_id (const struct ast_aeap_message *self)
static int	message_json_id_set (struct ast_aeap_message *self, const char *id)
static int	message_json_is_request (const struct ast_aeap_message *self)
static int	message_json_is_response (const struct ast_aeap_message *self)
static const char *	message_json_name (const struct ast_aeap_message *self)
static int	message_json_serialize (const struct ast_aeap_message *self, void **buf, intmax_t *size)

Variables
const struct ast_aeap_message_type *	ast_aeap_message_type_json = &message_type_json
	Asterisk external application JSON message type.
static const struct ast_aeap_message_type	message_type_json

Macro Definition Documentation

JSON_MSG

#define JSON_MSG	(		lvalue,
			rvalue
	)

Value:

        struct message_json *lvalue = \
        ((struct message_json *)rvalue)

Definition at line 25 of file message_json.c.

                    {
    /*! The base message type (must be first) */
    struct ast_aeap_message base;
    /*! Underlying JSON data structure */
    struct ast_json *json;
};
 
static int message_json_construct1(struct ast_aeap_message *self, const void *params)
{
    JSON_MSG(msg, self);
 
    msg->json = ast_json_ref((struct ast_json *)params) ?: ast_json_object_create();
 
    return msg->json ? 0 : -1;
}
 
static int message_json_construct2(struct ast_aeap_message *self, const char *msg_type,
    const char *name, const char *id, const void *params)
{
    struct ast_json *msg_data;
    int res;
 
    msg_data = ast_json_pack("{s:s,s:s*}", msg_type, name, "id", id);
 
    if (!msg_data) {
        ast_log(LOG_ERROR, "AEAP message json: failed to create data for '%s: %s'", msg_type, name);
        return -1;
    }
 
    if (params && ast_json_object_update(msg_data, (struct ast_json *)params)) {
        ast_log(LOG_ERROR, "AEAP message json: failed to update data for '%s: %s'", msg_type, name);
        ast_json_unref(msg_data);
        return -1;
    }
 
    res = message_json_construct1(self, msg_data);
    ast_json_unref(msg_data);
    return res;
}
 
static void message_json_destruct(struct ast_aeap_message *self)
{
    JSON_MSG(msg, self);
 
    ast_json_unref(msg->json);
}
 
static int message_json_deserialize(struct ast_aeap_message *self, const void *buf, intmax_t size)
{
    JSON_MSG(msg, self);
 
    msg->json = ast_json_load_buf(buf, size, NULL);
 
    return msg->json ? 0 : -1;
}
 
static int message_json_serialize(const struct ast_aeap_message *self, void **buf, intmax_t *size)
{
    const JSON_MSG(msg, self);
 
    *buf = ast_json_dump_string(msg->json);
    if (!*buf) {
        *size = 0;
        return -1;
    }
 
    *size = strlen(*buf);
 
    return 0;
}
 
static const char *message_json_id(const struct ast_aeap_message *self)
{
    const JSON_MSG(msg, self);
 
    return ast_json_object_string_get(msg->json, "id");
}
 
static int message_json_id_set(struct ast_aeap_message *self, const char *id)
{
    JSON_MSG(msg, self);
 
    if (ast_json_object_set(msg->json, "id", ast_json_string_create(id))) {
        return -1;
    }
 
    return 0;
}
 
static const char *message_json_name(const struct ast_aeap_message *self)
{
    const JSON_MSG(msg, self);
    struct ast_json_iter *iter;
 
    iter = ast_json_object_iter_at(msg->json, "response");
    if (!iter) {
        iter = ast_json_object_iter_at(msg->json, "request");
    }
 
    return iter ? ast_json_string_get(ast_json_object_iter_value(iter)) : "";
}
 
static void *message_json_data(struct ast_aeap_message *self)
{
    JSON_MSG(msg, self);
 
    return msg->json;
}
 
static int message_json_is_request(const struct ast_aeap_message *self)
{
    const JSON_MSG(msg, self);
 
    return ast_json_object_iter_at(msg->json, "request") != NULL;
}
 
static int message_json_is_response(const struct ast_aeap_message *self)
{
    const JSON_MSG(msg, self);
 
    return ast_json_object_iter_at(msg->json, "response") != NULL;
}
 
static const char *message_json_error_msg(const struct ast_aeap_message *self)
{
    const JSON_MSG(msg, self);
 
    return ast_json_object_string_get(msg->json, "error_msg");
}
 
static int message_json_error_msg_set(struct ast_aeap_message *self, const char *error_msg)
{
    JSON_MSG(msg, self);
 
    if (ast_json_object_set(msg->json, "error_msg", ast_json_string_create(error_msg))) {
        return -1;
    }
 
    return 0;
}
 
static const struct ast_aeap_message_type message_type_json = {
    .type_size = sizeof(struct message_json),
    .type_name = "json",
    .serial_type = AST_AEAP_DATA_TYPE_STRING,
    .construct1 = message_json_construct1,
    .construct2 = message_json_construct2,
    .destruct = message_json_destruct,
    .deserialize = message_json_deserialize,
    .serialize = message_json_serialize,
    .id = message_json_id,
    .id_set = message_json_id_set,
    .name = message_json_name,
    .data = message_json_data,
    .is_request = message_json_is_request,
    .is_response = message_json_is_response,
    .error_msg = message_json_error_msg,
    .error_msg_set = message_json_error_msg_set,
};
 
const struct ast_aeap_message_type *ast_aeap_message_type_json = &message_type_json;

Function Documentation

message_json_construct1()

static int message_json_construct1 ( struct ast_aeap_message *  self, const void *  params  )

static

Definition at line 38 of file message_json.c.

{
    JSON_MSG(msg, self);
 
    msg->json = ast_json_ref((struct ast_json *)params) ?: ast_json_object_create();
 
    return msg->json ? 0 : -1;
}

References ast_json_object_create(), ast_json_ref(), and JSON_MSG.

Referenced by message_json_construct2().

message_json_construct2()

static int message_json_construct2 ( struct ast_aeap_message *  self, const char *  msg_type, const char *  name, const char *  id, const void *  params  )

static

Definition at line 47 of file message_json.c.

{
    struct ast_json *msg_data;
    int res;
 
    msg_data = ast_json_pack("{s:s,s:s*}", msg_type, name, "id", id);
 
    if (!msg_data) {
        ast_log(LOG_ERROR, "AEAP message json: failed to create data for '%s: %s'", msg_type, name);
        return -1;
    }
 
    if (params && ast_json_object_update(msg_data, (struct ast_json *)params)) {
        ast_log(LOG_ERROR, "AEAP message json: failed to update data for '%s: %s'", msg_type, name);
        ast_json_unref(msg_data);
        return -1;
    }
 
    res = message_json_construct1(self, msg_data);
    ast_json_unref(msg_data);
    return res;
}

References ast_json_object_update(), ast_json_pack(), ast_json_unref(), ast_log, LOG_ERROR, message_json_construct1(), and name.

message_json_data()

static void * message_json_data ( struct ast_aeap_message *  self )

static

Definition at line 133 of file message_json.c.

{
    JSON_MSG(msg, self);
 
    return msg->json;
}

References JSON_MSG.

message_json_deserialize()

static int message_json_deserialize ( struct ast_aeap_message *  self, const void *  buf, intmax_t  size  )

static

Definition at line 78 of file message_json.c.

{
    JSON_MSG(msg, self);
 
    msg->json = ast_json_load_buf(buf, size, NULL);
 
    return msg->json ? 0 : -1;
}

References ast_json_load_buf(), buf, JSON_MSG, and NULL.

message_json_destruct()

static void message_json_destruct ( struct ast_aeap_message *  self )

static

Definition at line 71 of file message_json.c.

{
    JSON_MSG(msg, self);
 
    ast_json_unref(msg->json);
}

References ast_json_unref(), and JSON_MSG.

message_json_error_msg()

static const char * message_json_error_msg ( const struct ast_aeap_message *  self )

static

Definition at line 154 of file message_json.c.

{
    const JSON_MSG(msg, self);
 
    return ast_json_object_string_get(msg->json, "error_msg");
}

References ast_json_object_string_get, and JSON_MSG.

message_json_error_msg_set()

static int message_json_error_msg_set ( struct ast_aeap_message *  self, const char *  error_msg  )

static

Definition at line 161 of file message_json.c.

{
    JSON_MSG(msg, self);
 
    if (ast_json_object_set(msg->json, "error_msg", ast_json_string_create(error_msg))) {
        return -1;
    }
 
    return 0;
}

References ast_json_object_set(), ast_json_string_create(), and JSON_MSG.

message_json_id()

static const char * message_json_id ( const struct ast_aeap_message *  self )

static

Definition at line 102 of file message_json.c.

{
    const JSON_MSG(msg, self);
 
    return ast_json_object_string_get(msg->json, "id");
}

References ast_json_object_string_get, and JSON_MSG.

message_json_id_set()

static int message_json_id_set ( struct ast_aeap_message *  self, const char *  id  )

static

Definition at line 109 of file message_json.c.

{
    JSON_MSG(msg, self);
 
    if (ast_json_object_set(msg->json, "id", ast_json_string_create(id))) {
        return -1;
    }
 
    return 0;
}

References ast_json_object_set(), ast_json_string_create(), and JSON_MSG.

message_json_is_request()

static int message_json_is_request ( const struct ast_aeap_message *  self )

static

Definition at line 140 of file message_json.c.

{
    const JSON_MSG(msg, self);
 
    return ast_json_object_iter_at(msg->json, "request") != NULL;
}

References ast_json_object_iter_at(), JSON_MSG, and NULL.

message_json_is_response()

static int message_json_is_response ( const struct ast_aeap_message *  self )

static

Definition at line 147 of file message_json.c.

{
    const JSON_MSG(msg, self);
 
    return ast_json_object_iter_at(msg->json, "response") != NULL;
}

References ast_json_object_iter_at(), JSON_MSG, and NULL.

message_json_name()

static const char * message_json_name ( const struct ast_aeap_message *  self )

static

Definition at line 120 of file message_json.c.

{
    const JSON_MSG(msg, self);
    struct ast_json_iter *iter;
 
    iter = ast_json_object_iter_at(msg->json, "response");
    if (!iter) {
        iter = ast_json_object_iter_at(msg->json, "request");
    }
 
    return iter ? ast_json_string_get(ast_json_object_iter_value(iter)) : "";
}

References ast_json_object_iter_at(), ast_json_object_iter_value(), ast_json_string_get(), and JSON_MSG.

message_json_serialize()

static int message_json_serialize ( const struct ast_aeap_message *  self, void **  buf, intmax_t *  size  )

static

Definition at line 87 of file message_json.c.

{
    const JSON_MSG(msg, self);
 
    *buf = ast_json_dump_string(msg->json);
    if (!*buf) {
        *size = 0;
        return -1;
    }
 
    *size = strlen(*buf);
 
    return 0;
}

References ast_json_dump_string, buf, and JSON_MSG.

Variable Documentation

ast_aeap_message_type_json

const struct ast_aeap_message_type* ast_aeap_message_type_json = &message_type_json

Asterisk external application JSON message type.

Definition at line 191 of file message_json.c.

Referenced by AST_TEST_DEFINE(), AST_TEST_DEFINE(), AST_TEST_DEFINE(), handle_request_set(), load_module(), and speech_aeap_send_request().

message_type_json

const struct ast_aeap_message_type message_type_json

static

Definition at line 172 of file message_json.c.

                                                              {
    .type_size = sizeof(struct message_json),
    .type_name = "json",
    .serial_type = AST_AEAP_DATA_TYPE_STRING,
    .construct1 = message_json_construct1,
    .construct2 = message_json_construct2,
    .destruct = message_json_destruct,
    .deserialize = message_json_deserialize,
    .serialize = message_json_serialize,
    .id = message_json_id,
    .id_set = message_json_id_set,
    .name = message_json_name,
    .data = message_json_data,
    .is_request = message_json_is_request,
    .is_response = message_json_is_response,
    .error_msg = message_json_error_msg,
    .error_msg_set = message_json_error_msg_set,
};