spacebar/rust-nex
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages 50 Wiki Activity Actions

inform about people coming online

Browse source
This commit is contained in:
Maple 2026-04-26 00:24:54 +02:00
commit b4ad3d9c6f
1 changed files with 19 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

19
rnex-core/src/nex/friends_handler.rs
View file

@ -139,6 +139,9 @@ impl Friends for FriendsUser {
let Ok(any_self_fr_info) = Any::new(&self_fr_info) else { let Ok(any_self_fr_info) = Any::new(&self_fr_info) else {
return Err(ErrorCode::RendezVous_ControlScriptFailure); return Err(ErrorCode::RendezVous_ControlScriptFailure);
}; };
let Ok(any_self_presence) = Any::new(&self_fr_info.presence) else {
return Err(ErrorCode::RendezVous_ControlScriptFailure);
};
drop(data); drop(data);
let mut fr_list = vec![FriendInfo { let mut fr_list = vec![FriendInfo {
@ -227,6 +230,18 @@ impl Friends for FriendsUser {
.await; .await;
}); });
} else { } else {
let data = any_self_presence.clone();
let u = u.clone();
let sender = self.pid;
spawn(async move {
u.remote
.process_nintendo_notification_event_2(NintendoNotificationEvent {
event_type: 24,
sender,
data,
})
.await;
});
drop(fr); drop(fr);
} }
} }
@ -263,18 +278,22 @@ impl Friends for FriendsUser {
} }
async fn update_presence(&self, presence: NintendoPresenceV2) -> Result<(), ErrorCode> { async fn update_presence(&self, presence: NintendoPresenceV2) -> Result<(), ErrorCode> {
info!("user updated presence: {:?}", presence);
let mut data = self.data.write().await; let mut data = self.data.write().await;
let Some(inner_data) = data.as_mut() else { let Some(inner_data) = data.as_mut() else {
log::error!("unable to get presence data");
return Err(ErrorCode::RendezVous_PermissionDenied); return Err(ErrorCode::RendezVous_PermissionDenied);
}; };
inner_data.presence = presence; inner_data.presence = presence;
let Ok(any_self_fr_info) = Any::new(&inner_data.presence) else { let Ok(any_self_fr_info) = Any::new(&inner_data.presence) else {
log::error!("unable to create presence any data holder");
return Err(ErrorCode::RendezVous_ControlScriptFailure); return Err(ErrorCode::RendezVous_ControlScriptFailure);
}; };
drop(data); drop(data);
let users = self.fm.users.read().await; let users = self.fm.users.read().await;
for u in users.deref().iter().filter_map(|u| u.upgrade()) { for u in users.deref().iter().filter_map(|u| u.upgrade()) {
info!("sending presence update");
u.remote u.remote
.process_nintendo_notification_event_2(NintendoNotificationEvent { .process_nintendo_notification_event_2(NintendoNotificationEvent {
event_type: 24, event_type: 24,