test(libwebauthn-tests): integration test for largeBlob read

AlfioEmanueleFresta · AlfioEmanueleFresta · commit c70b88a7331c · 2026-05-19T19:54:17.000+01:00
Enables largeBlobs storage on the virt fido-authenticator and adds an
end-to-end test: registers a credential, plants an encrypted entry
directly via authenticatorLargeBlobs(set), then asserts
webauthn_get_assertion with largeBlob.read surfaces the plaintext.

Requires the chunked feature on fido-authenticator to lift the 1024-byte
single-message cap on the device-wide array, and a non-zero max_msg_size
in the virt config so the per-chunk length check passes.
diff --git a/libwebauthn-tests/Cargo.toml b/libwebauthn-tests/Cargo.toml
@@ -12,7 +12,7 @@ cosey = "0.3.2"
 ctaphid = { version = "0.3.1", default-features = false }
 ctaphid-dispatch = "0.3"
 delog = { version = "0.1", features = ["std-log"] }
-fido-authenticator = { git = "https://github.com/Nitrokey/fido-authenticator.git", tag = "v0.1.1-nitrokey.27", features = ["dispatch", "log-all"] }
+fido-authenticator = { git = "https://github.com/Nitrokey/fido-authenticator.git", tag = "v0.1.1-nitrokey.27", features = ["chunked", "dispatch", "log-all"] }
 interchange = "0.3.0"
 littlefs2 = "0.6.0"
 num_enum = "0.7.1"
@@ -22,8 +22,12 @@ trussed = { version = "0.1", features = ["virt"] }
 trussed-staging = { version = "0.3.0", features = ["chunked", "hkdf", "virt", "fs-info"] }
 
 [dev-dependencies]
+aes-gcm = "0.10"
 base64-url = "3.0.0"
+flate2 = "1.0"
 serde_bytes = "0.11.5"
+serde_cbor_2 = "0.13"
+sha2 = "0.10"
 tempfile = "3.21"
 test-log = "0.2"
 tokio = { version = "1.45", features = ["full"] }
diff --git a/libwebauthn-tests/src/virt/device.rs b/libwebauthn-tests/src/virt/device.rs
@@ -66,10 +66,13 @@ where
                 client,
                 Conforming {},
                 Config {
-                    max_msg_size: 0,
+                    max_msg_size: 1200,
                     skip_up_timeout: None,
                     max_resident_credential_count: options.max_resident_credential_count,
-                    large_blobs: None,
+                    large_blobs: Some(fido_authenticator::LargeBlobsConfig {
+                        location: trussed::types::Location::Internal,
+                        max_size: 4096,
+                    }),
                     nfc_transport: false,
                 },
             );
