Function send_raw

crates/openshell-supervisor-network/tests/sigv4_localstack.rs:30–55

(raw: &[u8])

}

async fn send_raw(raw: &[u8]) -> (u16, String) {
    let mut stream = TcpStream::connect(LOCALSTACK)
        .await
        .expect("connect to LocalStack");
    stream.write_all(raw).await.expect("write request");

    let mut buf = Vec::with_capacity(16384);
    let mut tmp = [0u8; 4096];
    loop {
        match tokio::time::timeout(std::time::Duration::from_secs(5), stream.read(&mut tmp)).await {
            Ok(Ok(0)) | Err(_) => break,
            Ok(Ok(n)) => buf.extend_from_slice(&tmp[..n]),
            Ok(Err(e)) => panic!("read error: {e}"),
        }
    }

    let response = String::from_utf8_lossy(&buf).to_string();
    let status = response
        .lines()
        .next()
        .and_then(|line| line.split_whitespace().nth(1))
        .and_then(|s| s.parse::<u16>().ok())
        .unwrap_or(0);

    (status, response)
}

async fn signed_request(raw: &str, host: &str, service: &str) -> (u16, String) {
    let signed = apply_sigv4_to_request(