mirror/matrix-rust-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-rust-sdk.git synced 2026-05-18 13:40:55 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix(sdk): limit the number of retries when updating push rules. (#2461)

Browse Source 
* fix(sdk): limit the number of retries when updating push rules.
* fix Rust format
This commit is contained in:
Nicolas Mauri
2023-08-25 17:11:49 +02:00
committed by GitHub
parent 2311edecf6
commit 63196aa6aa
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
crates/matrix-sdk/src/notification_settings/mod.rs
View File

@@ -18,7 +18,10 @@ mod command;
mod rule_commands;
mod rules;
use crate::{error::NotificationSettingsError, event_handler::EventHandlerHandle, Client, Result};
use crate::{
config::RequestConfig, error::NotificationSettingsError, event_handler::EventHandlerHandle,
Client, Result,
};
/// Enum representing the push notification modes for a room.
#[derive(Debug, Clone, PartialEq)]
@@ -324,6 +327,7 @@ impl NotificationSettings {
&self,
rule_commands: &RuleCommands,
) -> Result<(), NotificationSettingsError> {
let request_config = Some(RequestConfig::short_retry());
for command in &rule_commands.commands {
match command {
Command::DeletePushRule { scope, kind, rule_id } => {
@@ -333,7 +337,7 @@ impl NotificationSettings {
rule_id.clone(),
);
self.client
.send(request, None)
.send(request, request_config)
.await
.map_err(|_| NotificationSettingsError::UnableToRemovePushRule)?;
}
@@ -341,7 +345,7 @@ impl NotificationSettings {
let push_rule = command.to_push_rule()?;
let request = set_pushrule::v3::Request::new(scope.clone(), push_rule);
self.client
.send(request, None)
.send(request, request_config)
.await
.map_err(|_| NotificationSettingsError::UnableToAddPushRule)?;
}
@@ -349,7 +353,7 @@ impl NotificationSettings {
let push_rule = command.to_push_rule()?;
let request = set_pushrule::v3::Request::new(scope.clone(), push_rule);
self.client
.send(request, None)
.send(request, request_config)
.await
.map_err(|_| NotificationSettingsError::UnableToAddPushRule)?;
}
@@ -361,7 +365,7 @@ impl NotificationSettings {
*enabled,
);
self.client
.send(request, None)
.send(request, request_config)
.await
.map_err(|_| NotificationSettingsError::UnableToUpdatePushRule)?;
}
@@ -373,7 +377,7 @@ impl NotificationSettings {
actions.clone(),
);
self.client
.send(request, None)
.send(request, request_config)
.await
.map_err(|_| NotificationSettingsError::UnableToUpdatePushRule)?;
}