mirror of
https://github.com/emqx/neuron.git
synced 2026-10-19 05:51:27 +08:00
fengzero
292 lines
9.4 KiB
C
292 lines
9.4 KiB
C
/**
|
|
* NEURON IIoT System for Industry 4.0
|
|
* Copyright (C) 2020-2022 EMQ Technologies Co., Ltd All rights reserved.
|
|
*
|
|
* This program is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 3 of the License, or (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License
|
|
* along with this program; if not, write to the Free Software Foundation,
|
|
* Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
**/
|
|
|
|
#include <jansson.h>
|
|
|
|
#include "neuron.h"
|
|
#include "utils/log.h"
|
|
|
|
#include "json_rw.h"
|
|
#include "plugin_ekuiper.h"
|
|
|
|
int wrap_tag_data(neu_json_read_resp_tag_t *json_tag,
|
|
neu_resp_tag_value_t * tag_value)
|
|
{
|
|
if (NULL == json_tag || NULL == tag_value) {
|
|
return -1;
|
|
}
|
|
|
|
json_tag->name = tag_value->tag;
|
|
json_tag->error = NEU_ERR_SUCCESS;
|
|
|
|
switch (tag_value->value.type) {
|
|
case NEU_TYPE_INT8:
|
|
json_tag->t = NEU_JSON_INT;
|
|
json_tag->value.val_int = tag_value->value.value.i8;
|
|
break;
|
|
case NEU_TYPE_UINT8:
|
|
json_tag->t = NEU_JSON_INT;
|
|
json_tag->value.val_int = tag_value->value.value.u8;
|
|
break;
|
|
case NEU_TYPE_INT16:
|
|
json_tag->t = NEU_JSON_INT;
|
|
json_tag->value.val_int = tag_value->value.value.i16;
|
|
break;
|
|
case NEU_TYPE_WORD:
|
|
case NEU_TYPE_UINT16:
|
|
json_tag->t = NEU_JSON_INT;
|
|
json_tag->value.val_int = tag_value->value.value.u16;
|
|
break;
|
|
case NEU_TYPE_INT32:
|
|
json_tag->t = NEU_JSON_INT;
|
|
json_tag->value.val_int = tag_value->value.value.i32;
|
|
break;
|
|
case NEU_TYPE_DWORD:
|
|
case NEU_TYPE_UINT32:
|
|
json_tag->t = NEU_JSON_INT;
|
|
json_tag->value.val_int = tag_value->value.value.u32;
|
|
break;
|
|
case NEU_TYPE_INT64:
|
|
json_tag->t = NEU_JSON_INT;
|
|
json_tag->value.val_int = tag_value->value.value.i64;
|
|
break;
|
|
case NEU_TYPE_LWORD:
|
|
case NEU_TYPE_UINT64:
|
|
json_tag->t = NEU_JSON_INT;
|
|
json_tag->value.val_int = tag_value->value.value.u64;
|
|
break;
|
|
case NEU_TYPE_FLOAT:
|
|
json_tag->t = NEU_JSON_FLOAT;
|
|
json_tag->value.val_float = tag_value->value.value.f32;
|
|
break;
|
|
case NEU_TYPE_DOUBLE:
|
|
json_tag->t = NEU_JSON_DOUBLE;
|
|
json_tag->value.val_double = tag_value->value.value.d64;
|
|
break;
|
|
case NEU_TYPE_BIT:
|
|
json_tag->t = NEU_JSON_BIT;
|
|
json_tag->value.val_bit = tag_value->value.value.u8;
|
|
break;
|
|
case NEU_TYPE_BOOL:
|
|
json_tag->t = NEU_JSON_BOOL;
|
|
json_tag->value.val_bool = tag_value->value.value.boolean;
|
|
break;
|
|
case NEU_TYPE_STRING:
|
|
json_tag->t = NEU_JSON_STR;
|
|
json_tag->value.val_str = tag_value->value.value.str;
|
|
break;
|
|
case NEU_TYPE_ERROR:
|
|
json_tag->t = NEU_JSON_INT;
|
|
json_tag->value.val_int = tag_value->value.value.i32;
|
|
json_tag->error = tag_value->value.value.i32;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
int json_encode_read_resp_header(void *json_object, void *param)
|
|
{
|
|
int ret = 0;
|
|
json_read_resp_header_t *header = param;
|
|
|
|
neu_json_elem_t resp_elems[] = { {
|
|
.name = "node_name",
|
|
.t = NEU_JSON_STR,
|
|
.v.val_str = header->node_name,
|
|
},
|
|
{
|
|
.name = "group_name",
|
|
.t = NEU_JSON_STR,
|
|
.v.val_str = header->group_name,
|
|
},
|
|
{
|
|
.name = "timestamp",
|
|
.t = NEU_JSON_INT,
|
|
.v.val_int = header->timestamp,
|
|
} };
|
|
ret = neu_json_encode_field(json_object, resp_elems,
|
|
NEU_JSON_ELEM_SIZE(resp_elems));
|
|
|
|
return ret;
|
|
}
|
|
|
|
int json_encode_read_resp_tags(void *json_object, void *param)
|
|
{
|
|
int ret = 0;
|
|
json_read_resp_t * resp = param;
|
|
neu_plugin_t * plugin = resp->plugin;
|
|
neu_reqresp_trans_data_t *trans_data = resp->trans_data;
|
|
void * values_object = NULL;
|
|
void * errors_object = NULL;
|
|
|
|
values_object = neu_json_encode_new();
|
|
if (NULL == values_object) {
|
|
plog_error(plugin, "ekuiper cannot allocate json object");
|
|
return -1;
|
|
}
|
|
errors_object = neu_json_encode_new();
|
|
if (NULL == errors_object) {
|
|
plog_error(plugin, "ekuiper cannot allocate json object");
|
|
json_decref(values_object);
|
|
return -1;
|
|
}
|
|
|
|
for (int i = 0; i < trans_data->n_tag; i++) {
|
|
neu_json_read_resp_tag_t json_tag = { 0 };
|
|
|
|
if (0 != wrap_tag_data(&json_tag, &trans_data->tags[i])) {
|
|
continue; // ignore
|
|
}
|
|
|
|
neu_json_elem_t tag_elem = {
|
|
.name = json_tag.name,
|
|
.t = json_tag.t,
|
|
.v = json_tag.value,
|
|
.precision = trans_data->tags[i].value.precision,
|
|
};
|
|
|
|
ret = neu_json_encode_field((0 != json_tag.error) ? errors_object
|
|
: values_object,
|
|
&tag_elem, 1);
|
|
if (0 != ret) {
|
|
json_decref(errors_object);
|
|
json_decref(values_object);
|
|
return ret;
|
|
}
|
|
}
|
|
|
|
neu_json_elem_t resp_elems[] = { {
|
|
.name = "values",
|
|
.t = NEU_JSON_OBJECT,
|
|
.v.val_object = values_object,
|
|
},
|
|
{
|
|
.name = "errors",
|
|
.t = NEU_JSON_OBJECT,
|
|
.v.val_object = errors_object,
|
|
|
|
} };
|
|
// steals `values_object` and `errors_object`
|
|
ret = neu_json_encode_field(json_object, resp_elems,
|
|
NEU_JSON_ELEM_SIZE(resp_elems));
|
|
|
|
return ret;
|
|
}
|
|
|
|
int json_encode_read_resp(void *json_object, void *param)
|
|
{
|
|
int ret = 0;
|
|
json_read_resp_t * resp = param;
|
|
neu_plugin_t * plugin = resp->plugin;
|
|
neu_reqresp_trans_data_t *trans_data = resp->trans_data;
|
|
|
|
json_read_resp_header_t header = { .group_name = trans_data->group,
|
|
.node_name = trans_data->driver,
|
|
.timestamp = trans_data->timestamp };
|
|
|
|
ret = json_encode_read_resp_header(json_object, &header);
|
|
if (0 != ret) {
|
|
plog_error(plugin,
|
|
"ekuiper fail encode data header node:%s group:%s, %" PRIu64,
|
|
header.node_name, header.group_name, header.timestamp);
|
|
return ret;
|
|
}
|
|
|
|
ret = json_encode_read_resp_tags(json_object, param);
|
|
|
|
return ret;
|
|
}
|
|
|
|
int json_decode_write_req(char *buf, size_t len, json_write_req_t **result)
|
|
{
|
|
int ret = 0;
|
|
void * json_obj = NULL;
|
|
json_write_req_t *req = calloc(1, sizeof(json_write_req_t));
|
|
if (req == NULL) {
|
|
return -1;
|
|
}
|
|
|
|
json_obj = neu_json_decode_newb(buf, len);
|
|
if (NULL == json_obj) {
|
|
goto decode_fail;
|
|
}
|
|
|
|
neu_json_elem_t req_elems[] = {
|
|
{
|
|
.name = "node_name",
|
|
.t = NEU_JSON_STR,
|
|
},
|
|
{
|
|
.name = "group_name",
|
|
.t = NEU_JSON_STR,
|
|
},
|
|
{
|
|
.name = "tag_name",
|
|
.t = NEU_JSON_STR,
|
|
},
|
|
{
|
|
.name = "value",
|
|
.t = NEU_JSON_VALUE,
|
|
},
|
|
};
|
|
ret = neu_json_decode_by_json(json_obj, NEU_JSON_ELEM_SIZE(req_elems),
|
|
req_elems);
|
|
if (ret != 0) {
|
|
goto decode_fail;
|
|
}
|
|
|
|
req->node_name = req_elems[0].v.val_str;
|
|
req->group_name = req_elems[1].v.val_str;
|
|
req->tag_name = req_elems[2].v.val_str;
|
|
req->t = req_elems[3].t;
|
|
req->value = req_elems[3].v;
|
|
|
|
*result = req;
|
|
goto decode_exit;
|
|
|
|
decode_fail:
|
|
free(req);
|
|
ret = -1;
|
|
|
|
decode_exit:
|
|
if (json_obj != NULL) {
|
|
neu_json_decode_free(json_obj);
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
void json_decode_write_req_free(json_write_req_t *req)
|
|
{
|
|
if (NULL == req) {
|
|
return;
|
|
}
|
|
|
|
free(req->group_name);
|
|
free(req->node_name);
|
|
free(req->tag_name);
|
|
if (req->t == NEU_JSON_STR) {
|
|
free(req->value.val_str);
|
|
}
|
|
|
|
free(req);
|
|
}
|