playit-agent-core 0.20.1

Contains the logic to create a playit.gg agent
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

use std::net::{IpAddr, Ipv4Addr, SocketAddr, SocketAddrV4};

use byteorder::{BigEndian, ByteOrder};
use tokio::net::{TcpSocket, TcpStream, UdpSocket};

use crate::utils::shuffle::shuffle;

pub struct LanAddress;

impl LanAddress {
    pub async fn tcp_socket(special_lan_ip: bool, peer: SocketAddr, host: SocketAddr) -> std::io::Result<TcpStream> {
        let is_loopback = host.ip().is_loopback();
        if is_loopback && special_lan_ip {
            let local_ip = map_to_local_ip4(peer.ip());
            let socket = TcpSocket::new_v4()?;

            match socket.bind(SocketAddrV4::new(local_ip, 0).into()) {
                Err(e) => {
                    tracing::warn!("Failed to bind connection to special local address to support IP based banning: {:?}", e);
                }
                Ok(_) => {
                    match socket.connect(host).await {
                        Err(e) => {
                            tracing::warn!("Failed to establish connection using special lan {} for flow {:?} {:?}", local_ip, (peer, host), e);
                        }
                        v => return v,
                    };
                }
            }
        }

        tracing::warn!(is_loopback, host_ip = %host.ip(), special_lan_ip, "not using special lan address");
        match TcpStream::connect(host).await {
            Err(e) => {
                tracing::error!("Failed to establish connection for flow {:?} {:?}. Is your server running?", (peer, host), e);
                Err(e)
            }
            v => v,
        }
    }

    pub async fn udp_socket(special_lan_ip: bool, peer: SocketAddr, tunnel_id: u64) -> std::io::Result<UdpSocket> {
        let ip_shuffle = shuffle_ip_to_u32(peer.ip());

        /* try to have the same client bind to the same local resource */
        let rand_id = shuffle(peer.port() as u32)
            ^ shuffle((tunnel_id >> 32) as u32)
            ^ shuffle(tunnel_id as u32)
            ^ ip_shuffle;

        let local_port = (2048u32 + rand_id % (u16::MAX as u32 - 2048u32)) as u16;

        if special_lan_ip {
            let local_ip = Ipv4Addr::from(as_local_masked(ip_shuffle));

            match UdpSocket::bind(SocketAddrV4::new(local_ip, local_port)).await {
                Ok(v) => Ok(v),
                Err(bad_port_error) => match UdpSocket::bind(SocketAddrV4::new(local_ip, 0)).await {
                    Ok(v) => {
                        tracing::warn!("Failed to bind UDP port to {} to have connections survive agent restart: {:?}", local_port, bad_port_error);
                        Ok(v)
                    }
                    Err(bad_local_ip_err) => {
                        let v = UdpSocket::bind(SocketAddrV4::new(0.into(), 0)).await?;
                        tracing::warn!("Failed to bind UDP to special local address, in-game ip banning will not work: {:?}", bad_local_ip_err);
                        Ok(v)
                    }
                }
            }
        } else {
            match UdpSocket::bind(SocketAddrV4::new(0.into(), local_port)).await {
                Ok(v) => Ok(v),
                Err(bad_port_error) => {
                    let v = UdpSocket::bind(SocketAddrV4::new(0.into(), 0)).await?;
                    tracing::warn!("Failed to bind UDP to special port: {:?}", bad_port_error);
                    Ok(v)
                }
            }
        }
    }
}

fn as_local_masked(mut ip: u32) -> u32 {
    ip = shuffle(ip) & 0x00FFFFFFu32;
    if ip == 0 {
        ip = 1;
    }
    ip | 0x7F000000u32
}

fn map_to_local_ip4(ip: IpAddr) -> Ipv4Addr {
    Ipv4Addr::from(as_local_masked(shuffle_ip_to_u32(ip)))
}

fn shuffle_ip_to_u32(ip: IpAddr) -> u32 {
    match ip {
        IpAddr::V4(ip) => u32::from(ip),
        IpAddr::V6(ip) => {
            let bytes = ip.octets();

            shuffle(BigEndian::read_u32(&bytes[..4]))
                ^ shuffle(BigEndian::read_u32(&bytes[4..8]))
                ^ shuffle(BigEndian::read_u32(&bytes[4..8]))
                ^ shuffle(BigEndian::read_u32(&bytes[4..8]))
        }
    }
}