From ba1e23872dd7bc1d92f3daabe1e60e331036cb44 Mon Sep 17 00:00:00 2001 From: Jacob Gloudemans Date: Sat, 16 Feb 2019 14:54:50 -0600 Subject: [PATCH] WIP #15: Added skeleton for function to load config file Also capitalized some stuff --- update_node/scripts/update_node.py | 30 ++++++++++++++++++++++-------- 1 file changed, 22 insertions(+), 8 deletions(-) diff --git a/update_node/scripts/update_node.py b/update_node/scripts/update_node.py index a45fb11..e874068 100644 --- a/update_node/scripts/update_node.py +++ b/update_node/scripts/update_node.py @@ -6,10 +6,10 @@ # imports import rospy -from std_msgs.msg import UInt8 -from geometry_msgs.msg import Twist -from geometry_msgs.msg import Pose -from std_msgs.msg import Float64, Float32 +from std_msgs.msg import * +from geometry_msgs.msg import * +from nav_msgs.msg import * +from sensor_msgs.msg import * class UpdatePublisher: @@ -19,10 +19,10 @@ def __init__ (self, topic_name): latest_var = 0 #Initialize Publisher - self.publisher = rospy.publisher('updates/' + topic_name, Float64, queue_size=0) + self.publisher = rospy.Publisher('updates/' + topic_name, Float64, queue_size=0) #Initialize Subscriber - self.subscriber = rospy.subscriber(topic_name, Float64, self.update_message) + self.subscriber = rospy.Subscriber(topic_name, Float64, self.update_message) def update_message(self, data): @@ -36,6 +36,14 @@ def publish_message(self, latest_var): #Publish the variable self.publisher.publish(latest_var) + @staticmethod + def load_config_file(file_name): + + updaters = [] + + # Create a list of UpdatePublishers + + return updaters if __name__ == "__main__": @@ -45,12 +53,18 @@ def publish_message(self, latest_var): #create UpdatePublisher object updater = UpdatePublisher() + # TODO: Read a file containing a bunch of [topic name, message type] pairs, create an UpdatePublisher for each + # updaters = load_config_file(filename) + #read values from server update_rate = rospy.get_param("update_rate") #Log initialization message rospy.loginfo("Update node initialized...") - rate = rospy.rate(update_rate) + rate = rospy.Rate(update_rate) while not rospy.is_shutdown(): - rospy.sleep() + + # Send an update from each UpdatePublisher + + rate.sleep()