more modern stuff using

src/main.rs

@@ -76,7 +76,7 @@ impl PacketHandler for ExamplePacketHandler {
 		&self, 
 		client: Arc<ClientContext>, 
 		packet: &mut Packet, 
-		cancelled: &mut bool,
+		_: &mut bool,
 		state: ConnectionState
 	) -> Result<(), ServerError> {
 		debug!("{} -> S\t| 0x{:02x}\t| {:?}\t| {} bytes", client.addr.clone(), packet.id(), state, packet.len());
@@ -88,7 +88,7 @@ impl PacketHandler for ExamplePacketHandler {
 		&self, 
 		client: Arc<ClientContext>, 
 		packet: &mut Packet, 
-		cancelled: &mut bool,
+		_: &mut bool,
 		state: ConnectionState
 	) -> Result<(), ServerError> {
 		debug!("{} <- S\t| 0x{:02x}\t| {:?}\t| {} bytes", client.addr.clone(), packet.id(), state, packet.len());

src/server/event/mod.rs

@@ -88,7 +88,7 @@ macro_rules! trigger_event {
 
 pub trait Listener: Sync + Send {
     generate_handlers!(status, &mut String);
-    generate_handlers!(plugin_message, &mut String);
+    generate_handlers!(plugin_message, &str, &[u8]);
 }
 
 pub trait PacketHandler: Sync + Send {

src/server/protocol.rs

@@ -1,10 +1,9 @@
 use std::{io::Read, sync::Arc};
 
 use super::{player::context::{ClientContext, ClientInfo, Handshake, PlayerInfo}, ServerError};
-use log::error;
 use rust_mc_proto::{DataReader, DataWriter, Packet};
 
-use crate::{trigger_event, write_packet, read_packet};
+use crate::{read_packet, server::data::text_component::TextComponent, trigger_event, write_packet};
 
 #[derive(Debug, Clone)]
 pub enum ConnectionState {
@@ -33,11 +32,6 @@ pub fn handle_connection(
 	let server_port = packet.read_unsigned_short()?; // Все тоже самое что и с адресом сервера и все потому же и за тем же
 	let next_state = packet.read_varint()?; // Тип подключения: 1 для получения статуса и пинга, 2 и 3 для обычного подключения
 
-	// debug!("protocol_version: {protocol_version}");
-	// debug!("server_address: {server_address}");
-	// debug!("server_port: {server_port}");
-	// debug!("next_state: {next_state}");
-
 	client.set_handshake(Handshake { protocol_version, server_address, server_port });
 
 	match next_state {
@@ -89,9 +83,6 @@ pub fn handle_connection(
 			let name = packet.read_string()?;
 			let uuid = packet.read_uuid()?;
 
-			// debug!("name: {name}");
-			// debug!("uuid: {uuid}");
-
 			client.set_player_info(PlayerInfo { name: name.clone(), uuid: uuid.clone() });
 
 			if client.server.config.server.online_mode {
@@ -133,15 +124,13 @@ pub fn handle_connection(
 					if identifier == "minecraft:brand" { 
 						break String::from_utf8_lossy(&data).to_string();
 					} else {
-						error!("unknown plugin message channel: {}", identifier);
+						trigger_event!(client, plugin_message, &identifier, &data);
 					}
 				} else {
 					return Err(ServerError::UnknownPacket(format!("Неизвестный пакет при ожидании Serverbound Plugin Message"))); 
 				};
 			};
 
-			// debug!("brand: {brand}");
-
 			let mut packet = read_packet!(client, Configuration);
 
 			// Пакет Client Information
@@ -149,7 +138,7 @@ pub fn handle_connection(
 				return Err(ServerError::UnknownPacket(format!("Неизвестный пакет при ожидании Client Information"))); 
 			}
 
-			let locale = packet.read_string()?; // for example: ru_RU
+			let locale = packet.read_string()?; // for example: en_us
 			let view_distance = packet.read_signed_byte()?; // client-side render distance in chunks
 			let chat_mode = packet.read_varint()?; // 0: enabled, 1: commands only, 2: hidden. See Chat#Client chat mode for more information. 
 			let chat_colors = packet.read_boolean()?; // this settings does nothing on client but can be used on serverside
@@ -159,16 +148,6 @@ pub fn handle_connection(
 			let allow_server_listings = packet.read_boolean()?; // allows showing player in server listings in status
 			let particle_status = packet.read_varint()?; // 0 for all, 1 for decreased, 2 for minimal
 
-			// debug!("locale: {locale}");
-			// debug!("view_distance: {view_distance}");
-			// debug!("chat_mode: {chat_mode}");
-			// debug!("chat_colors: {chat_colors}");
-			// debug!("displayed_skin_parts: {displayed_skin_parts}");
-			// debug!("main_hand: {main_hand}");
-			// debug!("enable_text_filtering: {enable_text_filtering}");
-			// debug!("allow_server_listings: {allow_server_listings}");
-			// debug!("particle_status: {particle_status}");
-
 			client.set_client_info(ClientInfo { 
 				brand, 
 				locale, 
@@ -194,16 +173,8 @@ pub fn handle_connection(
 
 			client.set_state(ConnectionState::Play)?; // Мы перешли в режим Play
 
-			// Отключение игрока с сообщением
+			// Дальше работаем с режимом игры
-			// Отправляет в формате NBT TAG_String (https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/NBT#Specification:string_tag)
+			handle_play_state(client)?;
-			write_packet!(client, Play, Packet::build(0x1C, |p| {
-				let message = "server is in developmenet lol".to_string();
-				p.write_byte(0x08)?; // NBT Type Name (TAG_String)
-				p.write_unsigned_short(message.len() as u16)?; // String length in unsigned short
-				p.write_bytes(message.as_bytes())
-			})?);
-
-			// TODO: Сделать отправку пакетов Play
 		},
 		_ => {
 			return Err(ServerError::UnknownPacket(format!("Неизвестный NextState при рукопожатии"))); 
@@ -212,3 +183,16 @@ pub fn handle_connection(
 
 	Ok(())
 }
+
+// Отдельная функция для работы с самой игрой
+pub fn handle_play_state(
+	client: Arc<ClientContext>, // Контекст клиента
+) -> Result<(), ServerError> { 
+
+	// Отключение игрока с сообщением
+	client.protocol_helper().disconnect(TextComponent::rainbow("server is in developement suka".to_string()))?;
+
+	// TODO: Сделать отправку пакетов Play
+
+	Ok(())
+}