diff options
Diffstat (limited to 'xwalk/vehicle_instance.cc')
| -rw-r--r-- | xwalk/vehicle_instance.cc | 169 |
1 files changed, 169 insertions, 0 deletions
diff --git a/xwalk/vehicle_instance.cc b/xwalk/vehicle_instance.cc new file mode 100644 index 00000000..4e8027ca --- /dev/null +++ b/xwalk/vehicle_instance.cc @@ -0,0 +1,169 @@ +// Copyright (c) 2014 Intel Corporation. All rights reserved. +// Use of this source code is governed by a BSD-style license that can be +// found in the LICENSE file. + +#include "vehicle_instance.h" + +#include <abstractpropertytype.h> + +#include <algorithm> +#include <string> + +#include "vehicle.h" + +VehicleInstance::VehicleInstance(): vehicle_(new Vehicle(this)) { + DebugOut::setDebugThreshhold(5); +} + +void VehicleInstance::HandleMessage(const char* message) { + DebugOut() << "VehicleInstance message received " << message << endl; + + picojson::value v; + + std::string err; + picojson::parse(v, message, message + strlen(message), &err); + if (!err.empty()) { + return; + } + + std::string method = v.get("method").to_str(); + + Zone::Type amb_zone = 0; + if (v.contains("zone")) { + picojson::value zone = v.get("zone"); + if (zone.is<picojson::object>() && zone.contains("value")) { + picojson::value::array zones = zone.get("value").get<picojson::value::array>(); + amb_zone = ZoneToAMBZone(zones); + DebugOut() << "Converted W3C zone " << picojson::value(zones).to_str() << " to AMB zone: " << amb_zone << endl; + } else { + int callback_id = -1; + if (v.contains("asyncCallId")) + callback_id = v.get("asyncCallId").get<double>(); + PostError(callback_id, method, "invalid_zone"); + return; + } + } + + if (method == "get") { + std::string attribute = v.get("name").to_str(); + int callback_id = v.get("asyncCallId").get<double>(); + + std::transform(attribute.begin(), attribute.begin() + 1, attribute.begin(), + ::toupper); + + vehicle_->Get(attribute, amb_zone, callback_id); + } else if (method == "zones") { + std::string attribute = v.get("name").to_str(); + int callback_id = v.get("asyncCallId").get<double>(); + std::transform(attribute.begin(), attribute.begin() + 1, attribute.begin(), + ::toupper); + + vehicle_->GetZones(attribute, callback_id); + } else if (method == "subscribe") { + std::string attribute = v.get("name").to_str(); + std::transform(attribute.begin(), attribute.begin() + 1, attribute.begin(), + ::toupper); + + vehicle_->Subscribe(attribute, amb_zone); + } else if (method == "unsubscribe") { + std::string attribute = v.get("name").to_str(); + std::transform(attribute.begin(), attribute.begin() + 1, attribute.begin(), + ::toupper); + + vehicle_->Unsubscribe(attribute, amb_zone); + } else if (method == "set") { + std::string attribute = v.get("name").to_str(); + int callback_id = v.get("asyncCallId").get<double>(); + + std::transform(attribute.begin(), attribute.begin() + 1, attribute.begin(), + ::toupper); + + if (!v.get("value").is<picojson::object>()) { + PostError(callback_id, "set", "invalid_operation"); + } + picojson::object value = v.get("value").get<picojson::object>(); + + vehicle_->Set(attribute, value, amb_zone, callback_id); + } else if (method == "supported") { + std::string attribute = v.get("name").to_str(); + int callback_id = v.get("asyncCallId").get<double>(); + + std::transform(attribute.begin(), attribute.begin() + 1, attribute.begin(), + ::toupper); + vehicle_->Supported(attribute, callback_id); + } +} + +void VehicleInstance::HandleSyncMessage(const char* message) { + DebugOut() << "VehicleInstance Sync message received " << message << endl; + picojson::value v; + + std::string err; + picojson::parse(v, message, message + strlen(message), &err); + if (!err.empty()) { + return; + } + + std::string method = v.get("method").to_str(); + std::string objectName = v.get("name").to_str(); + std::string attName = v.get("attName").to_str(); + + std::transform(objectName.begin(), objectName.begin() + 1, objectName.begin(), + ::toupper); + + std::transform(attName.begin(), attName.begin() + 1, attName.begin(), + ::toupper); + + if(method == "availableForRetrieval") + { + std::string reply = vehicle_->AvailableForRetrieval(objectName, attName) ? "true" : "false"; + DebugOut() << "VehicleInstance reply: " << reply << endl; + SendSyncReply(reply.c_str()); + } + +} + +int VehicleInstance::ZoneToAMBZone(picojson::array zones) { + Zone::Type amb_zone = 0; + + for (auto zone : zones) { + std::string tempzone = zone.to_str(); + + std::transform(tempzone.begin(), tempzone.end(), tempzone.begin(), + ::tolower); + + if (tempzone == "front") { + amb_zone |= Zone::Front; + } else if (tempzone == "middle") { + amb_zone |= Zone::Middle; + } else if (tempzone == "right") { + amb_zone |= Zone::Right; + } else if (tempzone == "left") { + amb_zone |= Zone::Left; + } else if (tempzone == "rear") { + amb_zone |= Zone::Rear; + } else if (tempzone == "center") { + amb_zone |= Zone::Center; + } + } + + return amb_zone; +} + +void VehicleInstance::PostError(double callback_id, const std::string& method, + const std::string& error) { + picojson::object msg; + msg["method"] = picojson::value(method); + msg["error"] = picojson::value(true); + msg["value"] = picojson::value(error); + if (callback_id != -1) { + msg["asyncCallId"] = + picojson::value(static_cast<double>(callback_id)); + } + + std::string message = picojson::value(msg).serialize(); + + DebugOut() << "Error Reply message: " << message << endl; + + PostMessage(message.c_str()); +} |