feat: Added checking unsupported 1.19 versions

Author: Andcool-Systems

.gitignore

@@ -2,4 +2,5 @@
 /Cargo.lock
 /out
 /.vscode/settings.json
-/server_icon.png
+/server_icon.png
+/config.toml

config.example.toml

@@ -0,0 +1,27 @@
+[api]
+addr = "0.0.0.0"
+port = 8008
+code_life_time = 300
+
+[server]
+addr = "0.0.0.0"
+port = 25566
+timeout = 20
+server_ip = "localhost"
+
+[server.config]
+server_name = "mc-oauth-rs"
+protocol = 0
+version = "1.21"
+auth_url = "https://sessionserver.mojang.com/session/minecraft/hasJoined?username={{NAME}}&serverId={{HASH}}"
+
+[server.status]
+description = "§6mc-oauth.andcool.ru"
+players_max = 0
+players_online = 0
+icon_path = "server_icon.png"
+
+[messages]
+success = "Hello, §6{{NAME}}§r! Your code is: §a{{CODE}}"
+bad_session = "§cFailed to login: Invalid session (Try restarting your game and the launcher)"
+using_proxy = "§cYou are using a proxy!"

src/handlers/handshake.rs

@@ -14,7 +14,7 @@ impl MinecraftServer {
     pub async fn handle_handshake(&mut self) -> Result<()> {
         let handshake = HandshakePacket::parse(&mut self.buffer)?;
 
-        self.session.proto_ver = Some(handshake.proto_ver);
+        self.session.proto_ver = handshake.proto_ver;
         self.session.next_state = match handshake.next_state {
             1 => NextStateEnum::Status,
             2 => NextStateEnum::Login,

src/handlers/login_start.rs

@@ -1,13 +1,23 @@
 use crate::{packets::login_start::LoginStartPacket, server::MinecraftServer};
+use anyhow::Error;
 
 impl MinecraftServer {
     /**
     Handle login start packet from client
     */
-    pub fn handle_login_start(&mut self) -> anyhow::Result<()> {
+    pub async fn handle_login_start(&mut self) -> anyhow::Result<()> {
         let packet = LoginStartPacket::parse(&mut self.buffer)?;
         self.session.nickname = Some(packet.name);
         self.session.uuid = packet.uuid;
+
+        if self.session.proto_ver >= 759 && self.session.proto_ver <= 762 {
+            self.send_disconnect(
+                "Sorry, Minecraft 1.19.* clients not supported yet.\nTry using another version of client."
+                    .to_string(),
+            )
+            .await?;
+            return Err(Error::msg("Client using unsupported version!"));
+        }
         Ok(())
     }
 }

src/responses/encryption.rs

@@ -10,11 +10,11 @@ impl MinecraftServer {
     pub async fn send_encryption(&mut self) -> Result<()> {
         let public_der = self.keys.to_public_key().to_public_key_der()?.into_vec();
 
-        let proto_ver = match self.session.proto_ver {
-            Some(x) => x,
-            None => unreachable!(),
+        let should_authenticate = if self.session.proto_ver >= 766 {
+            Some(true)
+        } else {
+            None
         };
-        let should_authenticate = if proto_ver >= 766 { Some(true) } else { None };
 
         let packet = EncryptionRequestPacket::new(
             self.session.server_id.clone(),

src/responses/status.rs

@@ -14,10 +14,7 @@ impl MinecraftServer {
     pub async fn send_status(&mut self) -> Result<()> {
         let config = get_config().await;
         let proto_ver = if config.server.config.protocol == 0 {
-            match self.session.proto_ver {
-                Some(x) => x,
-                None => unreachable!(),
-            }
+            self.session.proto_ver
         } else {
             config.server.config.protocol
         };

src/server.rs

@@ -24,7 +24,7 @@ pub enum NextStateEnum {
 #[derive(Debug)]
 pub struct Session {
     pub server_id: String,
-    pub proto_ver: Option<usize>,
+    pub proto_ver: usize,
     pub next_state: NextStateEnum,
     pub nickname: Option<String>,
     pub uuid: Option<Uuid>,
@@ -40,7 +40,7 @@ impl Session {
 
         Self {
             server_id: config.server.config.server_name.clone(),
-            proto_ver: None,
+            proto_ver: 0,
             next_state: NextStateEnum::Unknown,
             nickname: None,
             uuid: None,
@@ -128,7 +128,7 @@ impl MinecraftServer {
             NextStateEnum::Status => self.send_status().await?, // Send status response
             NextStateEnum::Login => {
                 // Handle login start
-                self.handle_login_start()?;
+                self.handle_login_start().await?;
                 self.send_encryption().await?;
             }
             NextStateEnum::Unknown => self.handle_handshake().await?, // Handle handshake