mirror of
https://github.com/ekzhang/bore.git
synced 2024-12-22 17:15:21 +07:00
9cd43f458a
* using stream * fix tests * 💄 * 💄 fix review comments * clean up buffered data * 💄 fix review comments * Refactor Delimited to be its own struct * Add very_long_frame test to ensure behavior Co-authored-by: Eric Zhang <ekzhang1@gmail.com>
36 lines
1.0 KiB
Rust
36 lines
1.0 KiB
Rust
use anyhow::Result;
|
|
use bore_cli::{auth::Authenticator, shared::Delimited};
|
|
use tokio::io::{self};
|
|
|
|
#[tokio::test]
|
|
async fn auth_handshake() -> Result<()> {
|
|
let auth = Authenticator::new("some secret string");
|
|
|
|
let (client, server) = io::duplex(8); // Ensure correctness with limited capacity.
|
|
let mut client = Delimited::new(client);
|
|
let mut server = Delimited::new(server);
|
|
|
|
tokio::try_join!(
|
|
auth.client_handshake(&mut client),
|
|
auth.server_handshake(&mut server),
|
|
)?;
|
|
|
|
Ok(())
|
|
}
|
|
|
|
#[tokio::test]
|
|
async fn auth_handshake_fail() {
|
|
let auth = Authenticator::new("client secret");
|
|
let auth2 = Authenticator::new("different server secret");
|
|
|
|
let (client, server) = io::duplex(8); // Ensure correctness with limited capacity.
|
|
let mut client = Delimited::new(client);
|
|
let mut server = Delimited::new(server);
|
|
|
|
let result = tokio::try_join!(
|
|
auth.client_handshake(&mut client),
|
|
auth2.server_handshake(&mut server),
|
|
);
|
|
assert!(result.is_err());
|
|
}
|