TudbuT/conduit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

delete all active requests for the appservice when we delete it

Browse source 
Signed-off-by: strawberry <strawberry@puppygock.gay>
This commit is contained in:
strawberry 2024-04-24 02:19:52 -04:00 • committed by June
parent dc35d06c0a
commit c57601a4b8
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/service/appservice/mod.rs
View file

@ -152,6 +152,7 @@ impl Service {
/// ///
/// * `service_name` - the name you send to register the service previously /// * `service_name` - the name you send to register the service previously
pub(crate) async fn unregister_appservice(&self, service_name: &str) -> Result<()> { pub(crate) async fn unregister_appservice(&self, service_name: &str) -> Result<()> {
// removes the appservice registration info
services() services()
.appservice .appservice
.registration_info .registration_info
@ -160,7 +161,14 @@ impl Service {
.remove(service_name) .remove(service_name)
.ok_or_else(|| crate::Error::AdminCommand("Appservice not found"))?; .ok_or_else(|| crate::Error::AdminCommand("Appservice not found"))?;
self.db.unregister_appservice(service_name) // remove the appservice from the database
self.db.unregister_appservice(service_name)?;
// deletes all active requests for the appservice if there are any so we stop
// sending to the URL
services().sending.cleanup_events(service_name.to_owned())?;
Ok(())
} }
pub(crate) async fn get_registration(&self, id: &str) -> Option<Registration> { pub(crate) async fn get_registration(&self, id: &str) -> Option<Registration> {