Маппинг UDP пакетов на другую машину в локальной сети

use std::net::{SocketAddr, UdpSocket};
use std::thread;
use std::time;
 
fn main() {
    let source_address = "xx.xx.xx.xx:7777"; // Тут ip, с которого приходят пакеты
    let relay_socket_address = "xx.xx.xx.xx:0"; // Тут ip, который будет использоваться для всех прокси-сокетов
    let target_address = "xx.xx.xx.xx:7777"; // Тут ip, куда идут пакеты
 
    let server_socket = UdpSocket::bind(source_address).unwrap();
    server_socket.set_nonblocking(true).unwrap();
    let mut nat: Vec<(SocketAddr, UdpSocket)> = Vec::new();
    let mut buffer = [0u8; 2000];
    loop {
        loop {
            if let Ok((packet_length, sender)) = server_socket.recv_from(&mut buffer) {
                if !nat
                    .iter()
                    .any(|(source_address, _)| source_address.port() == sender.port())
                {
                    println!("{} connected", sender);
                    let relay_socket = UdpSocket::bind(relay_socket_address).unwrap();
                    println!(
                        "mapping {} -> {}",
                        sender,
                        relay_socket.local_addr().unwrap()
                    );
                    relay_socket.set_nonblocking(true).unwrap();
                    nat.push((sender, relay_socket));
                }
                nat.iter()
                    .find(|(source_address, _)| source_address.port() == sender.port())
                    .unwrap()
                    .1
                    .send_to(&buffer[..packet_length], target_address)
                    .unwrap();
            } else {
                break;
            }
        }
        for (source_address, relay_socket) in &nat {
            loop {
                if let Ok(packet_length) = relay_socket.recv(&mut buffer) {
                    server_socket
                        .send_to(&buffer[..packet_length], source_address)
                        .unwrap();
                } else {
                    break;
                }
            }
        }
        thread::sleep(time::Duration::from_millis(1));
    }
}