|
|
@ -73,22 +73,19 @@ impl EventEmitter for EventCallback { |
|
|
|
room_member: &StrippedStateEventStub<MemberEventContent>,
|
|
|
|
_: Option<MemberEventContent>) {
|
|
|
|
if room_member.state_key == self.user_id {
|
|
|
|
match sync_room {
|
|
|
|
RoomState::Invited(x) => {
|
|
|
|
let room = x.read().await;
|
|
|
|
println!("Invitation received from {}", room.display_name());
|
|
|
|
match self.client.join_room_by_id(&room.room_id).await {
|
|
|
|
Ok(_) => {
|
|
|
|
println!("Joined {}", room.display_name());
|
|
|
|
self.statsd_client.incr("joined.success");
|
|
|
|
},
|
|
|
|
Err(_) => {
|
|
|
|
println!("There was an error while joining {}", room.display_name());
|
|
|
|
self.statsd_client.incr("joined.error");
|
|
|
|
}
|
|
|
|
};
|
|
|
|
},
|
|
|
|
_ => {}
|
|
|
|
if let RoomState::Invited(x) = sync_room {
|
|
|
|
let room = x.read().await;
|
|
|
|
println!("Invitation received from {}", room.display_name());
|
|
|
|
match self.client.join_room_by_id(&room.room_id).await {
|
|
|
|
Ok(_) => {
|
|
|
|
println!("Joined {}", room.display_name());
|
|
|
|
self.statsd_client.incr("joined.success");
|
|
|
|
},
|
|
|
|
Err(_) => {
|
|
|
|
println!("There was an error while joining {}", room.display_name());
|
|
|
|
self.statsd_client.incr("joined.error");
|
|
|
|
}
|
|
|
|
};
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|