aboutsummaryrefslogtreecommitdiff
path: root/karld/src
diff options
context:
space:
mode:
authormetamuffin <yvchraiqi@protonmail.com>2022-06-10 15:34:47 +0200
committermetamuffin <yvchraiqi@protonmail.com>2022-06-10 15:34:47 +0200
commit4e964dbb135655794d570d61f8f2587474aaead4 (patch)
treebffad12fb53eff554f8ee2b49722b82eb82269f6 /karld/src
parent76db19f14c616e879f613b533ee5072c661f8a10 (diff)
downloadkarlender-4e964dbb135655794d570d61f8f2587474aaead4.tar
karlender-4e964dbb135655794d570d61f8f2587474aaead4.tar.bz2
karlender-4e964dbb135655794d570d61f8f2587474aaead4.tar.zst
asdfs
Diffstat (limited to 'karld/src')
-rw-r--r--karld/src/interface.rs4
-rw-r--r--karld/src/main.rs10
2 files changed, 8 insertions, 6 deletions
diff --git a/karld/src/interface.rs b/karld/src/interface.rs
index 99ef594..127c0db 100644
--- a/karld/src/interface.rs
+++ b/karld/src/interface.rs
@@ -1,5 +1,5 @@
use crate::handle_packet;
-use karlcommon::{socket_path, ClientboundPacket, ServerboundPacket};
+use karlcommon::{socket_path, version, ClientboundPacket, ServerboundPacket};
use log::{debug, error, info, warn};
use std::io;
use std::io::{BufRead, BufReader, ErrorKind, Write};
@@ -31,7 +31,7 @@ fn handle_connection(id: u32, mut stream: UnixStream) -> io::Result<()> {
let (responder, responses) = crossbeam_channel::unbounded();
responder
.send(ClientboundPacket::Handshake {
- version: env!("CARGO_PKG_VERSION").to_string(),
+ version: version!(),
})
.unwrap();
thread::spawn(move || {
diff --git a/karld/src/main.rs b/karld/src/main.rs
index 7fa47e2..f70b7e7 100644
--- a/karld/src/main.rs
+++ b/karld/src/main.rs
@@ -1,11 +1,11 @@
pub mod condition;
pub mod interface;
-use std::{collections::HashMap, sync::RwLock};
use crossbeam_channel::Sender;
use interface::network_loop;
-use karlcommon::{Task, Condition, Property, ServerboundPacket, ClientboundPacket};
-use log::info;
+use karlcommon::{ClientboundPacket, Condition, Property, ServerboundPacket, Task};
+use log::{debug, info};
+use std::{collections::HashMap, sync::RwLock};
fn main() {
env_logger::init();
@@ -43,7 +43,6 @@ lazy_static::lazy_static! {
}
pub fn handle_packet(client: u32, packet: ServerboundPacket, responder: Sender<ClientboundPacket>) {
- println!("{:?}, {:?}, {:?}", client, packet, responder);
match packet {
ServerboundPacket::Download => {
let _ = responder.send(ClientboundPacket::DownloadResponse(
@@ -56,5 +55,8 @@ pub fn handle_packet(client: u32, packet: ServerboundPacket, responder: Sender<C
ServerboundPacket::RemoveTask(i) => {
TASKS.write().unwrap().remove(&i);
}
+ ServerboundPacket::Handshake { version } => {
+ debug!("{client}: version {version}");
+ }
}
}