Function rejects_v1_without_terminator

gateway/src/pp.rs:250–263

()

    #[tokio::test]
    async fn rejects_v1_without_terminator() {
        // PROXY prefix matched but no \r\n terminator within V1_MAX_LENGTH bytes.
        let bytes = vec![b'P'; V1_MAX_LENGTH + 8]; // all 'P' — never closes
        let mut head = b"PROXY".to_vec();
        head.extend(std::iter::repeat(b'A').take(V1_MAX_LENGTH));
        let err = read_proxy_header(&head[..]).await.unwrap_err();
        let msg = format!("{err:#}");
        assert!(
            msg.contains("v1 terminator not found") || msg.contains("no valid proxy"),
            "unexpected error: {msg}"
        );
        // Sanity: the longer no-terminator buffer would also fail (read past)
        let _ = bytes;
    }

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