iframe-proxy | Sunbelt Computer Software

History

141 lines (111 loc) · 3.91 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

/* API Response.

* Author: Steffen Vogel <post@steffenvogel.de>

* SPDX-FileCopyrightText: 2014-2023 Institute for Automation of Complex Power Systems, RWTH Aachen University

* SPDX-License-Identifier: Apache-2.0

#include <cmath>

#include <limits>

#include <villas/api/universal.hpp>

#include <villas/exceptions.hpp>

using namespace villas::node::api::universal;

void ChannelList::parse(json_t *json, bool readable, bool writable) {

if (!json_is_array(json))

throw ConfigError(json, "node-config-node-api-signals",

"Signal list of API node must be an array");

clear();

size_t i;

json_t *json_channel;

json_array_foreach(json, i, json_channel) {

auto channel = std::make_shared<Channel>();

channel->parse(json_channel);

channel->readable = readable;

channel->writable = writable;

push_back(channel);

}

void Channel::parse(json_t *json) {

const char *desc = nullptr;

const char *pl = nullptr;

json_t *json_range = nullptr;

json_error_t err;

int ret = json_unpack_ex(json, &err, 0, "{ s?: s, s?: s, s?: o, s?: F }",

"description", &desc, "payload", &pl, "range",

&json_range, "rate", &rate);

if (ret)

throw ConfigError(json, err, "node-config-node-api-signals");

if (desc)

description = desc;

if (pl) {

if (!strcmp(pl, "samples"))

payload = PayloadType::SAMPLES;

else if (!strcmp(pl, "events"))

payload = PayloadType::EVENTS;

else

throw ConfigError(json, "node-config-node-api-signals-payload",

"Invalid payload type: {}", pl);

}

range_min = std::numeric_limits<double>::quiet_NaN();

range_max = std::numeric_limits<double>::quiet_NaN();

if (json_range) {

if (json_is_array(json_range)) {

ret = json_unpack_ex(json, &err, 0, "{ s?: F, s?: F }", "min", &range_min,

"max", &range_max);

if (ret)

throw ConfigError(json, err, "node-config-node-api-signals-range",

"Failed to parse channel range");

} else if (json_is_object(json_range)) {

size_t i;

json_t *json_option;

range_options.clear();

json_array_foreach(json_range, i, json_option) {

if (!json_is_string(json_option))

throw ConfigError(json, err, "node-config-node-api-signals-range",

"Channel range options must be strings");

auto *option = json_string_value(json_option);

range_options.push_back(option);

}

} else

throw ConfigError(json, "node-config-node-api-signals-range",

"Channel range must be an array or object");

}

json_t *Channel::toJson(Signal::Ptr sig) const {

json_error_t err;

json_t *json_ch = json_pack_ex(

&err, 0, "{ s: s, s: s, s: b, s: b }", "id", sig->name.c_str(),

"datatype", signalTypeToString(sig->type).c_str(), "readable",

(int)readable, "writable", (int)writable);

if (!description.empty())

json_object_set(json_ch, "description", json_string(description.c_str()));

if (!sig->unit.empty())

json_object_set(json_ch, "unit", json_string(sig->unit.c_str()));

if (rate > 0)

json_object_set(json_ch, "rate", json_real(rate));

switch (payload) {

case PayloadType::EVENTS:

json_object_set(json_ch, "payload", json_string("events"));

break;

case PayloadType::SAMPLES:

json_object_set(json_ch, "payload", json_string("samples"));

break;

default: {

}

switch (sig->type) {

case SignalType::FLOAT: {

if (std::isnan(range_min) && std::isnan(range_max))

break;

json_t *json_range = json_object();

if (!std::isnan(range_min))

json_object_set(json_range, "min", json_real(range_min));

if (!std::isnan(range_max))

json_object_set(json_range, "max", json_real(range_max));

json_object_set(json_ch, "range", json_range);

break;

}

default: {

}

return json_ch;

}

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

universal.cpp

Latest commit

History

universal.cpp

File metadata and controls