summaryrefslogtreecommitdiff
path: root/server/src
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-01-06 14:28:02 +0100
committermetamuffin <metamuffin@disroot.org>2025-01-06 14:28:02 +0100
commit814cc1cb01692aa934a40636c9226ff7bb911266 (patch)
tree47a50a5dc1861ace4bc1854a9156618b70df3847 /server/src
parentc2ee65a83838a0ce13402e2c4634bae409d55071 (diff)
downloadweareserver-814cc1cb01692aa934a40636c9226ff7bb911266.tar
weareserver-814cc1cb01692aa934a40636c9226ff7bb911266.tar.bz2
weareserver-814cc1cb01692aa934a40636c9226ff7bb911266.tar.zst
new proto
Diffstat (limited to 'server/src')
-rw-r--r--server/src/main.rs10
1 files changed, 7 insertions, 3 deletions
diff --git a/server/src/main.rs b/server/src/main.rs
index cc55488..6b2911f 100644
--- a/server/src/main.rs
+++ b/server/src/main.rs
@@ -11,7 +11,11 @@ use std::{
},
thread::spawn,
};
-use weareshared::{packets::Packet, store::ResourceStore, tree::SceneTree};
+use weareshared::{
+ packets::{Packet, ReadWrite},
+ store::ResourceStore,
+ tree::SceneTree,
+};
#[derive(Parser, Debug)]
struct Args {
@@ -59,7 +63,7 @@ fn main() -> Result<()> {
fn handle_conn_read(conn: usize, sock: TcpStream, state: Arc<Mutex<State>>) -> Result<()> {
let mut sock = BufReader::new(sock);
loop {
- let packet = Packet::deserialize(&mut sock)?;
+ let packet = Packet::read(&mut sock)?;
debug!("{conn} <- {packet:?}");
state.lock().unwrap().handle_packet(conn, packet)?;
}
@@ -68,7 +72,7 @@ fn handle_conn_write(conn: usize, sock: TcpStream, rx: Receiver<Packet>) -> Resu
let mut sock = BufWriter::new(sock);
for packet in rx {
debug!("{conn} -> {packet:?}");
- packet.serialize(&mut sock)?;
+ packet.write(&mut sock)?;
sock.flush()?;
}
Ok(())