use crate::packet::{Layer, LayerContext};
use crate::protocols::ipsec::ikev2::payload::{
write_generic_payload_header, IkePayload, PayloadHeaderFields, PayloadType,
};
use crate::protocols::transport::common::{impl_layer_div, impl_layer_object};
use crate::Result;
pub const IKE_NONCE_PAYLOAD_NAME: &str = "IkeNoncePayload";
pub const NONCE_MIN_LEN: usize = 16;
pub const NONCE_MAX_LEN: usize = 256;
#[derive(Debug, Clone)]
pub struct IkeNoncePayload {
nonce: Vec<u8>,
header: PayloadHeaderFields,
}
impl IkeNoncePayload {
pub fn new(nonce: impl Into<Vec<u8>>) -> Self {
Self {
nonce: nonce.into(),
header: PayloadHeaderFields::new(),
}
}
pub fn nonce(mut self, nonce: impl Into<Vec<u8>>) -> Self {
self.nonce = nonce.into();
self
}
pub fn nonce_bytes(&self) -> &[u8] {
&self.nonce
}
pub fn next_payload(mut self, next_payload: u8) -> Self {
self.header.set_next_payload(next_payload);
self
}
pub fn payload_length(mut self, length: u16) -> Self {
self.header.set_length(length);
self
}
pub fn critical(mut self, critical: bool) -> Self {
self.header.set_critical(critical);
self
}
fn nonce_body(&self) -> Vec<u8> {
self.nonce.clone()
}
}
impl IkePayload for IkeNoncePayload {
fn payload_type(&self) -> PayloadType {
PayloadType::Nonce
}
fn payload_body(&self, _ctx: &LayerContext<'_>) -> Result<Vec<u8>> {
Ok(self.nonce_body())
}
fn next_payload_override(&self) -> Option<u8> {
self.header.next_payload_override()
}
fn payload_length_override(&self) -> Option<u16> {
self.header.payload_length_override()
}
fn critical(&self) -> bool {
self.header.critical()
}
}
impl Layer for IkeNoncePayload {
fn name(&self) -> &'static str {
IKE_NONCE_PAYLOAD_NAME
}
fn summary(&self) -> String {
format!("IkeNoncePayload(nonce_len={})", self.nonce.len())
}
fn inspection_fields(&self) -> Vec<(&'static str, String)> {
vec![("nonce_len", self.nonce.len().to_string())]
}
fn encoded_len(&self) -> usize {
super::GENERIC_PAYLOAD_HEADER_LEN + self.nonce.len()
}
fn compile(&self, ctx: &LayerContext<'_>, out: &mut Vec<u8>) -> Result<()> {
let body = self.payload_body(ctx)?;
write_generic_payload_header(
out,
ctx,
self.next_payload_override(),
self.critical(),
self.payload_length_override(),
body.len(),
)?;
out.extend_from_slice(&body);
Ok(())
}
impl_layer_object!(IkeNoncePayload);
}
impl_layer_div!(IkeNoncePayload);
pub(crate) fn parse_nonce_payload_body(bytes: &[u8]) -> Result<IkeNoncePayload> {
Ok(IkeNoncePayload::new(bytes.to_vec()))
}
#[cfg(test)]
mod tests {
use super::*;
use crate::packet::{LayerContext, Packet, Raw};
use crate::protocols::ipsec::ikev2::payload::GENERIC_PAYLOAD_HEADER_LEN;
fn compile_payload(payload: IkeNoncePayload) -> Vec<u8> {
let packet = Packet::from_layer(payload);
let ctx = LayerContext::new(&packet, 0);
let mut out = Vec::new();
packet.get(0).unwrap().compile(&ctx, &mut out).unwrap();
out
}
fn sample_nonce() -> Vec<u8> {
(0u8..16).map(|i| 0xA0 ^ i).collect()
}
fn sample_payload() -> IkeNoncePayload {
IkeNoncePayload::new(sample_nonce())
}
#[test]
fn nonce_constants_match_rfc() {
assert_eq!(NONCE_MIN_LEN, 16);
assert_eq!(NONCE_MAX_LEN, 256);
}
#[test]
fn payload_type_is_nonce() {
assert_eq!(sample_payload().payload_type(), PayloadType::Nonce);
assert_eq!(sample_payload().name(), IKE_NONCE_PAYLOAD_NAME);
}
#[test]
fn body_is_the_nonce_data() {
let payload = sample_payload();
let body = payload.nonce_body();
assert_eq!(body, sample_nonce());
assert_eq!(body.len(), 16);
}
#[test]
fn payload_compiles_generic_header_then_body() {
let payload = sample_payload();
let bytes = compile_payload(payload.clone());
assert_eq!(bytes[0], 0);
assert_eq!(bytes[1], 0);
let payload_len = u16::from_be_bytes([bytes[2], bytes[3]]) as usize;
assert_eq!(payload_len, bytes.len());
assert_eq!(payload_len, payload.encoded_len());
assert_eq!(&bytes[GENERIC_PAYLOAD_HEADER_LEN..], &sample_nonce()[..]);
}
#[test]
fn payload_honors_generic_header_overrides() {
let payload = sample_payload()
.next_payload(34)
.critical(true)
.payload_length(0xBEEF);
let bytes = compile_payload(payload);
assert_eq!(bytes[0], 34);
assert_eq!(bytes[1], 0x80); assert_eq!(u16::from_be_bytes([bytes[2], bytes[3]]), 0xBEEF);
}
#[test]
fn allows_any_length_for_malformed_testing() {
let short = IkeNoncePayload::new(vec![0xFFu8; 4]);
let short_bytes = compile_payload(short.clone());
assert_eq!(short_bytes.len(), GENERIC_PAYLOAD_HEADER_LEN + 4);
let parsed_short =
parse_nonce_payload_body(&short_bytes[GENERIC_PAYLOAD_HEADER_LEN..]).unwrap();
assert_eq!(parsed_short.nonce_bytes(), short.nonce_bytes());
let long = IkeNoncePayload::new(vec![0x5Au8; 300]);
let long_bytes = compile_payload(long.clone());
assert_eq!(long_bytes.len(), GENERIC_PAYLOAD_HEADER_LEN + 300);
let parsed_long =
parse_nonce_payload_body(&long_bytes[GENERIC_PAYLOAD_HEADER_LEN..]).unwrap();
assert_eq!(parsed_long.nonce_bytes(), long.nonce_bytes());
let empty = IkeNoncePayload::new(Vec::<u8>::new());
let empty_bytes = compile_payload(empty);
assert_eq!(empty_bytes.len(), GENERIC_PAYLOAD_HEADER_LEN);
let parsed_empty =
parse_nonce_payload_body(&empty_bytes[GENERIC_PAYLOAD_HEADER_LEN..]).unwrap();
assert!(parsed_empty.nonce_bytes().is_empty());
}
#[test]
fn payload_chain_next_payload_points_at_nonce() {
use crate::protocols::ipsec::ikev2::payload::{
following_next_payload, payload_type_for_layer_name, PAYLOAD_NONCE,
};
assert_eq!(
payload_type_for_layer_name(IKE_NONCE_PAYLOAD_NAME),
Some(PayloadType::Nonce)
);
let packet: Packet = Packet::from_layer(Raw::from_bytes([0u8; 0])) / sample_payload();
let ctx = LayerContext::new(&packet, 0);
assert_eq!(following_next_payload(&ctx), PAYLOAD_NONCE);
}
#[test]
fn round_trip_preserves_nonce() {
let payload = sample_payload();
let bytes = compile_payload(payload.clone());
let parsed = parse_nonce_payload_body(&bytes[GENERIC_PAYLOAD_HEADER_LEN..]).unwrap();
assert_eq!(parsed.nonce_bytes(), payload.nonce_bytes());
}
#[test]
fn round_trip_recompiles_byte_for_byte() {
let payload = sample_payload();
let bytes = compile_payload(payload);
let parsed = parse_nonce_payload_body(&bytes[GENERIC_PAYLOAD_HEADER_LEN..]).unwrap();
let recompiled = compile_payload(parsed);
assert_eq!(recompiled, bytes);
}
}