diff --git a/satrs-example/src/events.rs b/satrs-example/src/events.rs index ecd2b1c..f843163 100644 --- a/satrs-example/src/events.rs +++ b/satrs-example/src/events.rs @@ -14,9 +14,10 @@ use satrs::{ verification::{TcStateStarted, VerificationReportingProvider, VerificationToken}, EcssTmSender, }, - spacepackets::time::cds::{self, TimeProvider}, ComponentId, + spacepackets::time::cds::{self, TimeProvider}, + ComponentId, }; -use satrs_example::config::{PUS_APID, ComponentIdList}; +use satrs_example::config::{ComponentIdList, PUS_APID}; use crate::update_time; @@ -47,8 +48,11 @@ impl PusEventHandler, - pub action_queue: mpsc::Receiver>, + // pub action_queue: mpsc::Receiver>, } pub struct ModeLeafDeviceHelper {} @@ -249,45 +248,69 @@ fn main() { // Mode requestors and handlers. let mut mode_node_assy = ModeRequestorAndHandlerMpscBounded::new( - TestChannelId::Assembly as u32, + TestComponentId::Assembly as ComponentId, request_receiver_assy, reply_receiver_assy, ); // Mode requestors only. - let mut mode_node_pus = - ModeRequestorBoundedMpsc::new(TestChannelId::PusModeService as u32, reply_receiver_pus); + let mut mode_node_pus = ModeRequestorBoundedMpsc::new( + TestComponentId::PusModeService as ComponentId, + reply_receiver_pus, + ); // Request handlers only. - let mut mode_node_dev1 = - ModeRequestHandlerMpscBounded::new(TestChannelId::Device1 as u32, request_receiver_dev1); - let mut mode_node_dev2 = - ModeRequestHandlerMpscBounded::new(TestChannelId::Device2 as u32, request_receiver_dev2); + let mut mode_node_dev1 = ModeRequestHandlerMpscBounded::new( + TestComponentId::Device1 as ComponentId, + request_receiver_dev1, + ); + let mut mode_node_dev2 = ModeRequestHandlerMpscBounded::new( + TestComponentId::Device2 as ComponentId, + request_receiver_dev2, + ); // Set up mode request senders first. - mode_node_pus.add_message_target(TestChannelId::Assembly as u32, request_sender_to_assy); mode_node_pus.add_message_target( - TestChannelId::Device1 as u32, + TestComponentId::Assembly as ComponentId, + request_sender_to_assy, + ); + mode_node_pus.add_message_target( + TestComponentId::Device1 as ComponentId, request_sender_to_dev1.clone(), ); mode_node_pus.add_message_target( - TestChannelId::Device2 as u32, + TestComponentId::Device2 as ComponentId, request_sender_to_dev2.clone(), ); - mode_node_assy.add_request_target(TestChannelId::Device1 as u32, request_sender_to_dev1); - mode_node_assy.add_request_target(TestChannelId::Device2 as u32, request_sender_to_dev2); + mode_node_assy.add_request_target( + TestComponentId::Device1 as ComponentId, + request_sender_to_dev1, + ); + mode_node_assy.add_request_target( + TestComponentId::Device2 as ComponentId, + request_sender_to_dev2, + ); // Set up mode reply senders. - mode_node_dev1.add_message_target(TestChannelId::Assembly as u32, reply_sender_to_assy.clone()); mode_node_dev1.add_message_target( - TestChannelId::PusModeService as u32, + TestComponentId::Assembly as ComponentId, + reply_sender_to_assy.clone(), + ); + mode_node_dev1.add_message_target( + TestComponentId::PusModeService as ComponentId, reply_sender_to_pus.clone(), ); - mode_node_dev2.add_message_target(TestChannelId::Assembly as u32, reply_sender_to_assy); mode_node_dev2.add_message_target( - TestChannelId::PusModeService as u32, + TestComponentId::Assembly as ComponentId, + reply_sender_to_assy, + ); + mode_node_dev2.add_message_target( + TestComponentId::PusModeService as ComponentId, reply_sender_to_pus.clone(), ); - mode_node_assy.add_reply_target(TestChannelId::PusModeService as u32, reply_sender_to_pus); + mode_node_assy.add_reply_target( + TestComponentId::PusModeService as ComponentId, + reply_sender_to_pus, + ); let mut device1 = TestDevice { name: "Test Device 1".to_string(), diff --git a/satrs/tests/pus_events.rs b/satrs/tests/pus_events.rs index 27c7d65..a21b9e7 100644 --- a/satrs/tests/pus_events.rs +++ b/satrs/tests/pus_events.rs @@ -30,7 +30,7 @@ fn test_threaded_usage() { let (pus_event_man_tx, pus_event_man_rx) = mpsc::channel(); let pus_event_man_send_provider = EventU32SenderMpsc::new(1, pus_event_man_tx); - event_man.subscribe_all(pus_event_man_send_provider.channel_id()); + event_man.subscribe_all(pus_event_man_send_provider.target_id()); event_man.add_sender(pus_event_man_send_provider); let (event_tx, event_rx) = mpsc::channel(); let reporter = EventReporter::new(0x02, 128).expect("Creating event reporter failed");