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

add user limit

Browse source
This commit is contained in:
Maple 2026-04-26 01:06:05 +02:00
commit 21e3227347
1 changed files with 7 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -200,6 +200,9 @@ impl Friends for FriendsUser {
println!("acquiring user and current friends locks"); println!("acquiring user and current friends locks");
let users = self.fm.users.read().await; let users = self.fm.users.read().await;
if users.len() >= 100 {
return Err(ErrorCode::RendezVous_ConnectionFailure);
}
println!("started summing users"); println!("started summing users");
for u in users.deref().iter().filter_map(|u| u.upgrade()) { for u in users.deref().iter().filter_map(|u| u.upgrade()) {
let data = u.data.read().await; let data = u.data.read().await;
@ -327,6 +330,10 @@ impl Secure for FriendsUser {
station_urls: Vec<StationUrl>, station_urls: Vec<StationUrl>,
) -> Result<(QResult, u32, StationUrl), ErrorCode> { ) -> Result<(QResult, u32, StationUrl), ErrorCode> {
let cid = self.fm.next_cid(); let cid = self.fm.next_cid();
let users = self.fm.users.read().await;
if users.len() >= 100 {
return Err(ErrorCode::RendezVous_ConnectionFailure);
}
Ok(( Ok((
QResult::success(ErrorCode::Core_Unknown), QResult::success(ErrorCode::Core_Unknown),
cid, cid,