diff --git a/src/Network/http/PropertyChangeWebsocket.cxx b/src/Network/http/PropertyChangeWebsocket.cxx index ecfdefbb4..bf4f0856c 100644 --- a/src/Network/http/PropertyChangeWebsocket.cxx +++ b/src/Network/http/PropertyChangeWebsocket.cxx @@ -21,7 +21,13 @@ #include "PropertyChangeWebsocket.hxx" #include "PropertyChangeObserver.hxx" #include "jsonprops.hxx" + #include +#include +#include + +#include +#include
#include
#include <3rdparty/cjson/cJSON.h> @@ -33,6 +39,84 @@ using std::string; static unsigned nextid = 0; +static void setPropertyFromJson(SGPropertyNode_ptr prop, cJSON * json) +{ + if (!prop) return; + if ( NULL == json ) return; + switch ( json->type ) { + case cJSON_String: + prop->setStringValue(json->valuestring); + break; + + case cJSON_Number: + prop->setDoubleValue(json->valuedouble); + break; + + case cJSON_True: + prop->setBoolValue(true); + break; + + case cJSON_False: + prop->setBoolValue(false); + break; + + default: + return; + } +} + +static void handleSetCommand(const string_list& nodes, cJSON* json, WebsocketWriter &writer) +{ + cJSON * value = cJSON_GetObjectItem(json, "value"); + if ( NULL != value ) { + if (nodes.size() > 1) { + SG_LOG(SG_NETWORK, SG_WARN, "httpd: WS set: insufficent values for nodes:" << nodes.size()); + return; + } + + SGPropertyNode_ptr n = fgGetNode(nodes.front()); + if (!n) { + SG_LOG(SG_NETWORK, SG_WARN, "httpd: set '" << nodes.front() << "' not found"); + return; + } + + setPropertyFromJson(n, value); + return; + } + + cJSON * values = cJSON_GetObjectItem(json, "values"); + if ( ( NULL == values ) || ( static_cast(cJSON_GetArraySize(values)) != nodes.size()) ) { + SG_LOG(SG_NETWORK, SG_WARN, "httpd: WS set: mismatched nodes/values sizes:" << nodes.size()); + return; + } + + string_list::const_iterator it; + int i=0; + for (it = nodes.begin(); it != nodes.end(); ++it, ++i) { + SGPropertyNode_ptr n = fgGetNode(*it); + if (!n) { + SG_LOG(SG_NETWORK, SG_WARN, "httpd: get '" << *it << "' not found"); + return; + } + + setPropertyFromJson(n, cJSON_GetArrayItem(values, i)); + } // of nodes iteration +} + +static void handleExecCommand(cJSON* json) +{ + cJSON* name = cJSON_GetObjectItem(json, "fgcommand"); + if ((NULL == name )|| (NULL == name->valuestring)) { + SG_LOG(SG_NETWORK, SG_WARN, "httpd: exec: no fgcommand name"); + return; + } + + SGPropertyNode_ptr arg(new SGPropertyNode); + JSON::addChildrenToProp( json, arg ); + + globals->get_commands()->execute(name->valuestring, arg); +} + PropertyChangeWebsocket::PropertyChangeWebsocket(PropertyChangeObserver * propertyChangeObserver) : id(++nextid), _propertyChangeObserver(propertyChangeObserver) { @@ -48,7 +132,22 @@ void PropertyChangeWebsocket::close() _watchedNodes.clear(); } -void PropertyChangeWebsocket::handleRequest(const HTTPRequest & request, WebsocketWriter &) +void PropertyChangeWebsocket::handleGetCommand(const string_list& nodes, WebsocketWriter &writer) +{ + double t = fgGetDouble("/sim/time/elapsed-sec"); + string_list::const_iterator it; + for (it = nodes.begin(); it != nodes.end(); ++it) { + SGPropertyNode_ptr n = fgGetNode(*it); + if (!n) { + SG_LOG(SG_NETWORK, SG_WARN, "httpd: get '" << *it << "' not found"); + return; + } + + writer.writeText( JSON::toJsonString( false, n, 0, t ) ); + } // of nodes iteration +} + +void PropertyChangeWebsocket::handleRequest(const HTTPRequest & request, WebsocketWriter &writer) { if (request.Content.empty()) return; @@ -71,10 +170,12 @@ void PropertyChangeWebsocket::handleRequest(const HTTPRequest & request, Websock command = j->valuestring; } - string nodeName; + // handle a single node name, or an array of them + string_list nodeNames; j = cJSON_GetObjectItem(json, "node"); - if ( NULL != j && NULL != j->valuestring) nodeName = j->valuestring; - _watchedNodes.handleCommand(command, nodeName, _propertyChangeObserver); + if ( NULL != j && NULL != j->valuestring) { + nodeNames.push_back(j->valuestring); + } cJSON * nodes = cJSON_GetObjectItem(json, "nodes"); if ( NULL != nodes) { @@ -82,10 +183,23 @@ void PropertyChangeWebsocket::handleRequest(const HTTPRequest & request, Websock cJSON * node = cJSON_GetArrayItem(nodes, i); if ( NULL == node) continue; if ( NULL == node->valuestring) continue; - nodeName = node->valuestring; - _watchedNodes.handleCommand(command, nodeName, _propertyChangeObserver); + nodeNames.push_back(node->valuestring); } } + + if (command == "get") { + handleGetCommand(nodeNames, writer); + } else if (command == "set") { + handleSetCommand(nodeNames, json, writer); + } else if (command == "exec") { + handleExecCommand(json); + } else { + string_list::const_iterator it; + for (it = nodeNames.begin(); it != nodeNames.end(); ++it) { + _watchedNodes.handleCommand(command, *it, _propertyChangeObserver); + } + } + cJSON_Delete(json); } } diff --git a/src/Network/http/PropertyChangeWebsocket.hxx b/src/Network/http/PropertyChangeWebsocket.hxx index f195c4917..3f5af11f5 100644 --- a/src/Network/http/PropertyChangeWebsocket.hxx +++ b/src/Network/http/PropertyChangeWebsocket.hxx @@ -43,6 +43,8 @@ private: unsigned id; PropertyChangeObserver * _propertyChangeObserver; + void handleGetCommand(const string_list& nodes, WebsocketWriter &writer); + class WatchedNodesList: public std::vector { public: void handleCommand(const std::string & command, const std::string & node, PropertyChangeObserver * propertyChangeObserver); diff --git a/src/Network/http/jsonprops.cxx b/src/Network/http/jsonprops.cxx index 5e7a4b54d..3bb3633fb 100644 --- a/src/Network/http/jsonprops.cxx +++ b/src/Network/http/jsonprops.cxx @@ -128,6 +128,19 @@ void JSON::toProp(cJSON * json, SGPropertyNode_ptr base) } } +void JSON::addChildrenToProp(cJSON * json, SGPropertyNode_ptr n) +{ + if (NULL == json) return; + if (!n) return; + + cJSON * children = cJSON_GetObjectItem(json, "children"); + if (NULL != children) { + for (int i = 0; i < cJSON_GetArraySize(children); i++) { + toProp(cJSON_GetArrayItem(children, i), n); + } + } +} + string JSON::toJsonString(bool indent, SGPropertyNode_ptr n, int depth, double timestamp ) { cJSON * json = toJson( n, depth, timestamp ); diff --git a/src/Network/http/jsonprops.hxx b/src/Network/http/jsonprops.hxx index 5c2ba1ad9..4f2fcf67f 100644 --- a/src/Network/http/jsonprops.hxx +++ b/src/Network/http/jsonprops.hxx @@ -31,7 +31,9 @@ class JSON { public: static cJSON * toJson(SGPropertyNode_ptr n, int depth, double timestamp = -1.0 ); static std::string toJsonString(bool indent, SGPropertyNode_ptr n, int depth, double timestamp = -1.0 ); + static void toProp(cJSON * json, SGPropertyNode_ptr base); + static void addChildrenToProp(cJSON * json, SGPropertyNode_ptr base); }; } // namespace http