/** JSON serializtion for edgeFlex project. * * @author Manuel Pitz * @copyright 2014-2020, Institute for Automation of Complex Power Systems, EONERC * @license GNU General Public License (version 3) * * VILLASnode * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * 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 General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . *********************************************************************************/ #include #include #include using namespace villas::node; int JsonEdgeflexFormat::packSample(json_t **json_smp, const struct sample *smp) { json_error_t err; json_t *json_value; if (smp->length < 1) return -1; struct signal *sig = (struct signal *) vlist_at_safe(smp->signals, 0); if (!sig) return -1; if (sig->type != SignalType::FLOAT) return -1; json_value = json_pack_ex(&err, 0, "{ s: f }", "value", smp->data[0].f ); if (json_value == nullptr) return -1; if (smp->flags & (int) SampleFlags::HAS_TS_ORIGIN) { json_t *json_created = json_integer(time_to_double(&smp->ts.origin) * 1e3); json_object_set_new(json_value, "created", json_created); } *json_smp = json_value; return 0; } int JsonEdgeflexFormat::unpackSample(json_t *json_smp, struct sample *smp) { int ret; json_int_t created = -1; if (smp->capacity < 1) return -1; struct signal *sig = (struct signal *) vlist_at_safe(signals, 0); if (!sig) return -1; if (sig->type != SignalType::FLOAT) return -1; ret = json_unpack(json_smp, "{ s: f, s?: I }", "value", &smp->data[0].f, "created", &created ); if (ret) return ret; if (created >= 0) { smp->ts.origin = time_from_double(created / 1e3); smp->flags |= (int) SampleFlags::HAS_TS_ORIGIN; } return 0; } static char n[] = "json.edgeflex"; static char d[] = "EdgeFlex JSON format"; static FormatPlugin p;