rust 1.0.1

Plopmenz · Plopmenz · commit 67c717193b4d · 2025-07-01T16:41:54.000+02:00
diff --git a/rust/package/Cargo.lock b/rust/package/Cargo.lock
diff --git a/rust/package/Cargo.toml b/rust/package/Cargo.toml
@@ -1,7 +1,7 @@
 [package]
 name = "xnode-manager-sdk"
 description = "Rust Software Development Kit for interacting with Xnode Manager"
-version = "1.0.0"
+version = "1.0.1"
 edition = "2024"
 repository = "https://github.com/Openmesh-Network/xnode-manager-sdk"
 license = "MIT"
diff --git a/rust/package/src/auth/handlers.rs b/rust/package/src/auth/handlers.rs
@@ -1,13 +1,13 @@
 use reqwest::Client;
 use serde::{Deserialize, Serialize};
 
-use crate::utils::{Empty, Session, SessionPostInput, SessionPostOutput, session_post};
+use crate::utils::{Empty, Error, Session, SessionPostInput, SessionPostOutput, session_post};
 
 pub fn scope() -> String {
     "/xnode-auth".to_string()
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct User {
     user: String,
     signature: Option<String>,
@@ -30,20 +30,24 @@ impl User {
         }
     }
 }
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct LoginInput {
     pub base_url: String,
     pub user: User,
 }
