add more moonraker endpoints

Author: paultag

moonraker/src/print.rs

@@ -1,8 +1,23 @@
 use anyhow::Result;
+use serde::{Deserialize, Serialize};
 use std::path::Path;
 
 use super::PrintManager;
 
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct InfoResponse {
+    pub state: String,
+    pub state_message: String,
+    pub hostname: String,
+    pub software_version: String,
+    pub cpu_info: String,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+struct InfoResponseWrapper {
+    pub result: InfoResponse,
+}
+
 impl PrintManager {
     /// Print an uploaded file.
     pub async fn print(&self, file_name: &Path) -> Result<()> {
@@ -16,6 +31,38 @@ impl PrintManager {
         Ok(())
     }
 
+    /// This endpoint will immediately halt the printer and put it in a
+    /// "shutdown" state. It should be used to implement an "emergency stop"
+    /// button and also used if a user enters M112(emergency stop) via a
+    /// console.
+    pub async fn emergency_stop(&self) -> Result<()> {
+        let client = reqwest::Client::new();
+        client
+            .post(format!("{}/printer/emergency_stop", self.url_base))
+            .send()
+            .await?;
+        Ok(())
+    }
+
+    /// Get information regarding the processor and its state.
+    pub async fn info(&self) -> Result<InfoResponse> {
+        let client = reqwest::Client::new();
+        let resp: InfoResponseWrapper = client
+            .post(format!("{}/printer/info", self.url_base))
+            .send()
+            .await?
+            .json()
+            .await?;
+        Ok(resp.result)
+    }
+
+    /// Restart the printer (shut down and reboot).
+    pub async fn restart(&self) -> Result<()> {
+        let client = reqwest::Client::new();
+        client.post(format!("{}/printer/restart", self.url_base)).send().await?;
+        Ok(())
+    }
+
     /// Cancel a print job.
     pub async fn cancel_print(&self) -> Result<()> {
         let client = reqwest::Client::new();
@@ -25,4 +72,24 @@ impl PrintManager {
             .await?;
         Ok(())
     }
+
+    /// Pause a print job.
+    pub async fn pause_print(&self) -> Result<()> {
+        let client = reqwest::Client::new();
+        client
+            .post(format!("{}/printer/print/pause", self.url_base))
+            .send()
+            .await?;
+        Ok(())
+    }
+
+    /// Resume a print job.
+    pub async fn resume_print(&self) -> Result<()> {
+        let client = reqwest::Client::new();
+        client
+            .post(format!("{}/printer/print/resume", self.url_base))
+            .send()
+            .await?;
+        Ok(())
+    }
 }

moonraker/src/upload.rs

@@ -27,14 +27,14 @@ pub struct DeleteResponseItem {
 }
 
 #[derive(Clone, Debug, Deserialize, Serialize)]
-pub struct DeleteResponseInner {
+pub struct DeleteResponse {
     pub item: DeleteResponseItem,
     pub action: String,
 }
 
 #[derive(Clone, Debug, Deserialize, Serialize)]
-pub struct DeleteResponse {
-    result: DeleteResponseInner,
+struct DeleteResponseWrapper {
+    result: DeleteResponse,
 }
 
 impl PrintManager {
@@ -83,11 +83,12 @@ impl PrintManager {
     pub async fn delete(&self, file_name: &Path) -> Result<DeleteResponse> {
         let file_name = file_name.to_str().unwrap();
         let client = reqwest::Client::new();
-        Ok(client
+        let resp: DeleteResponseWrapper = client
             .delete(format!("{}/server/files/gcodes/{}", self.url_base, file_name))
             .send()
             .await?
             .json()
-            .await?)
+            .await?;
+        Ok(resp.result)
     }
 }