fix(runtime): use TransferResult instead of Result in transfer_to_human
All checks were successful
BotServer CI/CD / build (push) Successful in 5m19s
All checks were successful
BotServer CI/CD / build (push) Successful in 5m19s
This commit is contained in:
parent
3f94d23e1f
commit
eb98574c8a
1 changed files with 90 additions and 10 deletions
|
|
@ -518,11 +518,27 @@ pub fn register_transfer_to_human_keyword(
|
||||||
)
|
)
|
||||||
.await
|
.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 _ = 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()
|
result.to_dynamic()
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
@ -553,11 +569,27 @@ pub fn register_transfer_to_human_keyword(
|
||||||
)
|
)
|
||||||
.await
|
.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 _ = 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()
|
result.to_dynamic()
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
@ -591,11 +623,27 @@ pub fn register_transfer_to_human_keyword(
|
||||||
)
|
)
|
||||||
.await
|
.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 _ = 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()
|
result.to_dynamic()
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
|
|
@ -631,11 +679,27 @@ pub fn register_transfer_to_human_keyword(
|
||||||
)
|
)
|
||||||
.await
|
.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 _ = 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()
|
result.to_dynamic()
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
|
|
@ -682,11 +746,27 @@ pub fn register_transfer_to_human_keyword(
|
||||||
)
|
)
|
||||||
.await
|
.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 _ = 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()
|
result.to_dynamic()
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue