use crate::detect::SIGMATCH_QUOTES_MANDATORY;
use suricata_sys::sys::{
DetectEngineCtx, DetectEngineThreadCtx, InspectionBuffer, SCDetectHelperTransformRegister,
SCDetectSignatureAddTransform, SCInspectionBufferCheckAndExpand, SCInspectionBufferTruncate,
SCTransformTableElmt, Signature,
};
use std::ffi::CStr;
use std::os::raw::{c_int, c_void};
static mut G_TRANSFORM_XOR_ID: c_int = 0;
#[derive(Debug, PartialEq)]
struct DetectTransformXorData {
key: Vec<u8>,
}
fn xor_parse_do(i: &str) -> Option<DetectTransformXorData> {
if i.len() % 2 != 0 {
SCLogError!("XOR transform key's length must be an even number");
return None;
}
if i.len() / 2 > usize::from(u8::MAX) {
SCLogError!("Key length too big for XOR transform");
return None;
}
if let Ok(key) = hex::decode(i) {
return Some(DetectTransformXorData { key });
}
SCLogError!("XOR transform key must be hexadecimal characters only");
return None;
}
unsafe fn xor_parse(raw: *const std::os::raw::c_char) -> *mut c_void {
let raw: &CStr = CStr::from_ptr(raw); if let Ok(s) = raw.to_str() {
if let Some(ctx) = xor_parse_do(s) {
let boxed = Box::new(ctx);
return Box::into_raw(boxed) as *mut _;
}
}
return std::ptr::null_mut();
}
unsafe extern "C" fn xor_setup(
de: *mut DetectEngineCtx, s: *mut Signature, opt_str: *const std::os::raw::c_char,
) -> c_int {
let ctx = xor_parse(opt_str);
if ctx.is_null() {
return -1;
}
let r = SCDetectSignatureAddTransform(s, G_TRANSFORM_XOR_ID, ctx);
if r != 0 {
xor_free(de, ctx);
}
return r;
}
fn xor_transform_do(input: &[u8], output: &mut [u8], ctx: &DetectTransformXorData) {
let mut ki = 0;
for (i, o) in input.iter().zip(output.iter_mut()) {
*o = (*i) ^ ctx.key[ki];
ki = (ki + 1) % ctx.key.len();
}
}
unsafe extern "C" fn xor_transform(
_det: *mut DetectEngineThreadCtx, buffer: *mut InspectionBuffer, ctx: *mut c_void,
) {
let input = (*buffer).inspect;
let input_len = (*buffer).inspect_len;
if input.is_null() || input_len == 0 {
return;
}
let input = build_slice!(input, input_len as usize);
let output = SCInspectionBufferCheckAndExpand(buffer, input_len);
if output.is_null() {
return;
}
let output = std::slice::from_raw_parts_mut(output, input_len as usize);
let ctx = cast_pointer!(ctx, DetectTransformXorData);
xor_transform_do(input, output, ctx);
SCInspectionBufferTruncate(buffer, input_len);
}
unsafe extern "C" fn xor_free(_de: *mut DetectEngineCtx, ctx: *mut c_void) {
std::mem::drop(Box::from_raw(ctx as *mut DetectTransformXorData));
}
unsafe extern "C" fn xor_id(data: *mut *const u8, length: *mut u32, ctx: *mut c_void) {
if data.is_null() || length.is_null() || ctx.is_null() {
return;
}
let ctx = cast_pointer!(ctx, DetectTransformXorData);
*data = ctx.key.as_ptr();
*length = ctx.key.len() as u32;
}
#[no_mangle]
pub unsafe extern "C" fn DetectTransformXorRegister() {
let kw = SCTransformTableElmt {
name: b"xor\0".as_ptr() as *const libc::c_char,
desc: b"modify buffer via XOR decoding before inspection\0".as_ptr() as *const libc::c_char,
url: b"/rules/transforms.html#xor\0".as_ptr() as *const libc::c_char,
Setup: Some(xor_setup),
flags: SIGMATCH_QUOTES_MANDATORY,
Transform: Some(xor_transform),
Free: Some(xor_free),
TransformValidate: None,
TransformId: Some(xor_id),
};
unsafe {
G_TRANSFORM_XOR_ID = SCDetectHelperTransformRegister(&kw);
if G_TRANSFORM_XOR_ID < 0 {
SCLogWarning!("Failed registering transform xor");
}
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_xor_parse() {
assert!(xor_parse_do("nohexa").is_none());
let key = b"\x0a\x0d\xc8\xff";
assert_eq!(
xor_parse_do("0a0DC8ff"),
Some(DetectTransformXorData { key: key.to_vec() })
);
}
#[test]
fn test_xor_id() {
let ctx = Box::new(DetectTransformXorData {
key: vec![1, 2, 3, 4, 5],
});
let ctx_ptr: *const c_void = &*ctx as *const _ as *const c_void;
let mut data_ptr: *const u8 = std::ptr::null();
let mut length: u32 = 0;
unsafe {
xor_id(
&mut data_ptr as *mut *const u8,
&mut length as *mut u32,
ctx_ptr as *mut c_void,
);
assert!(!data_ptr.is_null(), "data_ptr should not be null");
assert_eq!(length, 5);
let actual = std::slice::from_raw_parts(data_ptr, length as usize);
assert_eq!(actual, &[1, 2, 3, 4, 5]);
}
}
#[test]
fn test_xor_transform() {
let mut buf = Vec::new();
buf.extend_from_slice(b"example.com");
let mut out = vec![0; buf.len()];
let ctx = xor_parse_do("0a0DC8ff").unwrap();
xor_transform_do(&buf, &mut out, &ctx);
assert_eq!(out, b"ou\xa9\x92za\xad\xd1ib\xa5");
let still_buf = unsafe { std::slice::from_raw_parts(buf.as_ptr(), buf.len()) };
xor_transform_do(still_buf, &mut buf, &ctx);
assert_eq!(&still_buf, b"ou\xa9\x92za\xad\xd1ib\xa5");
}
}