|
|
@@ -349,21 +349,23 @@ impl Platform for KucoinSwap {
|
|
|
let result_sd = self.order_sender.clone();
|
|
|
let err_sd = self.error_sender.clone();
|
|
|
let handle = tokio::spawn(async move {
|
|
|
- let result = self_clone.cancel_order(&order_id, &custom_id).await;
|
|
|
- match result {
|
|
|
- Ok(result) => {
|
|
|
- result_sd.send(result).await.unwrap();
|
|
|
- }
|
|
|
- Err(error) => {
|
|
|
- if error.to_string() == "The order cannot be canceled." {
|
|
|
- let mut err_order = Order::new();
|
|
|
- err_order.id = order_id;
|
|
|
- err_order.custom_id = custom_id;
|
|
|
- err_order.status = "REMOVE".to_string();
|
|
|
+ if order_id != "" {
|
|
|
+ let result = self_clone.cancel_order(&order_id, &custom_id).await;
|
|
|
+ match result {
|
|
|
+ Ok(result) => {
|
|
|
+ result_sd.send(result).await.unwrap();
|
|
|
+ }
|
|
|
+ Err(error) => {
|
|
|
+ if error.to_string() == "The order cannot be canceled." {
|
|
|
+ let mut err_order = Order::new();
|
|
|
+ err_order.id = order_id;
|
|
|
+ err_order.custom_id = custom_id;
|
|
|
+ err_order.status = "REMOVE".to_string();
|
|
|
|
|
|
- result_sd.send(err_order).await.unwrap();
|
|
|
+ result_sd.send(err_order).await.unwrap();
|
|
|
+ }
|
|
|
+ err_sd.send(error).await.unwrap();
|
|
|
}
|
|
|
- err_sd.send(error).await.unwrap();
|
|
|
}
|
|
|
}
|
|
|
});
|