implement gateway reset over modbus

src/gateway/mod.rs

@@ -8,7 +8,7 @@ use std::{
     net::{IpAddr, SocketAddr},
     path::PathBuf,
 };
-use tokio_modbus::client::tcp::connect;
+use tokio_modbus::{client::tcp::connect, slave::SlaveContext, Slave};
 
 #[derive(Subcommand)]
 pub enum Commands {
@@ -36,14 +36,16 @@ impl Cmd {
         let output = std::io::stdout().lock();
 
         let socket_addr = SocketAddr::new(self.ip, 502);
-        let ctx = connect(socket_addr).await?;
+        let mut ctx = connect(socket_addr).await?;
+
+        ctx.set_slave(Slave(0));
 
         match self.subcommand {
             Commands::Status => status::command(output, ctx).await,
             Commands::Update(options) => {
                 update::command(output, options, self.ip).await
             }
-            Commands::Restart => restart::command(output).await,
+            Commands::Restart => restart::command(output, ctx).await,
             Commands::Reset => reset::command(output).await,
         }
     }

src/gateway/restart.rs

@@ -1,4 +1,21 @@
+use std::time::Duration;
+use tokio_modbus::client::{Context as ModbusContext, Writer};
+
 #[allow(unused_variables, unused_mut)]
-pub async fn command(mut output: impl std::io::Write) -> anyhow::Result<()> {
-    unimplemented!();
+pub async fn command(
+    mut output: impl std::io::Write,
+    mut ctx: ModbusContext,
+) -> anyhow::Result<()> {
+    writeln!(output, "Resetting gateway...")?;
+
+    // write reset coil
+    let _ = tokio::time::timeout(
+        Duration::from_secs(1),
+        ctx.write_single_coil(1, true),
+    )
+    .await;
+
+    writeln!(output, "Done")?;
+
+    Ok(())
 }