topic publishing issue solved

qgroundcontrol.pro

@@ -28,12 +28,11 @@ QGCROOT  = $$PWD
 DebugBuild {
     DESTDIR  = $${OUT_PWD}/debug
     DEFINES += DEBUG
-    DEFINES += ROS_BRIDGE_DEBUG
-    #DEFINES += ROS_BRIDGE_CLIENT_DEBUG
+    #DEFINES += ROS_BRIDGE_DEBUG
 }
 else {
     DESTDIR  = $${OUT_PWD}/release
-    DEFINES += ROS_BRIDGE_DEBUG
+    #DEFINES += ROS_BRIDGE_DEBUG
     DEFINES += NDEBUG
 }
 

src/comm/ros_bridge/include/RosBridgeClient.cpp

@@ -122,10 +122,6 @@ void RosbridgeWsClient::run()
             // ====================================================================================
             if ( std::chrono::high_resolution_clock::now() > poll_time_point) {
                 poll_time_point = std::chrono::high_resolution_clock::now() + poll_interval;
-#ifdef ROS_BRIDGE_DEBUG
-                std::cout << "Starting new poll." << std::endl;
-                std::cout << "connected: " << this->isConnected->load() << std::endl;
-#endif
                 std::string reset_status_task_name = "reset_status_task";
                 // Add status task if necessary.
                 auto const it = std::find_if(task_list.begin(), task_list.end(),
@@ -133,16 +129,10 @@ void RosbridgeWsClient::run()
                     return t.name == reset_status_task_name;
                 });
                 if ( it == task_list.end() ){
-#ifdef ROS_BRIDGE_DEBUG
-                    std::cout << "Adding status_task" << std::endl;
-#endif
                     // Check connection status.
                     auto status_set = std::make_shared<std::atomic_bool>(false);
                     auto status_client = std::make_shared<WsClient>(this->server_port_path);
                     status_client->on_open = [status_set, this](std::shared_ptr<WsClient::Connection>) {
-#ifdef ROS_BRIDGE_DEBUG
-                            std::cout << "status_client opened" << std::endl;
-#endif
                             this->isConnected->store(true);
                             status_set->store(true);
                     };
@@ -190,9 +180,6 @@ void RosbridgeWsClient::run()
                     });
                     if ( topics_it == task_list.end() ){
                         // Call /rosapi/topics service.
-#ifdef ROS_BRIDGE_DEBUG
-                        std::cout << "Adding reset_topics_task" << std::endl;
-#endif
                         auto topics_set = std::make_shared<std::atomic_bool>(false);
                         this->callService("/rosapi/topics", [topics_set, this](
                                           std::shared_ptr<WsClient::Connection> connection,
@@ -238,9 +225,6 @@ void RosbridgeWsClient::run()
                     });
                     if ( services_it == task_list.end() ){
                         // Call /rosapi/services service.
-#ifdef ROS_BRIDGE_DEBUG
-                        std::cout << "Adding reset_services_task" << std::endl;
-#endif
                         auto services_set = std::make_shared<std::atomic_bool>(false);
                         this->callService("/rosapi/services", [this, services_set](
                                           std::shared_ptr<WsClient::Connection> connection,

src/comm/ros_bridge/include/com_private.cpp

@@ -19,11 +19,7 @@ std::size_t ros_bridge::com_private::getHash(const char *str)
 bool ros_bridge::com_private::getTopic(const ros_bridge::com_private::JsonDoc &doc, std::string &topic)
 {
     if ( doc.HasMember("topic") && doc["topic"].IsString() ){
-
-        rapidjson::StringBuffer sb;
-        rapidjson::Writer<rapidjson::StringBuffer> writer(sb);
-        doc["topic"].Accept(writer);
-        topic = sb.GetString();
+        topic = doc["topic"].GetString();
         return true;
     } else
         return false;
@@ -41,10 +37,7 @@ bool ros_bridge::com_private::removeTopic(ros_bridge::com_private::JsonDoc &doc)
 bool ros_bridge::com_private::getType(const ros_bridge::com_private::JsonDoc &doc, std::string &type)
 {
     if ( doc.HasMember("type") && doc["type"].IsString() ){
-        rapidjson::StringBuffer sb;
-        rapidjson::Writer<rapidjson::StringBuffer> writer(sb);
-        doc["type"].Accept(writer);
-        type = sb.GetString();
+        type = doc["type"].GetString();
         return true;
     } else
         return false;

src/comm/ros_bridge/include/topic_publisher.cpp

@@ -40,6 +40,16 @@ void ros_bridge::com_private::TopicPublisher::start()
             bool ret = com_private::getTopic(*pJsonDoc, topic);
             assert(ret);
             (void)ret;            
+
+
+            // Debug
+            rapidjson::StringBuffer sb;
+            rapidjson::Writer<rapidjson::StringBuffer> writer(sb);
+            pJsonDoc->Accept(writer);
+            std::cout << "message: " << sb.GetString() << std::endl;
+            std::cout << "topic: " << topic << std::endl;
+
+
             ret = com_private::removeTopic(*pJsonDoc);
             assert(ret);
             (void)ret;