use std::{cmp::max, pin::Pin};
use hybrid_array::Array;
use typenum::U32;
use super::Aes256CbcHmacKey;
use crate::{CryptoError, Result, util::hkdf_expand};
pub(super) fn stretch_key(key: &Pin<Box<Array<u8, U32>>>) -> Aes256CbcHmacKey {
Aes256CbcHmacKey {
enc_key: hkdf_expand(key, Some("enc")).expect("HKDF expand to succeed"),
mac_key: hkdf_expand(key, Some("mac")).expect("HKDF expand to succeed"),
}
}
pub(crate) fn pad_bytes(bytes: &mut Vec<u8>, min_length: usize) -> Result<(), CryptoError> {
let pad_bytes = min_length.saturating_sub(bytes.len()).max(1);
if pad_bytes > 255 {
return Err(CryptoError::InvalidPadding);
}
let padded_length = max(min_length, bytes.len() + 1);
bytes.resize(padded_length, pad_bytes as u8);
Ok(())
}
pub(crate) fn unpad_bytes(padded_bytes: &[u8]) -> Result<&[u8], CryptoError> {
let pad_len = *padded_bytes.last().ok_or(CryptoError::InvalidPadding)? as usize;
if pad_len == 0 || pad_len > padded_bytes.len() {
return Err(CryptoError::InvalidPadding);
}
Ok(padded_bytes[..(padded_bytes.len() - pad_len)].as_ref())
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_stretch_kdf_key() {
let key = Box::pin(
[
31, 79, 104, 226, 150, 71, 177, 90, 194, 80, 172, 209, 17, 129, 132, 81, 138, 167,
69, 167, 254, 149, 2, 27, 39, 197, 64, 42, 22, 195, 86, 75,
]
.into(),
);
let stretched = stretch_key(&key);
assert_eq!(
[
111, 31, 178, 45, 238, 152, 37, 114, 143, 215, 124, 83, 135, 173, 195, 23, 142,
134, 120, 249, 61, 132, 163, 182, 113, 197, 189, 204, 188, 21, 237, 96
],
stretched.enc_key.as_slice()
);
assert_eq!(
[
221, 127, 206, 234, 101, 27, 202, 38, 86, 52, 34, 28, 78, 28, 185, 16, 48, 61, 127,
166, 209, 247, 194, 87, 232, 26, 48, 85, 193, 249, 179, 155
],
stretched.mac_key.as_slice()
);
}
#[test]
fn test_pad_bytes_256_error() {
let mut bytes = vec![1u8; 0];
let result = pad_bytes(&mut bytes, 256);
assert!(matches!(result, Err(CryptoError::InvalidPadding)));
}
#[test]
fn test_pad_bytes_roundtrip() {
let original_bytes = vec![1u8; 10];
let mut cloned_bytes = original_bytes.clone();
let mut encoded_bytes = vec![1u8; 12];
encoded_bytes[10] = 2;
encoded_bytes[11] = 2;
pad_bytes(&mut cloned_bytes, 12).expect("Padding failed");
assert_eq!(encoded_bytes, cloned_bytes);
let unpadded_bytes = unpad_bytes(&cloned_bytes).unwrap();
assert_eq!(original_bytes, unpadded_bytes);
}
#[test]
fn test_pad_bytes_roundtrip_empty() {
let original_bytes = Vec::new();
let mut cloned_bytes = original_bytes.clone();
pad_bytes(&mut cloned_bytes, 32).expect("Padding failed");
let unpadded = unpad_bytes(&cloned_bytes).unwrap();
assert_eq!(Vec::<u8>::new(), unpadded);
}
#[test]
fn test_unpad_bytes_invalid_empty() {
let data: Vec<u8> = vec![];
let result = unpad_bytes(&data);
assert!(matches!(result, Err(CryptoError::InvalidPadding)));
}
#[test]
fn test_unpad_bytes_invalid_too_large() {
let data = vec![1, 2, 3, 5];
let result = unpad_bytes(&data);
assert!(matches!(result, Err(CryptoError::InvalidPadding)));
}
#[test]
fn test_unpad_bytes_invalid_0_padding() {
let data = vec![1, 2, 3, 0];
let result = unpad_bytes(&data);
assert!(matches!(result, Err(CryptoError::InvalidPadding)));
}
#[test]
fn test_pad_and_unpad_bytes_range_0_to_1024() {
let cases: Vec<_> = (0..=1024)
.flat_map(|data_size| (2..=1024).map(move |padding_size| (data_size, padding_size)))
.collect();
let data_larger_than_padding_cases: Vec<_> = cases
.clone()
.into_iter()
.filter(|(data_size, padding_size)| data_size > padding_size)
.collect();
for (data_size, padding_size) in data_larger_than_padding_cases {
let mut data: Vec<u8> = vec![0x12; data_size];
let original = data.clone();
pad_bytes(&mut data, padding_size).expect("Padding failed");
let unpadded = unpad_bytes(&data).expect("Unpadding failed");
assert_eq!(
unpadded, original,
"Failed at size {} and padding {}",
data_size, padding_size
);
}
let padding_larger_than_data_cases: Vec<_> = cases
.clone()
.into_iter()
.filter(|(data_size, padding_size)| {
data_size <= padding_size && (padding_size - data_size) <= 255
})
.collect();
for (data_size, padding_size) in padding_larger_than_data_cases {
println!(
"Testing data_size: {}, padding_size: {}",
data_size, padding_size
);
let data_original: Vec<u8> = vec![0x12; data_size];
let mut data = data_original.clone();
pad_bytes(&mut data, padding_size).expect("Padding failed");
let unpadded = unpad_bytes(&data).expect("Unpadding failed");
assert_eq!(
unpadded, data_original,
"Failed at size {} and padding {}",
data_size, padding_size
);
}
let padding_massively_larger_than_data_cases: Vec<_> = cases
.into_iter()
.filter(|(data_size, padding_size)| {
data_size <= padding_size && (padding_size - data_size) > 255
})
.collect();
for (data_size, padding_size) in padding_massively_larger_than_data_cases {
let mut data: Vec<u8> = vec![0x12; data_size];
let error = pad_bytes(&mut data, padding_size);
assert!(
matches!(error, Err(CryptoError::InvalidPadding)),
"Expected InvalidPadding error at size {} and padding {}, but got {:?}",
data_size,
padding_size,
error
);
}
}
}