From eb98574c8ad2189f3cb358c3b6830e0b329a3889 Mon Sep 17 00:00:00 2001 From: "Rodrigo Rodriguez (Pragmatismo)" Date: Fri, 3 Apr 2026 20:49:17 -0300 Subject: [PATCH] fix(runtime): use TransferResult instead of Result in transfer_to_human --- src/basic/keywords/transfer_to_human.rs | 100 +++++++++++++++++++++--- 1 file changed, 90 insertions(+), 10 deletions(-) diff --git a/src/basic/keywords/transfer_to_human.rs b/src/basic/keywords/transfer_to_human.rs index 6f2c1fdb..8b372d36 100644 --- a/src/basic/keywords/transfer_to_human.rs +++ b/src/basic/keywords/transfer_to_human.rs @@ -518,11 +518,27 @@ pub fn register_transfer_to_human_keyword( ) .await }), - Err(e) => Err(anyhow::anyhow!("Failed to create runtime: {}", e)), + Err(_) => TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Failed to create runtime".to_string(), + }, }; let _ = tx.send(result); }); - let result = rx.recv().unwrap_or_else(|e| Err(anyhow::anyhow!("Channel error: {}", e))); + let result = rx.recv().unwrap_or_else(|_| TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Channel error".to_string(), + }); result.to_dynamic() }); @@ -553,11 +569,27 @@ pub fn register_transfer_to_human_keyword( ) .await }), - Err(e) => Err(anyhow::anyhow!("Failed to create runtime: {}", e)), + Err(_) => TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Failed to create runtime".to_string(), + }, }; let _ = tx.send(result); }); - let result = rx.recv().unwrap_or_else(|e| Err(anyhow::anyhow!("Channel error: {}", e))); + let result = rx.recv().unwrap_or_else(|_| TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Channel error".to_string(), + }); result.to_dynamic() }); @@ -591,11 +623,27 @@ pub fn register_transfer_to_human_keyword( ) .await }), - Err(e) => Err(anyhow::anyhow!("Failed to create runtime: {}", e)), + Err(_) => TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Failed to create runtime".to_string(), + }, }; let _ = tx.send(result); }); - let result = rx.recv().unwrap_or_else(|e| Err(anyhow::anyhow!("Channel error: {}", e))); + let result = rx.recv().unwrap_or_else(|_| TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Channel error".to_string(), + }); result.to_dynamic() }, ); @@ -631,11 +679,27 @@ pub fn register_transfer_to_human_keyword( ) .await }), - Err(e) => Err(anyhow::anyhow!("Failed to create runtime: {}", e)), + Err(_) => TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Failed to create runtime".to_string(), + }, }; let _ = tx.send(result); }); - let result = rx.recv().unwrap_or_else(|e| Err(anyhow::anyhow!("Channel error: {}", e))); + let result = rx.recv().unwrap_or_else(|_| TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Channel error".to_string(), + }); result.to_dynamic() }, ); @@ -682,11 +746,27 @@ pub fn register_transfer_to_human_keyword( ) .await }), - Err(e) => Err(anyhow::anyhow!("Failed to create runtime: {}", e)), + Err(_) => TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Failed to create runtime".to_string(), + }, }; let _ = tx.send(result); }); - let result = rx.recv().unwrap_or_else(|e| Err(anyhow::anyhow!("Channel error: {}", e))); + let result = rx.recv().unwrap_or_else(|_| TransferResult { + success: false, + status: TransferStatus::Error, + queue_position: None, + assigned_to: None, + assigned_to_name: None, + estimated_wait_seconds: None, + message: "Channel error".to_string(), + }); result.to_dynamic() });