char
/
matrix-rust-sdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

matrix-sdk: example: retry autojoin

master
strct 2020-10-10 15:57:23 +02:00
parent d039a39d84
commit c4ac0d0570
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
matrix_sdk/examples/autojoin.rs
View File

@ -1,4 +1,5 @@
use std::{env, process::exit}; use std::{env, process::exit};
use tokio::time::{delay_for, Duration};
use matrix_sdk::{ use matrix_sdk::{
self, self,
@ -32,11 +33,23 @@ impl EventEmitter for AutoJoinBot {
if let SyncRoom::Invited(room) = room { if let SyncRoom::Invited(room) = room {
let room = room.read().await; let room = room.read().await;
println!("Autojoining room {}", room.display_name()); println!("Autojoining room {}", room.room_id);
self.client let mut delay = 2;
.join_room_by_id(&room.room_id) while let Err(err) = self.client.join_room_by_id(&room.room_id).await {
.await // retry autojoin due to synapse sending invites, before the invited user can join
.expect("Can't join room"); // for more information see https://github.com/matrix-org/synapse/issues/4345
eprintln!(
"Failed to join room {} ({:?}), retrying in {}s",
room.room_id, err, delay
);
delay_for(Duration::from_secs(delay)).await;
delay *= 2;
if delay > 3600 {
eprintln!("Can't join room {} ({:?})", room.room_id, err);
break;
}
}
println!("Successfully joined room {}", room.room_id);
} }
} }
} }