flibusta-apps/book_bot
1
0
Fork 0
mirror of https://github.com/flibusta-apps/book_bot.git synced 2025-12-06 15:35:35 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fixes

Browse Source
This commit is contained in:
Bulat Kurbanov
2023-08-26 00:01:23 +02:00
parent a1b1505fca
commit 937e9c16d4
3 changed files with 101 additions and 96 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/bots_manager/mod.rs
View File

@@ -88,9 +88,9 @@ impl<T> ClosableSender<T> {
self.origin.read().unwrap().clone()
}
// fn close(&mut self) {
// self.origin.write().unwrap().take();
// }
fn close(&mut self) {
self.origin.write().unwrap().take();
}
}
@@ -228,7 +228,9 @@ impl BotsManager {
Some(v) => v,
None => {
stop_token.stop();
routers.write().await.remove(&token);
if let Some((_, mut sender)) = routers.write().await.remove(&token) {
sender.close();
};
return StatusCode::SERVICE_UNAVAILABLE;
},
};
@@ -242,7 +244,9 @@ impl BotsManager {
if let Err(err) = tx.send(Ok(update)) {
log::error!("{:?}", err);
stop_token.stop();
routers.write().await.remove(&token);
if let Some((_, mut sender)) = routers.write().await.remove(&token) {
sender.close();
};
return StatusCode::SERVICE_UNAVAILABLE;
}
}