Initial import of a module to talk to Moonraker

Author: paultag

Cargo.lock

@@ -64,5 +64,6 @@ debug = ["dep:delouse", "dep:console-subscriber"]
 [workspace]
 members = [
 	"bambulabs",
+	"moonraker"
 ]
 

Cargo.toml

@@ -0,0 +1,11 @@
+[package]
+name = "moonraker"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+anyhow = "1"
+bytes = "1.7.1"
+reqwest = { version = "0", features = ["json", "multipart"] }
+serde = { version = "1.0.204", features = ["derive"] }
+tokio = { version = "1", features = ["full"] }

moonraker/Cargo.toml

@@ -0,0 +1,18 @@
+use anyhow::Result;
+use moonraker;
+use std::path::PathBuf;
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    let args: Vec<String> = std::env::args().collect();
+
+    let printer = moonraker::PrintManager::new(&args[1])?;
+    let path: PathBuf = args[2].parse().unwrap();
+    let path: PathBuf = printer.upload_file(&path).await?.item.path.parse().unwrap();
+    eprintln!("Uploaded {}", path.display());
+    eprintln!("Requesting print");
+    printer.print(&path).await?;
+    eprintln!("OK");
+
+    Ok(())
+}

moonraker/src/bin/print.rs

@@ -0,0 +1,31 @@
+#![deny(missing_docs)]
+#![deny(missing_copy_implementations)]
+#![deny(trivial_casts)]
+#![deny(trivial_numeric_casts)]
+#![deny(unused_import_braces)]
+#![deny(unused_qualifications)]
+#![deny(rustdoc::broken_intra_doc_links)]
+#![deny(rustdoc::private_intra_doc_links)]
+
+//! This crate implements support for interfacing with the moonraker 3d printer
+//! api, proxying calls to klipper.
+
+mod print;
+mod upload;
+
+use anyhow::Result;
+
+/// PrintManager is a moonraker instance which can accept gcode for printing.
+pub struct PrintManager {
+    pub(crate) url_base: String,
+}
+
+impl PrintManager {
+    /// Create a new PrintManager handle to control the printer via the
+    /// moonraker interface.
+    pub fn new(url_base: &str) -> Result<Self> {
+        Ok(Self {
+            url_base: url_base.to_owned(),
+        })
+    }
+}

moonraker/src/lib.rs

@@ -0,0 +1,28 @@
+use anyhow::Result;
+use std::path::Path;
+
+use super::PrintManager;
+
+impl PrintManager {
+    /// Print an uploaded file.
+    pub async fn print(&self, file_name: &Path) -> Result<()> {
+        let file_name = file_name.to_str().unwrap();
+        let client = reqwest::Client::new();
+        client
+            .post(format!("{}/printer/print/start", self.url_base))
+            .form(&[("filename", file_name)])
+            .send()
+            .await?;
+        Ok(())
+    }
+
+    /// Cancel a print job.
+    pub async fn cancel_print(&self) -> Result<()> {
+        let client = reqwest::Client::new();
+        client
+            .post(format!("{}/printer/print/cancel", self.url_base))
+            .send()
+            .await?;
+        Ok(())
+    }
+}