diff --git a/crates/buzz-acp/src/workflow_wake_recovery_tests.rs b/crates/buzz-acp/src/workflow_wake_recovery_tests.rs index 9e07b11ef6..82a54215e1 100644 --- a/crates/buzz-acp/src/workflow_wake_recovery_tests.rs +++ b/crates/buzz-acp/src/workflow_wake_recovery_tests.rs @@ -230,7 +230,7 @@ async fn complete_malformed_authority_body_is_terminal() { for body in ["{", "{}"] { let (mut stream, _) = listener.accept().await.unwrap(); let mut request = [0u8; 4096]; - stream.read(&mut request).await.unwrap(); + assert!(stream.read(&mut request).await.unwrap() > 0); stream .write_all( format!( diff --git a/crates/buzz-relay/src/workflow_delivery_tests.rs b/crates/buzz-relay/src/workflow_delivery_tests.rs index e46c9a3708..3d045bc219 100644 --- a/crates/buzz-relay/src/workflow_delivery_tests.rs +++ b/crates/buzz-relay/src/workflow_delivery_tests.rs @@ -266,7 +266,7 @@ async fn captured_revision_survives_replacement_but_not_revocation() { deletion, crate::handlers::ingest::IngestAuth::Nip42 { pubkey: f.owner.public_key(), - scopes: vec![], + scopes: vec![buzz_auth::Scope::MessagesWrite], channel_ids: None, conn_id: Uuid::new_v4(), },