Function parses_v2_ipv4

gateway/src/pp.rs:220–236

()

    #[tokio::test]
    async fn parses_v2_ipv4() {
        // v2 magic + ver/cmd 0x21 + family/proto 0x11 (TCP/IPv4) + len 12
        let mut header = Vec::new();
        header.extend_from_slice(V2_PROTOCOL_PREFIX);
        header.extend_from_slice(&[0x21, 0x11, 0x00, 0x0c]);
        header.extend_from_slice(&[1, 2, 3, 4]); // src ip
        header.extend_from_slice(&[5, 6, 7, 8]); // dst ip
        header.extend_from_slice(&11111u16.to_be_bytes()); // src port
        header.extend_from_slice(&22222u16.to_be_bytes()); // dst port

        let (_stream, parsed) = read_proxy_header(&header[..]).await.expect("v2 parse");
        let (src, dst) = extract_v4(parsed);
        assert_eq!(src.ip().octets(), [1, 2, 3, 4]);
        assert_eq!(src.port(), 11111);
        assert_eq!(dst.ip().octets(), [5, 6, 7, 8]);
        assert_eq!(dst.port(), 22222);
    }

    #[tokio::test]
    async fn rejects_no_prefix() {