Skip to content

feat(obfuscation/redis): Reach feature parity on redis obfuscation [APMSP-2668] #1632

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
gh-worker-dd-mergequeue-cf854d merged 5 commits into from
Mar 6, 2026
+168 −5
Merged

feat(obfuscation/redis): Reach feature parity on redis obfuscation [APMSP-2668] #1632

Changes from 3 commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
4df3233
feat: make remove_all_redis_args public
Eldolfin Feb 26, 2026
0f2e331
fix: obfuscate multiple hset kv entries
Eldolfin Feb 23, 2026
e9f4d0c
feat: implement quantize redis obfuscation
Eldolfin Feb 24, 2026
e46bd83
apply copilot's suggestion
Eldolfin Feb 26, 2026
dfa071c
test: add HSET multiple args test
Eldolfin Feb 26, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
168 changes: 163 additions & 5 deletions libdd-trace-obfuscation/src/redis.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,61 @@

use crate::redis_tokenizer::{RedisTokenType, RedisTokenizer};

const REDIS_TRUNCATION_MARK: &str = "...";
const MAX_REDIS_NB_COMMANDS: usize = 3;

/// Returns a quantized version of a Redis query, keeping only up to 3 command names.
pub fn quantize_redis_string(query: &str) -> String {
let mut commands: Vec<String> = Vec::with_capacity(MAX_REDIS_NB_COMMANDS);
let mut truncated = false;

for raw_line in query.split('\n') {
if commands.len() >= MAX_REDIS_NB_COMMANDS {
break;
}

let line = raw_line.trim_matches(' ');
if line.is_empty() {
continue;
}

let mut tokens = line.split(' ').filter(|s| !s.is_empty());
let Some(first) = tokens.next() else { continue };

if first.ends_with(REDIS_TRUNCATION_MARK) {
truncated = true;
continue;
}

let cmd = first.to_ascii_uppercase();
let command = match cmd.as_bytes() {
b"CLIENT" | b"CLUSTER" | b"COMMAND" | b"CONFIG" | b"DEBUG" | b"SCRIPT" => {
match tokens.next() {
Some(sub) if sub.ends_with(REDIS_TRUNCATION_MARK) => {
truncated = true;
continue;
}
Some(sub) => format!("{cmd} {}", sub.to_ascii_uppercase()),
None => cmd,
}
}
_ => cmd,
};

commands.push(command);
truncated = false;
}

let mut result = commands.join(" ");
if commands.len() == MAX_REDIS_NB_COMMANDS || truncated {
if !result.is_empty() {
result.push(' ');
}
result.push_str("...");
}
Comment on lines +51 to +57
Copy link

Copilot AI Feb 26, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The ellipsis logic appends "..." whenever commands.len() == MAX_REDIS_NB_COMMANDS, even if the input contains exactly 3 commands and nothing more. If the intent is to indicate truncation only when additional (non-empty) commands exist (or a truncation mark was seen), this should instead be conditioned on having remaining content beyond the captured commands.

Copilot uses AI. Check for mistakes.
result
}

