null.rs - mozsearch

Enable keyboard shortcuts

// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or

// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license

// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your

// option. This file may not be copied, modified, or distributed

// except according to those terms.

#![cfg(feature = "disable-encryption")]

use neqo_crypto::aead_null::AEAD_NULL_TAG;

use test_fixture::now;

use super::{connect_force_idle, default_client, default_server};

use crate::StreamType;

#[test]

fn no_encryption() {

    const DATA_CLIENT: &[u8] = &[2; 40];

    const DATA_SERVER: &[u8] = &[3; 50];

    let mut client = default_client();

    let mut server = default_server();

    connect_force_idle(&mut client, &mut server);

    let stream_id = client.stream_create(StreamType::BiDi).unwrap();

    client.stream_send(stream_id, DATA_CLIENT).unwrap();

    let client_pkt = client.process_output(now()).dgram().unwrap();

    assert!(client_pkt[..client_pkt.len() - AEAD_NULL_TAG.len()].ends_with(DATA_CLIENT));

    server.process_input(&client_pkt, now());

    let mut buf = vec![0; 100];

    let (len, _) = server.stream_recv(stream_id, &mut buf).unwrap();

    assert_eq!(len, DATA_CLIENT.len());

    assert_eq!(&buf[..len], DATA_CLIENT);

    server.stream_send(stream_id, DATA_SERVER).unwrap();

    let server_pkt = server.process_output(now()).dgram().unwrap();

    assert!(server_pkt[..server_pkt.len() - AEAD_NULL_TAG.len()].ends_with(DATA_SERVER));

    client.process_input(&server_pkt, now());

    let (len, _) = client.stream_recv(stream_id, &mut buf).unwrap();

    assert_eq!(len, DATA_SERVER.len());

    assert_eq!(&buf[..len], DATA_SERVER);