diff --git a/libwebauthn-tests/tests/large_blob.rs b/libwebauthn-tests/tests/large_blob.rs
@@ -0,0 +1,223 @@
+//! End-to-end test of WebAuthn largeBlob.read against the virt authenticator.
+
+use std::time::Duration;
+
+use libwebauthn::ops::webauthn::{
+    GetAssertionLargeBlobExtension, GetAssertionRequest, GetAssertionRequestExtensions,
+    MakeCredentialLargeBlobExtension, MakeCredentialLargeBlobExtensionInput,
+    MakeCredentialRequest, MakeCredentialsRequestExtensions, ResidentKeyRequirement,
+    UserVerificationRequirement,
+};
+use libwebauthn::proto::ctap2::{
+    Ctap2, Ctap2CredentialType, Ctap2GetAssertionRequest, Ctap2LargeBlobsRequest,
+    Ctap2PublicKeyCredentialDescriptor, Ctap2PublicKeyCredentialRpEntity,
+    Ctap2PublicKeyCredentialUserEntity,
+};
+use libwebauthn::transport::{Channel, Device};
+use libwebauthn::webauthn::WebAuthn;
+use libwebauthn::UvUpdate;
+use libwebauthn_tests::virt::get_virtual_device;
+use rand::{thread_rng, Rng};
+use test_log::test;
+use tokio::sync::broadcast::Receiver;
+
+const TIMEOUT: Duration = Duration::from_secs(10);
+const RP: &str = "example.org";
+
+async fn handle_updates(mut state_recv: Receiver<UvUpdate>) {
+    // MakeCredential update
+    assert_eq!(state_recv.recv().await, Ok(UvUpdate::PresenceRequired));
+    // GetAssertion update
+    assert_eq!(state_recv.recv().await, Ok(UvUpdate::PresenceRequired));
+}
+
+#[test(tokio::test)]
+async fn test_webauthn_large_blob_read_returns_planted_blob() {
+    let mut device = get_virtual_device();
+    let mut channel = device.channel().await.unwrap();
+
+    let user_id: [u8; 32] = thread_rng().gen();
+    let challenge: [u8; 32] = thread_rng().gen();
+
+    let make = MakeCredentialRequest {
+        origin: RP.into(),
+        challenge: challenge.to_vec(),
+        relying_party: Ctap2PublicKeyCredentialRpEntity::new(RP, RP),
+        user: Ctap2PublicKeyCredentialUserEntity::new(&user_id, "alice", "Alice"),
+        resident_key: Some(ResidentKeyRequirement::Required),
+        user_verification: UserVerificationRequirement::Discouraged,
+        algorithms: vec![Ctap2CredentialType::default()],
+        exclude: None,
+        extensions: Some(MakeCredentialsRequestExtensions {
+            large_blob: Some(MakeCredentialLargeBlobExtensionInput {
+                support: MakeCredentialLargeBlobExtension::Required,
+            }),
+            ..Default::default()
+        }),
+        timeout: TIMEOUT,
+        top_origin: None,
+    };
+
+    let state_recv = channel.get_ux_update_receiver();
+    let update_handle = tokio::spawn(handle_updates(state_recv));
+
+    let response = channel
+        .webauthn_make_credential(&make)
+        .await
+        .expect("MakeCredential should succeed");
+    assert_eq!(
+        response
+            .unsigned_extensions_output
+            .large_blob
+            .as_ref()
+            .and_then(|lb| lb.supported),
+        Some(true),
+        "device must report largeBlob.supported=true"
+    );
+    let credential: Ctap2PublicKeyCredentialDescriptor =
+        (&response.authenticator_data).try_into().unwrap();
+
+    let key = capture_large_blob_key(&mut channel, &credential, &challenge).await;
+    let plaintext = b"hello, planted largeBlob".to_vec();
+    let nonce: [u8; 12] = thread_rng().gen();
+    let serialized = encode_serialized_array(&[encode_entry(&key, &nonce, &plaintext)]);
+    plant_large_blob_array(&mut channel, serialized).await;
+
+    let ga = GetAssertionRequest {
+        relying_party_id: RP.into(),
+        origin: RP.into(),
+        challenge: challenge.to_vec(),
+        allow: vec![credential],
+        user_verification: UserVerificationRequirement::Discouraged,
+        extensions: Some(GetAssertionRequestExtensions {
+            appid: None,
+            cred_blob: false,
+            prf: None,
+            large_blob: Some(GetAssertionLargeBlobExtension::Read),
+        }),
+        timeout: TIMEOUT,
+        top_origin: None,
+    };
+    let ga_response = channel
+        .webauthn_get_assertion(&ga)
+        .await
+        .expect("GetAssertion should succeed");
+    let blob = ga_response.assertions[0]
+        .unsigned_extensions_output
+        .as_ref()
+        .and_then(|u| u.large_blob.as_ref())
+        .and_then(|lb| lb.blob.as_ref())
+        .expect("largeBlob.blob populated");
+    assert_eq!(blob.as_slice(), plaintext.as_slice());
+
+    update_handle.await.unwrap();
+}
+
+/// Capture the per-credential AES key via a direct CTAP GetAssertion.
+async fn capture_large_blob_key(
+    channel: &mut libwebauthn::transport::hid::channel::HidChannel<'_>,
+    credential: &Ctap2PublicKeyCredentialDescriptor,
+    challenge: &[u8; 32],
+) -> [u8; 32] {
+    let ga_for_key = GetAssertionRequest {
+        relying_party_id: RP.into(),
+        origin: RP.into(),
+        challenge: challenge.to_vec(),
+        allow: vec![credential.clone()],
+        user_verification: UserVerificationRequirement::Discouraged,
+        extensions: Some(GetAssertionRequestExtensions {
+            appid: None,
+            cred_blob: false,
+            prf: None,
+            large_blob: Some(GetAssertionLargeBlobExtension::Read),
+        }),
+        timeout: TIMEOUT,
+        top_origin: None,
+    };
+    let ctap_req: Ctap2GetAssertionRequest = ga_for_key.into();
+    let ctap_resp = channel
+        .ctap2_get_assertion(&ctap_req, TIMEOUT)
+        .await
+        .expect("CTAP get_assertion succeeds");
+    let key_buf = ctap_resp
+        .large_blob_key
+        .expect("device returns largeBlobKey when extension requested");
+    key_buf
+        .as_slice()
+        .try_into()
+        .expect("largeBlobKey is 32 bytes")
+}
+
+/// Plant a serialized largeBlobArray via direct CTAP set (no-PIN path).
+async fn plant_large_blob_array(
+    channel: &mut libwebauthn::transport::hid::channel::HidChannel<'_>,
+    serialized: Vec<u8>,
+) {
+    let length = serialized.len() as u32;
+    let req = Ctap2LargeBlobsRequest {
+        get: None,
+        set: Some(serde_bytes::ByteBuf::from(serialized)),
+        offset: 0,
+        length: Some(length),
+        pin_uv_auth_param: None,
+        pin_uv_auth_protocol: None,
+    };
+    channel
+        .ctap2_large_blobs(&req, TIMEOUT)
+        .await
+        .expect("authenticatorLargeBlobs(set) succeeds without PIN");
+}
+
+/// Encode one largeBlobMap entry per CTAP 2.1 §6.10.3.
+fn encode_entry(key: &[u8; 32], nonce: &[u8; 12], plaintext: &[u8]) -> Vec<u8> {
+    use aes_gcm::aead::Aead;
+    use aes_gcm::{Aes256Gcm, Key, KeyInit, Nonce};
+    use flate2::write::DeflateEncoder;
+    use flate2::Compression;
+    use serde_cbor_2::value::Value as CborVal;
+    use std::collections::BTreeMap;
+    use std::io::Write;
+
+    let mut compressed = Vec::new();
+    {
+        let mut enc = DeflateEncoder::new(&mut compressed, Compression::default());
+        enc.write_all(plaintext).unwrap();
+        enc.finish().unwrap();
+    }
+    let mut ad = b"blob".to_vec();
+    ad.extend_from_slice(&(plaintext.len() as u64).to_le_bytes());
+    let cipher = Aes256Gcm::new(Key::<Aes256Gcm>::from_slice(key));
+    let ciphertext = cipher
+        .encrypt(
+            Nonce::from_slice(nonce),
+            aes_gcm::aead::Payload {
+                msg: &compressed,
+                aad: &ad,
+            },
+        )
+        .unwrap();
+
+    let mut map = BTreeMap::new();
+    map.insert(CborVal::Integer(1), CborVal::Bytes(ciphertext));
+    map.insert(CborVal::Integer(2), CborVal::Bytes(nonce.to_vec()));
+    map.insert(
+        CborVal::Integer(3),
+        CborVal::Integer(plaintext.len() as i128),
+    );
+    let mut buf = Vec::new();
+    serde_cbor_2::to_writer(&mut buf, &CborVal::Map(map)).unwrap();
+    buf
+}
+
+/// Wrap entries in a CBOR array + 16-byte left-SHA-256 trailer (CTAP 2.1 §6.10.3).
+fn encode_serialized_array(entries: &[Vec<u8>]) -> Vec<u8> {
+    use sha2::{Digest, Sha256};
+    assert!(entries.len() <= 23, "test fixture uses short-form CBOR array");
+    let mut out = vec![0x80 | entries.len() as u8];
+    for e in entries {
+        out.extend_from_slice(e);
+    }
+    let h = Sha256::digest(&out);
+    out.extend_from_slice(&h[..16]);
+    out
+}
