use std::{
collections::{BTreeMap, BTreeSet},
sync::Arc,
};
use ruma::{
events::{
presence::PresenceEvent,
room::{
member::MembershipState,
power_levels::{PowerLevelAction, RoomPowerLevels, RoomPowerLevelsEventContent},
},
MessageLikeEventType, StateEventType,
},
MxcUri, OwnedUserId, UserId,
};
use crate::{
deserialized_responses::{MemberEvent, SyncOrStrippedState},
MinimalRoomMemberEvent,
};
#[derive(Clone, Debug)]
pub struct RoomMember {
pub(crate) event: Arc<MemberEvent>,
pub(crate) profile: Arc<Option<MinimalRoomMemberEvent>>,
#[allow(dead_code)]
pub(crate) presence: Arc<Option<PresenceEvent>>,
pub(crate) power_levels: Arc<Option<SyncOrStrippedState<RoomPowerLevelsEventContent>>>,
pub(crate) max_power_level: i64,
pub(crate) is_room_creator: bool,
pub(crate) display_name_ambiguous: bool,
pub(crate) is_ignored: bool,
}
impl RoomMember {
pub(crate) fn from_parts(member_info: MemberInfo, room_info: &MemberRoomInfo<'_>) -> Self {
let MemberInfo { event, profile, presence } = member_info;
let MemberRoomInfo {
power_levels,
max_power_level,
room_creator,
users_display_names,
ignored_users,
} = room_info;
let is_room_creator = room_creator.as_deref() == Some(event.user_id());
let display_name_ambiguous =
users_display_names.get(event.display_name()).is_some_and(|s| s.len() > 1);
let is_ignored = ignored_users.as_ref().is_some_and(|s| s.contains(event.user_id()));
Self {
event: event.into(),
profile: profile.into(),
presence: presence.into(),
power_levels: power_levels.clone(),
max_power_level: *max_power_level,
is_room_creator,
display_name_ambiguous,
is_ignored,
}
}
pub fn user_id(&self) -> &UserId {
self.event.user_id()
}
pub fn event(&self) -> &Arc<MemberEvent> {
&self.event
}
pub fn display_name(&self) -> Option<&str> {
if let Some(p) = self.profile.as_ref() {
p.as_original().and_then(|e| e.content.displayname.as_deref())
} else {
self.event.original_content()?.displayname.as_deref()
}
}
pub fn name(&self) -> &str {
if let Some(d) = self.display_name() {
d
} else {
self.user_id().localpart()
}
}
pub fn avatar_url(&self) -> Option<&MxcUri> {
if let Some(p) = self.profile.as_ref() {
p.as_original().and_then(|e| e.content.avatar_url.as_deref())
} else {
self.event.original_content()?.avatar_url.as_deref()
}
}
pub fn normalized_power_level(&self) -> i64 {
if self.max_power_level > 0 {
(self.power_level() * 100) / self.max_power_level
} else {
self.power_level()
}
}
pub fn power_level(&self) -> i64 {
(*self.power_levels)
.as_ref()
.map(|e| e.power_levels().for_user(self.user_id()).into())
.unwrap_or_else(|| if self.is_room_creator { 100 } else { 0 })
}
pub fn can_ban(&self) -> bool {
self.can_do_impl(|pls| pls.user_can_ban(self.user_id()))
}
pub fn can_invite(&self) -> bool {
self.can_do_impl(|pls| pls.user_can_invite(self.user_id()))
}
pub fn can_kick(&self) -> bool {
self.can_do_impl(|pls| pls.user_can_kick(self.user_id()))
}
pub fn can_redact(&self) -> bool {
self.can_do_impl(|pls| pls.user_can_redact(self.user_id()))
}
pub fn can_send_message(&self, msg_type: MessageLikeEventType) -> bool {
self.can_do_impl(|pls| pls.user_can_send_message(self.user_id(), msg_type))
}
pub fn can_send_state(&self, state_type: StateEventType) -> bool {
self.can_do_impl(|pls| pls.user_can_send_state(self.user_id(), state_type))
}
pub fn can_trigger_room_notification(&self) -> bool {
self.can_do_impl(|pls| pls.user_can_trigger_room_notification(self.user_id()))
}
pub fn can_do(&self, action: PowerLevelAction) -> bool {
self.can_do_impl(|pls| pls.user_can_do(self.user_id(), action))
}
fn can_do_impl(&self, f: impl FnOnce(RoomPowerLevels) -> bool) -> bool {
match &*self.power_levels {
Some(event) => f(event.power_levels()),
None => self.is_room_creator,
}
}
pub fn name_ambiguous(&self) -> bool {
self.display_name_ambiguous
}
pub fn membership(&self) -> &MembershipState {
self.event.membership()
}
pub fn is_ignored(&self) -> bool {
self.is_ignored
}
}
pub(crate) struct MemberInfo {
pub event: MemberEvent,
pub(crate) profile: Option<MinimalRoomMemberEvent>,
pub(crate) presence: Option<PresenceEvent>,
}
pub(crate) struct MemberRoomInfo<'a> {
pub(crate) power_levels: Arc<Option<SyncOrStrippedState<RoomPowerLevelsEventContent>>>,
pub(crate) max_power_level: i64,
pub(crate) room_creator: Option<OwnedUserId>,
pub(crate) users_display_names: BTreeMap<&'a str, BTreeSet<OwnedUserId>>,
pub(crate) ignored_users: Option<BTreeSet<OwnedUserId>>,
}