-pub type LoginOutput = Result<Session, reqwest::Error>;
+pub type LoginOutput = Result<Session, Error>;
 pub async fn login(input: LoginInput) -> LoginOutput {
-    let client = Client::builder().cookie_store(true).build()?;
+    let client = Client::builder()
+        .cookie_store(true)
+        .build()
+        .map_err(Error::ReqwestError)?;
 
     client
         .post(format!("{}{}/api/login", input.base_url, scope()))
         .json(&input.user)
         .send()
-        .await?;
+        .await
+        .map_err(Error::ReqwestError)?;
 
     Ok(Session {
         reqwest_client: client,
diff --git a/rust/package/src/config/handlers.rs b/rust/package/src/config/handlers.rs
@@ -17,7 +17,7 @@ pub async fn containers(input: ContainersInput<'_>) -> SessionGetOutput<Containe
     session_get(input, scope(), |_path| "/containers").await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct GetPath {
     pub container: String,
 }
@@ -30,7 +30,7 @@ pub async fn get(input: GetInput<'_>) -> SessionGetOutput<GetOutput> {
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct SetPath {
     pub container: String,
 }
@@ -43,7 +43,7 @@ pub async fn set(input: SetInput<'_>) -> SessionPostOutput<SetOutput> {
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct RemovePath {
     pub container: String,
 }
diff --git a/rust/package/src/config/models.rs b/rust/package/src/config/models.rs
@@ -1,19 +1,19 @@
 use serde::{Deserialize, Serialize};
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct ContainerConfiguration {
     pub flake: String,
     pub flake_lock: Option<String>,
     pub network: Option<String>,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct ContainerSettings {
     pub flake: String,
     pub network: Option<String>,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct ContainerChange {
     pub settings: ContainerSettings,
     pub update_inputs: Option<Vec<String>>,
diff --git a/rust/package/src/file/handlers.rs b/rust/package/src/file/handlers.rs
@@ -13,6 +13,7 @@ pub fn scope() -> String {
     "/file".to_string()
 }
 
+#[derive(Debug, Clone, PartialEq)]
 pub struct ReadFilePath {
     pub scope: String,
 }
@@ -25,6 +26,7 @@ pub async fn read_file(input: ReadFileInput<'_>) -> SessionGetOutput<ReadFileOut
     .await
 }
 
+#[derive(Debug, Clone, PartialEq)]
 pub struct WriteFilePath {
     pub scope: String,
 }
@@ -37,6 +39,7 @@ pub async fn write_file(input: WriteFileInput<'_>) -> SessionPostOutput<WriteFil
     .await
 }
 
+#[derive(Debug, Clone, PartialEq)]
 pub struct RemoveFilePath {
     pub scope: String,
 }
@@ -49,7 +52,7 @@ pub async fn remove_file(input: RemoveFileInput<'_>) -> SessionPostOutput<Remove
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct ReadDirectoryPath {
     pub scope: String,
 }
@@ -64,7 +67,7 @@ pub async fn read_directory(
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct CreateDirectoryPath {
     pub scope: String,
 }
@@ -79,7 +82,7 @@ pub async fn create_directory(
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct RemoveDirectoryPath {
     pub scope: String,
 }
diff --git a/rust/package/src/file/models.rs b/rust/package/src/file/models.rs
@@ -2,45 +2,45 @@ use serde::{Deserialize, Serialize};
 
 use crate::utils::Output;
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct ReadFile {
     pub path: String,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct WriteFile {
     pub path: String,
     pub content: Vec<u8>,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct RemoveFile {
     pub path: String,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct ReadDirectory {
     pub path: String,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct CreateDirectory {
     pub path: String,
     pub make_parent: bool,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct RemoveDirectory {
     pub path: String,
     pub make_empty: bool,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct File {
     pub content: Output,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct Directory {
     pub directories: Vec<String>,
     pub files: Vec<String>,
diff --git a/rust/package/src/info/models.rs b/rust/package/src/info/models.rs
@@ -1,11 +1,11 @@
 use serde::{Deserialize, Serialize};
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct FlakeQuery {
     pub flake: String,
 }
 
-#[derive(Serialize, Deserialize)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct Flake {
     pub last_modified: u64,
     pub revision: String,
diff --git a/rust/package/src/os/models.rs b/rust/package/src/os/models.rs
@@ -1,6 +1,6 @@
 use serde::{Deserialize, Serialize};
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct OSChange {
     pub flake: Option<String>,
     pub update_inputs: Option<Vec<String>>,
@@ -11,7 +11,7 @@ pub struct OSChange {
     pub user_passwd: Option<String>,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct OSConfiguration {
     pub flake: String,
     pub flake_lock: String,
diff --git a/rust/package/src/process/handlers.rs b/rust/package/src/process/handlers.rs
@@ -11,6 +11,7 @@ pub fn scope() -> String {
     "/process".to_string()
 }
 
+#[derive(Debug, Clone, PartialEq)]
 pub struct ListPath {
     pub scope: String,
 }
@@ -23,7 +24,7 @@ pub async fn list(input: ListInput<'_>) -> SessionGetOutput<ListOutput> {
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct LogsPath {
     pub scope: String,
     pub process: String,
@@ -41,7 +42,7 @@ pub async fn logs(input: LogsInput<'_>) -> SessionGetOutput<LogsOutput> {
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct ExecutePath {
     pub scope: String,
     pub process: String,
diff --git a/rust/package/src/process/models.rs b/rust/package/src/process/models.rs
@@ -2,42 +2,42 @@ use serde::{Deserialize, Serialize};
 
 use crate::utils::Output;
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct SystemCtlProcess {
     pub unit: String,
     pub description: String,
     pub sub: String,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct Process {
     pub name: String,
     pub description: Option<String>,
     pub running: bool,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct LogQuery {
     pub max: Option<u32>,
     pub level: Option<LogLevel>,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct Log {
     pub timestamp: u64, // Epoch time in Microseconds
     pub message: Output,
     pub level: LogLevel,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub enum LogLevel {
     Error,
     Warn,
     Info,
     Unknown,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub enum ProcessCommand {
     Start,
     Stop,
diff --git a/rust/package/src/request/handlers.rs b/rust/package/src/request/handlers.rs
@@ -7,7 +7,7 @@ pub fn scope() -> String {
     "/request".to_string()
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct RequestInfoPath {
     pub request_id: RequestId,
 }
@@ -20,7 +20,7 @@ pub async fn request_info(input: RequestInfoInput<'_>) -> SessionGetOutput<Reque
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct CommandInfoPath {
     pub request_id: RequestId,
     pub command: String,
diff --git a/rust/package/src/request/models.rs b/rust/package/src/request/models.rs
@@ -4,24 +4,24 @@ use crate::utils::Output;
 
 pub type RequestId = u32;
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct RequestIdResponse {
     pub request_id: RequestId,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub enum RequestIdResult {
     Success { body: Option<String> },
     Error { error: String },
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct RequestInfo {
     pub commands: Vec<String>,
     pub result: Option<RequestIdResult>,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq)]
 pub struct CommandInfo {
     pub command: String,
     pub stdout: Output,
diff --git a/rust/package/src/usage/handlers.rs b/rust/package/src/usage/handlers.rs
@@ -7,7 +7,7 @@ pub fn scope() -> String {
     "/usage".to_string()
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct CpuPath {
     pub scope: String,
 }
@@ -20,7 +20,7 @@ pub async fn cpu(input: CpuInput<'_>) -> SessionGetOutput<CpuOutput> {
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct MemoryPath {
     pub scope: String,
 }
@@ -33,7 +33,7 @@ pub async fn memory(input: MemoryInput<'_>) -> SessionGetOutput<MemoryOutput> {
     .await
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct DiskPath {
     pub scope: String,
 }
diff --git a/rust/package/src/usage/models.rs b/rust/package/src/usage/models.rs
diff --git a/rust/package/src/utils/error.rs b/rust/package/src/utils/error.rs
diff --git a/rust/package/src/utils/mod.rs b/rust/package/src/utils/mod.rs
diff --git a/rust/package/src/utils/output.rs b/rust/package/src/utils/output.rs
diff --git a/rust/package/src/utils/session.rs b/rust/package/src/utils/session.rs

Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ pub async fn containers(input: ContainersInput<'_>) -> SessionGetOutput<Containe`
`17`	`17`	`session_get(input, scope(), \|_path\| "/containers").await`
`18`	`18`	`}`
`19`	`19`
`20`		`-#[derive(Debug)]`
	`20`	`+#[derive(Debug, Clone, PartialEq)]`
`21`	`21`	`pub struct GetPath {`
`22`	`22`	`pub container: String,`
`23`	`23`	`}`
`@@ -30,7 +30,7 @@ pub async fn get(input: GetInput<'_>) -> SessionGetOutput<GetOutput> {`
`30`	`30`	`.await`
`31`	`31`	`}`
`32`	`32`
`33`		`-#[derive(Debug)]`
	`33`	`+#[derive(Debug, Clone, PartialEq)]`
`34`	`34`	`pub struct SetPath {`
`35`	`35`	`pub container: String,`
`36`	`36`	`}`
`@@ -43,7 +43,7 @@ pub async fn set(input: SetInput<'_>) -> SessionPostOutput<SetOutput> {`
`43`	`43`	`.await`
`44`	`44`	`}`
`45`	`45`
`46`		`-#[derive(Debug)]`
	`46`	`+#[derive(Debug, Clone, PartialEq)]`
`47`	`47`	`pub struct RemovePath {`
`48`	`48`	`pub container: String,`
`49`	`49`	`}`
Original file line number	Diff line number	Diff line change
`@@ -13,6 +13,7 @@ pub fn scope() -> String {`
`13`	`13`	`"/file".to_string()`
`14`	`14`	`}`
`15`	`15`
	`16`	`+#[derive(Debug, Clone, PartialEq)]`
`16`	`17`	`pub struct ReadFilePath {`
`17`	`18`	`pub scope: String,`
`18`	`19`	`}`
`@@ -25,6 +26,7 @@ pub async fn read_file(input: ReadFileInput<'_>) -> SessionGetOutput<ReadFileOut`
`25`	`26`	`.await`
`26`	`27`	`}`
`27`	`28`
	`29`	`+#[derive(Debug, Clone, PartialEq)]`
`28`	`30`	`pub struct WriteFilePath {`
`29`	`31`	`pub scope: String,`
`30`	`32`	`}`
`@@ -37,6 +39,7 @@ pub async fn write_file(input: WriteFileInput<'_>) -> SessionPostOutput<WriteFil`
`37`	`39`	`.await`
`38`	`40`	`}`
`39`	`41`
	`42`	`+#[derive(Debug, Clone, PartialEq)]`
`40`	`43`	`pub struct RemoveFilePath {`
`41`	`44`	`pub scope: String,`
`42`	`45`	`}`
`@@ -49,7 +52,7 @@ pub async fn remove_file(input: RemoveFileInput<'_>) -> SessionPostOutput<Remove`
`49`	`52`	`.await`
`50`	`53`	`}`
`51`	`54`
`52`		`-#[derive(Debug)]`
	`55`	`+#[derive(Debug, Clone, PartialEq)]`
`53`	`56`	`pub struct ReadDirectoryPath {`
`54`	`57`	`pub scope: String,`
`55`	`58`	`}`
`@@ -64,7 +67,7 @@ pub async fn read_directory(`
`64`	`67`	`.await`
`65`	`68`	`}`
`66`	`69`
`67`		`-#[derive(Debug)]`
	`70`	`+#[derive(Debug, Clone, PartialEq)]`
`68`	`71`	`pub struct CreateDirectoryPath {`
`69`	`72`	`pub scope: String,`
`70`	`73`	`}`
`@@ -79,7 +82,7 @@ pub async fn create_directory(`
`79`	`82`	`.await`
`80`	`83`	`}`
`81`	`84`
`82`		`-#[derive(Debug)]`
	`85`	`+#[derive(Debug, Clone, PartialEq)]`
`83`	`86`	`pub struct RemoveDirectoryPath {`
`84`	`87`	`pub scope: String,`
`85`	`88`	`}`
Original file line number	Diff line number	Diff line change
`@@ -11,6 +11,7 @@ pub fn scope() -> String {`
`11`	`11`	`"/process".to_string()`
`12`	`12`	`}`
`13`	`13`
	`14`	`+#[derive(Debug, Clone, PartialEq)]`
`14`	`15`	`pub struct ListPath {`
`15`	`16`	`pub scope: String,`
`16`	`17`	`}`
`@@ -23,7 +24,7 @@ pub async fn list(input: ListInput<'_>) -> SessionGetOutput<ListOutput> {`
`23`	`24`	`.await`
`24`	`25`	`}`
`25`	`26`
`26`		`-#[derive(Debug)]`
	`27`	`+#[derive(Debug, Clone, PartialEq)]`
`27`	`28`	`pub struct LogsPath {`
`28`	`29`	`pub scope: String,`
`29`	`30`	`pub process: String,`
`@@ -41,7 +42,7 @@ pub async fn logs(input: LogsInput<'_>) -> SessionGetOutput<LogsOutput> {`
`41`	`42`	`.await`
`42`	`43`	`}`
`43`	`44`
`44`		`-#[derive(Debug)]`
	`45`	`+#[derive(Debug, Clone, PartialEq)]`
`45`	`46`	`pub struct ExecutePath {`
`46`	`47`	`pub scope: String,`
`47`	`48`	`pub process: String,`