Add support for filtering shaded third-party libs

jpbempel · jpbempel · commit 067bbb78ef50 · 2025-03-24T14:51:47.000+01:00
Add filtering on shading identifiers
Add option to add more shading idententifiers
diff --git a/dd-java-agent/agent-debugger/src/main/java/com/datadog/debugger/agent/ThirdPartyLibraries.java b/dd-java-agent/agent-debugger/src/main/java/com/datadog/debugger/agent/ThirdPartyLibraries.java
@@ -7,10 +7,12 @@
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStreamReader;
+import java.util.Arrays;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -22,6 +24,20 @@ public class ThirdPartyLibraries {
   private static final JsonAdapter<InternalConfig> ADAPTER =
       new Moshi.Builder().build().adapter(InternalConfig.class);
   private static final String FILE_NAME = "/third_party_libraries.json";
+  private static final Set<String> DEFAULT_SHADING_IDENTIFIERS =
+      new HashSet<>(
+          Arrays.asList(
+              "shaded",
+              "thirdparty",
+              "dependencies",
+              "relocated",
+              "bundled",
+              "embedded",
+              "vendor",
+              "repackaged",
+              "shadow",
+              "shim",
+              "wrapper"));
 
   private ThirdPartyLibraries() {}
 
@@ -46,6 +62,13 @@ public Set<String> getThirdPartyExcludes(Config config) {
         .collect(Collectors.toSet());
   }
 
+  public Set<String> getShadingIdentifiers(Config config) {
+    Stream<String> configStream =
+        config.getThirdPartyShadingIdentifiers().stream().filter(s -> !s.isEmpty());
+    return Stream.concat(configStream, DEFAULT_SHADING_IDENTIFIERS.stream())
+        .collect(Collectors.toSet());
+  }
+
   // Add a*, b*, c*, ..., z* to the exclude trie in ClassNameFiltering. Simply adding * does not
   // work.
   private static Set<String> getExcludeAll() {
diff --git a/dd-java-agent/agent-debugger/src/main/java/com/datadog/debugger/symbol/SymbolExtractionTransformer.java b/dd-java-agent/agent-debugger/src/main/java/com/datadog/debugger/symbol/SymbolExtractionTransformer.java
@@ -1,6 +1,7 @@
 package com.datadog.debugger.symbol;
 
 import datadog.trace.bootstrap.debugger.DebuggerContext.ClassNameFilter;
+import datadog.trace.util.Strings;
 import java.lang.instrument.ClassFileTransformer;
 import java.security.ProtectionDomain;
 import org.slf4j.Logger;
@@ -34,7 +35,7 @@ public byte[] transform(
         // Don't parse our own classes to avoid duplicate class definition
         return null;
       }
-      if (classNameFiltering.isExcluded(className)) {
+      if (classNameFiltering.isExcluded(Strings.getClassName(className))) {
         return null;
       }
       symbolAggregator.parseClass(className, classfileBuffer, protectionDomain);
diff --git a/dd-java-agent/agent-debugger/src/main/java/com/datadog/debugger/util/ClassNameFiltering.java b/dd-java-agent/agent-debugger/src/main/java/com/datadog/debugger/util/ClassNameFiltering.java
@@ -4,6 +4,7 @@
 import datadog.trace.api.Config;
 import datadog.trace.bootstrap.debugger.DebuggerContext.ClassNameFilter;
 import datadog.trace.util.ClassNameTrie;
+import datadog.trace.util.Strings;
 import java.util.Collections;
 import java.util.Set;
 import java.util.regex.Pattern;
@@ -14,36 +15,53 @@ public class ClassNameFiltering implements ClassNameFilter {
 
   private final ClassNameTrie includeTrie;
   private final ClassNameTrie excludeTrie;
+  private final Set<String> shadingIdentifiers;
 
   public ClassNameFiltering(Config config) {
     this(
         ThirdPartyLibraries.INSTANCE.getThirdPartyLibraries(config),
-        ThirdPartyLibraries.INSTANCE.getThirdPartyExcludes(config));
+        ThirdPartyLibraries.INSTANCE.getThirdPartyExcludes(config),
+        ThirdPartyLibraries.INSTANCE.getShadingIdentifiers(config));
   }
 
   public ClassNameFiltering(Set<String> excludes) {
-    this(excludes, Collections.emptySet());
+    this(excludes, Collections.emptySet(), Collections.emptySet());
   }
 
-  public ClassNameFiltering(Set<String> excludes, Set<String> includes) {
+  public ClassNameFiltering(
+      Set<String> excludes, Set<String> includes, Set<String> shadingIdentifiers) {
     ClassNameTrie.Builder excludeBuilder = new ClassNameTrie.Builder();
     excludes.forEach(s -> excludeBuilder.put(s + "*", 1));
     this.excludeTrie = excludeBuilder.buildTrie();
     ClassNameTrie.Builder includeBuilder = new ClassNameTrie.Builder();
     includes.forEach(s -> includeBuilder.put(s + "*", 1));
     this.includeTrie = includeBuilder.buildTrie();
+    this.shadingIdentifiers = shadingIdentifiers;
   }
 
+  // className is the fully qualified class name with '.' (Java type) notation
   public boolean isExcluded(String className) {
     return (includeTrie.apply(className) < 0 && excludeTrie.apply(className) > 0)
-        || isLambdaProxyClass(className);
+        || isLambdaProxyClass(className)
+        || isShaded(className);
   }
 
   static boolean isLambdaProxyClass(String className) {
     return LAMBDA_PROXY_CLASS_PATTERN.matcher(className).matches();
   }
 
+  boolean isShaded(String className) {
+    String packageName = Strings.getPackageName(className);
+    for (String shadingIdentifier : shadingIdentifiers) {
+      if (packageName.contains(shadingIdentifier)) {
+        return true;
+      }
+    }
+    return false;
+  }
+
   public static ClassNameFiltering allowAll() {
-    return new ClassNameFiltering(Collections.emptySet(), Collections.emptySet());
+    return new ClassNameFiltering(
+        Collections.emptySet(), Collections.emptySet(), Collections.emptySet());
   }
 }
diff --git a/dd-java-agent/agent-debugger/src/test/java/com/datadog/debugger/agent/ThirdPartyLibrariesTest.java b/dd-java-agent/agent-debugger/src/test/java/com/datadog/debugger/agent/ThirdPartyLibrariesTest.java
@@ -1,5 +1,6 @@
 package com.datadog.debugger.agent;
 
+import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -20,6 +21,7 @@ class ThirdPartyLibrariesTest {
   void setUp() {
     when(mockConfig.getThirdPartyIncludes()).thenReturn(Collections.emptySet());
     when(mockConfig.getThirdPartyExcludes()).thenReturn(Collections.emptySet());
+    when(mockConfig.getThirdPartyShadingIdentifiers()).thenReturn(Collections.emptySet());
   }
 
   @Test
@@ -29,7 +31,6 @@ void testGetExcludesContainsDefaultExclude() {
 
   @Test
   void testGetExcludesWithExplicitExclude() {
-
     when(mockConfig.getThirdPartyIncludes())
         .thenReturn(Collections.singleton("com.datadog.debugger"));
     assertTrue(
@@ -72,4 +73,22 @@ void testGetExcludeAll() {
     Set<String> excludeAll = ThirdPartyLibraries.INSTANCE.getThirdPartyLibraries(null);
     for (char c : ThirdPartyLibraries.ALPHABET) assertTrue(excludeAll.contains(String.valueOf(c)));
   }
+
+  @Test
+  void testEmptyStrings() {
+    int expectedIncludeDefaultSize =
+        ThirdPartyLibraries.INSTANCE.getThirdPartyLibraries(mockConfig).size();
+    int expectedShadingDefaultSize =
+        ThirdPartyLibraries.INSTANCE.getShadingIdentifiers(mockConfig).size();
+    when(mockConfig.getThirdPartyIncludes()).thenReturn(Collections.singleton(""));
+    when(mockConfig.getThirdPartyExcludes()).thenReturn(Collections.singleton(""));
+    when(mockConfig.getThirdPartyShadingIdentifiers()).thenReturn(Collections.singleton(""));
+    assertEquals(
+        expectedIncludeDefaultSize,
+        ThirdPartyLibraries.INSTANCE.getThirdPartyLibraries(mockConfig).size());
+    assertTrue(ThirdPartyLibraries.INSTANCE.getThirdPartyExcludes(mockConfig).isEmpty());
+    assertEquals(
+        expectedShadingDefaultSize,
+        ThirdPartyLibraries.INSTANCE.getShadingIdentifiers(mockConfig).size());
+  }
 }
diff --git a/dd-java-agent/agent-debugger/src/test/java/com/datadog/debugger/symbol/SymDBEnablementTest.java b/dd-java-agent/agent-debugger/src/test/java/com/datadog/debugger/symbol/SymDBEnablementTest.java
@@ -169,7 +169,8 @@ public void noDuplicateSymbolExtraction() {
     ClassNameFiltering classNameFiltering =
         new ClassNameFiltering(
             Collections.singleton("org.springframework."),
-            Collections.singleton("com.datadog.debugger."));
+            Collections.singleton("com.datadog.debugger."),
+            Collections.emptySet());
     SymbolAggregator symbolAggregator = new SymbolAggregator(classNameFiltering, mockSymbolSink, 1);
     SymDBEnablement symDBEnablement =
         new SymDBEnablement(instr, config, symbolAggregator, classNameFiltering);
diff --git a/dd-java-agent/agent-debugger/src/test/java/com/datadog/debugger/symbol/SymbolExtractionTransformerTest.java b/dd-java-agent/agent-debugger/src/test/java/com/datadog/debugger/symbol/SymbolExtractionTransformerTest.java
@@ -982,7 +982,8 @@ private SymbolExtractionTransformer createTransformer(
     return createTransformer(
         symbolSink,
         symbolFlushThreshold,
-        new ClassNameFiltering(TRANSFORMER_EXCLUDES, Collections.singleton(SYMBOL_PACKAGE)));
+        new ClassNameFiltering(
+            TRANSFORMER_EXCLUDES, Collections.singleton(SYMBOL_PACKAGE), Collections.emptySet()));
   }
 
   private SymbolExtractionTransformer createTransformer(
diff --git a/dd-java-agent/agent-debugger/src/test/java/com/datadog/debugger/util/ClassNameFilteringTest.java b/dd-java-agent/agent-debugger/src/test/java/com/datadog/debugger/util/ClassNameFilteringTest.java
@@ -6,7 +6,6 @@
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 
-import com.datadog.debugger.agent.ThirdPartyLibraries;
 import datadog.trace.api.Config;
 import java.util.Collections;
 import java.util.HashSet;
@@ -52,15 +51,18 @@ public void testIncludeOverridesExclude() {
     ClassNameFiltering classNameFiltering =
         new ClassNameFiltering(
             Collections.singleton("com.datadog.debugger"),
-            Collections.singleton("com.datadog.debugger"));
+            Collections.singleton("com.datadog.debugger"),
+            Collections.emptySet());
     assertFalse(classNameFiltering.isExcluded("com.datadog.debugger.FooBar"));
   }
 
   @Test
   public void testIncludePrefixOverridesExclude() {
     ClassNameFiltering classNameFiltering =
         new ClassNameFiltering(
-            Collections.singleton("com.datadog.debugger"), Collections.singleton("com.datadog"));
+            Collections.singleton("com.datadog.debugger"),
+            Collections.singleton("com.datadog"),
+            Collections.emptySet());
     assertFalse(classNameFiltering.isExcluded("com.datadog.debugger.FooBar"));
   }
 
@@ -69,7 +71,8 @@ public void testIncludeSomeExcludeSome() {
     ClassNameFiltering classNameFiltering =
         new ClassNameFiltering(
             Stream.of("com.datadog.debugger", "org.junit").collect(Collectors.toSet()),
-            Collections.singleton("com.datadog.debugger"));
+            Collections.singleton("com.datadog.debugger"),
+            Collections.emptySet());
     assertFalse(classNameFiltering.isExcluded("com.datadog.debugger.FooBar"));
     assertTrue(classNameFiltering.isExcluded("org.junit.FooBar"));
   }
@@ -82,14 +85,15 @@ public void testIncludeSomeExcludeSome() {
         "akka.Actor",
         "cats.Functor",
         "org.junit.jupiter.api.Test",
-        "org.datadog.jmxfetch.FooBar"
+        "org.datadog.jmxfetch.FooBar",
+        "shaded.org.junit.Test"
       })
   public void testExcludeDefaults(String input) {
     Config config = mock(Config.class);
     when(config.getThirdPartyExcludes()).thenReturn(Collections.emptySet());
     when(config.getThirdPartyIncludes()).thenReturn(Collections.emptySet());
-    ClassNameFiltering classNameFiltering =
-        new ClassNameFiltering(ThirdPartyLibraries.INSTANCE.getThirdPartyLibraries(config));
+    when(config.getThirdPartyShadingIdentifiers()).thenReturn(Collections.emptySet());
+    ClassNameFiltering classNameFiltering = new ClassNameFiltering(config);
     assertTrue(classNameFiltering.isExcluded(input));
   }
 
diff --git a/dd-trace-api/src/main/java/datadog/trace/api/config/DebuggerConfig.java b/dd-trace-api/src/main/java/datadog/trace/api/config/DebuggerConfig.java
@@ -61,6 +61,7 @@ public final class DebuggerConfig {
   public static final String DISTRIBUTED_DEBUGGER_ENABLED = "distributed.debugger.enabled";
   public static final String THIRD_PARTY_INCLUDES = "third.party.includes";
   public static final String THIRD_PARTY_EXCLUDES = "third.party.excludes";
+  public static final String THIRD_PARTY_SHADING_IDENTIFIERS = "third.party.shading.identifiers";
 
   private DebuggerConfig() {}
 }
diff --git a/internal-api/src/main/java/datadog/trace/api/Config.java b/internal-api/src/main/java/datadog/trace/api/Config.java
@@ -430,6 +430,7 @@ public static String getHostName() {
 
   private final Set<String> debuggerThirdPartyIncludes;
   private final Set<String> debuggerThirdPartyExcludes;
+  private final Set<String> debuggerShadingIdentifiers;
 
   private final boolean awsPropagationEnabled;
   private final boolean sqsPropagationEnabled;
@@ -1734,6 +1735,8 @@ PROFILING_DATADOG_PROFILER_ENABLED, isDatadogProfilerSafeInCurrentEnvironment())
 
     debuggerThirdPartyIncludes = tryMakeImmutableSet(configProvider.getList(THIRD_PARTY_INCLUDES));
     debuggerThirdPartyExcludes = tryMakeImmutableSet(configProvider.getList(THIRD_PARTY_EXCLUDES));
+    debuggerShadingIdentifiers =
+        tryMakeImmutableSet(configProvider.getList(THIRD_PARTY_SHADING_IDENTIFIERS));
 
     awsPropagationEnabled = isPropagationEnabled(true, "aws", "aws-sdk");
     sqsPropagationEnabled = isPropagationEnabled(true, "sqs");
@@ -3299,6 +3302,10 @@ public Set<String> getThirdPartyExcludes() {
     return debuggerThirdPartyExcludes;
   }
 
+  public Set<String> getThirdPartyShadingIdentifiers() {
+    return debuggerShadingIdentifiers;
+  }
+
   private String getFinalDebuggerBaseUrl() {
     if (agentUrl.startsWith("unix:")) {
       // provide placeholder agent URL, in practice we'll be tunnelling over UDS

Original file line number	Diff line number	Diff line change
`@@ -982,7 +982,8 @@ private SymbolExtractionTransformer createTransformer(`
`982`	`982`	`return createTransformer(`
`983`	`983`	`symbolSink,`
`984`	`984`	`symbolFlushThreshold,`
`985`		`- new ClassNameFiltering(TRANSFORMER_EXCLUDES, Collections.singleton(SYMBOL_PACKAGE)));`
	`985`	`+ new ClassNameFiltering(`
	`986`	`+ TRANSFORMER_EXCLUDES, Collections.singleton(SYMBOL_PACKAGE), Collections.emptySet()));`
`986`	`987`	`}`
`987`	`988`
`988`	`989`	`private SymbolExtractionTransformer createTransformer(`
Original file line number	Diff line number	Diff line change
`@@ -61,6 +61,7 @@ public final class DebuggerConfig {`
`61`	`61`	`public static final String DISTRIBUTED_DEBUGGER_ENABLED = "distributed.debugger.enabled";`
`62`	`62`	`public static final String THIRD_PARTY_INCLUDES = "third.party.includes";`
`63`	`63`	`public static final String THIRD_PARTY_EXCLUDES = "third.party.excludes";`
	`64`	`+ public static final String THIRD_PARTY_SHADING_IDENTIFIERS = "third.party.shading.identifiers";`
`64`	`65`
`65`	`66`	`private DebuggerConfig() {}`
`66`	`67`	`}`