From: Michael Carpenter Date: Tue, 28 Aug 2012 11:12:23 +0000 (-0400) Subject: Fixing a bug where a AMBD property request was being replied as a genivi request X-Git-Tag: submit/release/20120910.223349~47 X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=1b3a120b02d3e5fc619f6aa75743d0c1b0e64c29;p=profile%2Fivi%2Fautomotive-message-broker.git Fixing a bug where a AMBD property request was being replied as a genivi request --- diff --git a/plugins/websocketsink/websocketsink.cpp b/plugins/websocketsink/websocketsink.cpp index 37b3898..35ceda5 100644 --- a/plugins/websocketsink/websocketsink.cpp +++ b/plugins/websocketsink/websocketsink.cpp @@ -32,13 +32,14 @@ -WebSocketSink::WebSocketSink(AbstractRoutingEngine* re,libwebsocket *wsi,string uuid,VehicleProperty::Property property) : AbstractSink(re) +WebSocketSink::WebSocketSink(AbstractRoutingEngine* re,libwebsocket *wsi,string uuid,VehicleProperty::Property property,std::string ambdproperty) : AbstractSink(re) { + m_amdbproperty = ambdproperty; m_uuid = uuid; m_wsi = wsi; m_property = property; m_re = re; - re->subscribeToProperty(property,this); + re->subscribeToProperty(ambdproperty,this); } string WebSocketSink::uuid() { @@ -51,22 +52,10 @@ void WebSocketSink::propertyChanged(VehicleProperty::Property property, boost::a stringstream s; //TODO: Dirty hack hardcoded stuff, jsut to make it work. - string tmpstr = ""; - if (property == VehicleProperty::VehicleSpeed) + std::string tmpstr=""; + if (m_property != property) { - tmpstr = "running_status_speedometer"; - } - else if (property == VehicleProperty::EngineSpeed) - { - tmpstr = "running_status_engine_speed"; - } - else if (property == VehicleProperty::SteeringWheelAngle) - { - tmpstr = "running_status_steering_wheel_angle"; - } - else if (property == VehicleProperty::TransmissionShiftPosition) - { - tmpstr = "running_status_transmission_gear_status"; + tmpstr = m_property; } else { @@ -86,7 +75,7 @@ void WebSocketSink::propertyChanged(VehicleProperty::Property property, boost::a } WebSocketSink::~WebSocketSink() { - m_re->unsubscribeToProperty(m_property,this); + m_re->unsubscribeToProperty(m_amdbproperty,this); } void WebSocketSink::supportedChanged(PropertyList supportedProperties) { diff --git a/plugins/websocketsink/websocketsink.h b/plugins/websocketsink/websocketsink.h index 482095a..40f790c 100644 --- a/plugins/websocketsink/websocketsink.h +++ b/plugins/websocketsink/websocketsink.h @@ -27,13 +27,14 @@ class WebSocketSink : public AbstractSink { public: - WebSocketSink(AbstractRoutingEngine* re,libwebsocket *wsi,string uuid,VehicleProperty::Property property); + WebSocketSink(AbstractRoutingEngine* re,libwebsocket *wsi,string uuid,VehicleProperty::Property property,std::string ambdproperty); ~WebSocketSink(); string uuid() ; void propertyChanged(VehicleProperty::Property property, boost::any value, string uuid); void supportedChanged(PropertyList supportedProperties); PropertyList subscriptions(); private: + string m_amdbproperty; AbstractRoutingEngine *m_re; libwebsocket *m_wsi; string m_uuid; diff --git a/plugins/websocketsink/websocketsinkmanager.cpp b/plugins/websocketsink/websocketsinkmanager.cpp index 75d3e48..426936e 100644 --- a/plugins/websocketsink/websocketsinkmanager.cpp +++ b/plugins/websocketsink/websocketsinkmanager.cpp @@ -54,7 +54,36 @@ WebSocketSinkManager::WebSocketSinkManager(AbstractRoutingEngine* engine):Abstra void WebSocketSinkManager::addSingleShotSink(libwebsocket* socket, VehicleProperty::Property property,string id) { AsyncPropertyRequest velocityRequest; - velocityRequest.property = property; + if (property == "running_status_speedometer") + { + velocityRequest.property = VehicleProperty::VehicleSpeed; + } + else if (property == "running_status_engine_speed") + { + velocityRequest.property = VehicleProperty::EngineSpeed; + } + else if ("running_status_steering_wheel_angle") + { + velocityRequest.property = VehicleProperty::SteeringWheelAngle; + } + else if ("running_status_transmission_gear_status") + { + velocityRequest.property = VehicleProperty::TransmissionShiftPosition; + } + else + { + PropertyList foo = VehicleProperty::capabilities(); + if (ListPlusPlus(&foo).contains(property)) + { + velocityRequest.property = property; + } + else + { + //Invalid property requested. + return; + } + + } velocityRequest.completed = [socket,id,property](AsyncPropertyReply* reply) { printf("Got property:%i\n",boost::any_cast(reply->value)); @@ -63,7 +92,7 @@ void WebSocketSinkManager::addSingleShotSink(libwebsocket* socket, VehicleProper //TODO: Dirty hack hardcoded stuff, jsut to make it work. string tmpstr = ""; - if (property == VehicleProperty::VehicleSpeed) + /*if (property == VehicleProperty::VehicleSpeed) { tmpstr = "running_status_speedometer"; } @@ -90,7 +119,8 @@ void WebSocketSinkManager::addSingleShotSink(libwebsocket* socket, VehicleProper //{ //} - } + }*/ + tmpstr = property; s << "{\"type\":\"methodReply\",\"name\":\"get\",\"data\":[{\"name\":\"" << tmpstr << "\",\"value\":\"" << velocity << "\"}],\"transactionid\":\"" << id << "\"}"; string replystr = s.str(); @@ -134,32 +164,37 @@ void WebSocketSinkManager::addSink(libwebsocket* socket, VehicleProperty::Proper //TODO: Dirty hack hardcoded stuff, jsut to make it work. string tmpstr = ""; - if (property == VehicleProperty::VehicleSpeed) + if (property == "running_status_speedometer") { - tmpstr = "running_status_speedometer"; + tmpstr = VehicleProperty::VehicleSpeed; } - else if (property == VehicleProperty::EngineSpeed) + else if (property == "running_status_engine_speed") { - tmpstr = "running_status_engine_speed"; + tmpstr = VehicleProperty::EngineSpeed; } - else if (property == VehicleProperty::SteeringWheelAngle) + else if ("running_status_steering_wheel_angle") { - tmpstr = "running_status_steering_wheel_angle"; + tmpstr = VehicleProperty::SteeringWheelAngle; } - else if (property == VehicleProperty::TransmissionShiftPosition) + else if ("running_status_transmission_gear_status") { - tmpstr = "running_status_transmission_gear_status"; + tmpstr = VehicleProperty::TransmissionShiftPosition; } else { - tmpstr = property; + PropertyList foo = VehicleProperty::capabilities(); + if (ListPlusPlus(&foo).contains(property)) + { + tmpstr = property; + } + else + { + //Invalid property requested. + return; + } + } - - - - - - s << "{\"type\":\"methodReply\",\"name\":\"subscribe\",\"data\":[\"" << tmpstr << "\"],\"transactionid\":\"" << uuid << "\"}"; + s << "{\"type\":\"methodReply\",\"name\":\"subscribe\",\"data\":[\"" << property << "\"],\"transactionid\":\"" << uuid << "\"}"; string replystr = s.str(); printf("Reply: %s\n",replystr.c_str()); @@ -169,7 +204,7 @@ void WebSocketSinkManager::addSink(libwebsocket* socket, VehicleProperty::Proper strcpy(new_response,replystr.c_str()); libwebsocket_write(socket, (unsigned char*)new_response, strlen(new_response), LWS_WRITE_TEXT); - WebSocketSink *sink = new WebSocketSink(m_engine,socket,uuid,property); + WebSocketSink *sink = new WebSocketSink(m_engine,socket,uuid,property,tmpstr); m_sinkMap[property] = sink; } @@ -302,7 +337,8 @@ static int websocket_callback(struct libwebsocket_context *context,struct libweb { //GetProperty is going to be a singleshot sink. //string arg = arguments.front(); - if (data.front()== "running_status_speedometer") + sinkManager->addSingleShotSink(wsi,data.front(),id); + /*if (data.front()== "running_status_speedometer") { sinkManager->addSingleShotSink(wsi,VehicleProperty::VehicleSpeed,id); } @@ -325,7 +361,7 @@ static int websocket_callback(struct libwebsocket_context *context,struct libweb { sinkManager->addSingleShotSink(wsi,data.front(),id); } - } + }*/ } else { @@ -334,6 +370,8 @@ static int websocket_callback(struct libwebsocket_context *context,struct libweb } else if (name == "subscribe") { + sinkManager->addSink(wsi,data.front(),id); + /* if (data.front()== "running_status_speedometer") { sinkManager->addSink(wsi,VehicleProperty::VehicleSpeed,id); @@ -362,11 +400,12 @@ static int websocket_callback(struct libwebsocket_context *context,struct libweb { DebugOut() << __SMALLFILE__ << ":" << __LINE__ << " Unsupported subscription type:" << data.front(); } - } + }*/ } else if (name == "unsubscribe") { - if (data.front()== "running_status_speedometer") + sinkManager->removeSink(wsi,data.front(),id); + /*if (data.front()== "running_status_speedometer") { sinkManager->removeSink(wsi,VehicleProperty::VehicleSpeed,id); } @@ -394,7 +433,7 @@ static int websocket_callback(struct libwebsocket_context *context,struct libweb //Unsupported unsubscribe DebugOut() << __SMALLFILE__ << ":" << __LINE__ << " Unsupported unsubscription type:" << data.front(); } - } + }*/ } else if (name == "getSupportedEventTypes") {