From 11d64bd8cd1eda35afcd66d6fb732c58d494c10d Mon Sep 17 00:00:00 2001
From: DJMrTV <tvnebel@gmail.com>
Date: Sun, 19 Jan 2025 14:34:02 +0100
Subject: [PATCH] fixed packets not being processed

---
 README.md           |  7 +++++++
 src/prudp/server.rs | 10 ++++++----
 2 files changed, 13 insertions(+), 4 deletions(-)
 create mode 100644 README.md

diff --git a/README.md b/README.md
new file mode 100644
index 0000000..4900bd8
--- /dev/null
+++ b/README.md
@@ -0,0 +1,7 @@
+# Splatoon NEX Server in Rust
+
+## Credits:
+- Pretendo team for the rest of the Servers and Reverse engineering efforts 
+- Kinnay for his huge work on reversing nex servers and documentation(https://github.com/Kinnay/NintendoClients/)
+- Splatfestival testing team for helping us test our messes of code
+- The SPFN team(Andrea and DJMrTV)
\ No newline at end of file
diff --git a/src/prudp/server.rs b/src/prudp/server.rs
index 7090ba5..74344d1 100644
--- a/src/prudp/server.rs
+++ b/src/prudp/server.rs
@@ -1,13 +1,13 @@
 use std::{env, io, thread};
 use std::io::Cursor;
 use std::marker::PhantomData;
-use std::net::{Ipv4Addr, SocketAddrV4, UdpSocket};
+use std::net::{Ipv4Addr, SocketAddr, SocketAddrV4, UdpSocket};
 use std::ops::{Deref, DerefMut};
 use std::sync::{Arc, Mutex};
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::thread::JoinHandle;
 use once_cell::sync::Lazy;
-use log::error;
+use log::{error, info};
 use crate::prudp::auth_module::AuthModule;
 use crate::prudp::endpoint::Endpoint;
 use crate::prudp::packet::PRUDPPacket;
@@ -29,7 +29,7 @@ impl NexServer{
     fn process_prudp_packet(&self, packet: &PRUDPPacket){
 
     }
-    fn process_prudp_packets(&self, addr: Ipv4Addr, udp_message: &[u8]){
+    fn process_prudp_packets(&self, addr: SocketAddr, udp_message: &[u8]){
         let mut stream = Cursor::new(udp_message);
 
         while stream.position() as usize != udp_message.len() {
@@ -41,6 +41,8 @@ impl NexServer{
                 },
             };
 
+            info!("got valid prudp packet from someone({}): \n{:?}", addr, packet);
+
 
         }
     }
@@ -55,7 +57,7 @@ impl NexServer{
 
             let current_msg = &msg_buffer[0..len];
 
-
+            self.process_prudp_packets(addr, current_msg);
         }
     }