pub fn obfuscate_redis_string(cmd: &str) -> String {
let mut tokenizer = RedisTokenizer::new(cmd);
let s = &mut String::new();
Expand Down Expand Up @@ -79,8 +134,8 @@ fn obfuscate_redis_cmd<'a>(str: &mut String, cmd: &'a str, mut args: Vec<&'a str
// • ZSCORE key member
args = obfuscate_redis_args_n(args, 1);
}
b"HSET" | b"HSETNX" | b"LREM" | b"LSET" | b"SETBIT" | b"SETEX" | b"PSETEX"
| b"SETRANGE" | b"ZINCRBY" | b"SMOVE" | b"RESTORE" => {
b"HSETNX" | b"LREM" | b"LSET" | b"SETBIT" | b"SETEX" | b"PSETEX" | b"SETRANGE"
| b"ZINCRBY" | b"SMOVE" | b"RESTORE" => {
// Obfuscate 3rd argument:
// • HSET key field value
// • HSETNX key field value
Expand Down Expand Up @@ -120,7 +175,7 @@ fn obfuscate_redis_cmd<'a>(str: &mut String, cmd: &'a str, mut args: Vec<&'a str
// • GEOADD key longitude latitude member [longitude latitude member ...]
args = obfuscate_redis_args_step(args, 1, 3)
}
b"HMSET" => {
b"HMSET" | b"HSET" => {
// Every 2nd argument starting from first.
// • HMSET key field value [field value ...]
args = obfuscate_redis_args_step(args, 1, 2)
Expand Down Expand Up @@ -196,7 +251,7 @@ fn obfuscate_redis_args_step(mut args: Vec<&str>, start: usize, step: usize) ->
args
}

pub(crate) fn remove_all_redis_args(redis_cmd: &str) -> String {
pub fn remove_all_redis_args(redis_cmd: &str) -> String {
let mut redis_cmd_iter = redis_cmd.split_whitespace().peekable();
let mut obfuscated_cmd = String::new();

Expand Down Expand Up @@ -267,7 +322,110 @@ fn ascii_uppercase<'a>(s: &str, dest: &'a mut [u8]) -> Option<&'a [u8]> {
mod tests {
use duplicate::duplicate_item;

use super::{obfuscate_redis_string, remove_all_redis_args};
use super::{obfuscate_redis_string, quantize_redis_string, remove_all_redis_args};

#[duplicate_item(
[
test_name [test_quantize_redis_string_client]
input ["CLIENT"]
expected ["CLIENT"];
]
[
test_name [test_quantize_redis_string_client_list]
input ["CLIENT LIST"]
expected ["CLIENT LIST"];
]
[
test_name [test_quantize_redis_string_get_lowercase]
input ["get my_key"]
expected ["GET"];
]
[
test_name [test_quantize_redis_string_set]
input ["SET le_key le_value"]
expected ["SET"];
]
[
test_name [test_quantize_redis_string_set_with_newlines]
input ["\n\n \nSET foo bar \n \n\n "]
expected ["SET"];
]
[
test_name [test_quantize_redis_string_config_set]
input ["CONFIG SET parameter value"]
expected ["CONFIG SET"];
]
[
test_name [test_quantize_redis_string_two_cmds]
input ["SET toto tata \n \n EXPIRE toto 15 "]
expected ["SET EXPIRE"];
]
[
test_name [test_quantize_redis_string_mset]
input ["MSET toto tata toto tata toto tata \n "]
expected ["MSET"];
]
[
test_name [test_quantize_redis_string_max_cmds]
input ["MULTI\nSET k1 v1\nSET k2 v2\nSET k3 v3\nSET k4 v4\nDEL to_del\nEXEC"]
expected ["MULTI SET SET ..."];
]
[
test_name [test_quantize_redis_string_truncation_first]
input ["GET..."]
expected ["..."];
]
[
test_name [test_quantize_redis_string_truncation_arg]
input ["GET k..."]
expected ["GET"];
]
[
test_name [test_quantize_redis_string_truncation_third]
input ["GET k1\nGET k2\nG..."]
expected ["GET GET ..."];
]
[
test_name [test_quantize_redis_string_truncation_after_max]
input ["GET k1\nGET k2\nDEL k3\nGET k..."]
expected ["GET GET DEL ..."];
]
[
test_name [test_quantize_redis_string_truncation_hdel]
input ["GET k1\nGET k2\nHDEL k3 a\nG..."]
expected ["GET GET HDEL ..."];
]
[
test_name [test_quantize_redis_string_truncation_mid]
input ["GET k...\nDEL k2\nMS..."]
expected ["GET DEL ..."];
]
[
test_name [test_quantize_redis_string_truncation_early]
input ["GET k...\nDE...\nMS..."]
expected ["GET ..."];
]
[
test_name [test_quantize_redis_string_truncation_then_cmd]
input ["GET k1\nDE...\nGET k2"]
expected ["GET GET"];
]
[
test_name [test_quantize_redis_string_truncation_complex]
input ["GET k1\nDE...\nGET k2\nHDEL k3 a\nGET k4\nDEL k5"]
expected ["GET GET HDEL ..."];
]
[
test_name [test_quantize_redis_string_unknown]
input ["UNKNOWN 123"]
expected ["UNKNOWN"];
]
)]
#[test]
fn test_name() {
let result = quantize_redis_string(input);
assert_eq!(result, expected);
}

#[duplicate_item(
[
Expand Down
Loading