voxel/kubi
1
1
Fork 0
mirror of https://github.com/griffi-gh/kubi.git synced 2024-11-13 19:08:41 -06:00
Code Issues Packages Projects Releases Wiki Activity

handle unsub requests

Browse source
This commit is contained in:
griffi-gh 2024-05-03 23:39:37 +02:00
parent 1d06621504
commit f067a07d90
1 changed files with 28 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
kubi-server/src/world.rs
View file

@ -13,7 +13,7 @@ use kubi_shared::{
use uflow::{server::RemoteClient, SendMode};
use lz4_flex::compress_prepend_size as lz4_compress;
use anyhow::Result;
use std::{rc::Rc, cell::RefCell};
use std::{cell::RefCell, os::windows::process, rc::Rc};
use kubi_shared::networking::client::ClientIdMap;
use crate::{
server::{UdpServer, ServerEvents},
@ -168,6 +168,32 @@ fn process_finished_tasks(
}
}
fn process_chunk_unsubscribe_events(
server: NonSendSync<UniqueView<UdpServer>>,
events: UniqueView<ServerEvents>,
mut chunk_manager: UniqueViewMut<ChunkManager>,
addr_map: UniqueView<ClientAddressMap>,
clients: View<Client>
) {
for event in &events.0 {
let Some(message) = check_message_auth
::<{ClientToServerMessageType::ChunkUnsubscribe as u8}>
(&server, event, &clients, &addr_map) else { continue };
let ClientToServerMessage::ChunkUnsubscribe { chunk: chunk_position } = message.message else {
unreachable!()
};
let Some(chunk) = chunk_manager.chunks.get_mut(&chunk_position) else {
log::warn!("tried to unsubscribe from non-existent chunk");
continue
};
chunk.subscriptions.remove(&message.client_id);
//TODO unload chunk if no more subscribers
}
}
fn process_block_queue_messages(
server: NonSendSync<UniqueView<UdpServer>>,
events: UniqueView<ServerEvents>,
@ -251,6 +277,7 @@ pub fn update_world() -> Workload {
process_finished_tasks,
process_block_queue_messages,
process_block_queue,
process_chunk_unsubscribe_events,
process_chunk_requests,
).into_sequential_workload()
}