🔥 not publishing events anymore

kas-lab · Nov 27, 2023 · 3ea6012 · 3ea6012
1 parent 9dbd626
commit 3ea6012
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 8 deletions.
diff --git a/ros_typedb/ros_typedb/ros_typedb_interface.py b/ros_typedb/ros_typedb/ros_typedb_interface.py
@@ -128,16 +128,14 @@ def init_typedb_interface(
         self.typedb_interface.insert_data_event = self.insert_data_event
         self.typedb_interface.delete_data_event = self.delete_data_event
 
-    def data_event(self, event_type):
-        event = String()
-        event.data = event_type
-        self.event_pub.publish(event)
+    def publish_data_event(self, event_type):
+        self.event_pub.publish(String(data=event_type))
 
     def insert_data_event(self):
-        self.data_event('insert')
+        self.publish_data_event('insert')
 
     def delete_data_event(self):
-        self.data_event('delete')
+        self.publish_data_event('delete')
 
     def on_configure(self, state: State) -> TransitionCallbackReturn:
         self.get_logger().info(self.get_name() + ': on_configure() is called.')

diff --git a/ros_typedb/ros_typedb/typedb_interface.py b/ros_typedb/ros_typedb/typedb_interface.py
@@ -203,7 +203,7 @@ def delete_data_event_wrapper(*args, **kwargs):
     # Events end
 
     # Insert query
-    @insert_data_event_
+    # @insert_data_event_
     def insert_database(self, query):
         result = None
         try:
@@ -214,7 +214,7 @@ def insert_database(self, query):
         return result
 
     # Delete query
-    @delete_data_event_
+    # @delete_data_event_
     def delete_from_database(self, query):
         result = None
         try:

diff --git a/ros_typedb/test/test_ros_typedb_interface.py b/ros_typedb/test/test_ros_typedb_interface.py
@@ -118,6 +118,8 @@ def test_ros_typedb_insert_query(insert_query):
         rclpy.shutdown()
 
 
+@pytest.mark.skip(
+    reason='Events deactivated')
 @pytest.mark.launch(fixture=generate_test_description)
 def test_ros_typedb_insert_event(insert_query):
     rclpy.init()
@@ -165,6 +167,8 @@ def test_ros_typedb_delete_query(insert_query):
         rclpy.shutdown()
 
 
+@pytest.mark.skip(
+    reason='Events deactivated')
 @pytest.mark.launch(fixture=generate_test_description)
 def test_ros_typedb_delete_event(insert_query):
     rclpy.init()