add a way to send Sync from bus_manager and cli

zencan-cli/src/bin/zencan-cli.rs

@@ -476,6 +476,10 @@ async fn run_command<S: AsyncCanSender + Sync + Send>(cmd: Commands, manager: &m
                 Err(e) => println!("Error reading PDO config: {e}"),
             }
         }
+        Commands::Sync(args) => {
+            manager.sync(args.count).await;
+            println!("SYNC sent");
+        }
     }
 }
 

zencan-cli/src/command.rs

@@ -30,6 +30,8 @@ pub enum Commands {
     /// LSS commands
     #[command(subcommand)]
     Lss(LssCommands),
+    /// Send a SYNC packet
+    Sync(SyncArgs),
 }
 
 #[derive(Debug, Args)]
@@ -94,6 +96,12 @@ pub struct SaveObjectsArgs {
     pub node_id: u8,
 }
 
+#[derive(Debug, Args)]
+pub struct SyncArgs {
+    /// The optional count value (0-255). When omitted, sends a SYNC with zero data length.
+    pub count: Option<u8>,
+}
+
 /// Specifies a node to apply an NMT command
 #[derive(Debug, Clone, Copy, PartialEq)]
 pub enum NmtNodeArg {

zencan-client/src/bus_manager/bus_manager.rs

@@ -9,7 +9,7 @@ use zencan_common::constants::object_ids::{
     RPDO_COMM_BASE, RPDO_MAP_BASE, TPDO_COMM_BASE, TPDO_MAP_BASE,
 };
 use zencan_common::lss::{LssIdentity, LssState};
-use zencan_common::messages::{NmtCommand, NmtCommandSpecifier, ZencanMessage};
+use zencan_common::messages::{NmtCommand, NmtCommandSpecifier, SyncObject, ZencanMessage};
 use zencan_common::nmt::NmtState;
 use zencan_common::node_id::ConfiguredNodeId;
 use zencan_common::sdo::AbortCode;
@@ -549,6 +549,12 @@ impl<S: AsyncCanSender + Sync + Send> BusManager<S> {
         self.send_nmt_cmd(NmtCommandSpecifier::Stop, node).await
     }
 
+    /// Send a SYNC packet on the bus
+    pub async fn sync(&mut self, count: Option<u8>) {
+        let sync_obj = SyncObject::new(count);
+        self.sender.send(sync_obj.into()).await.ok();
+    }
+
     async fn send_nmt_cmd(&mut self, cmd: NmtCommandSpecifier, node: u8) {
         let message = NmtCommand { cs: cmd, node };
         self.sender.send(message.into()).await.ok();