Fix Antithesis SDK compatibility: Use Jackson ObjectNode instead of Map

The Antithesis SDK expects Jackson ObjectNode, not Map.
Replaced HashMap with ObjectNode using JsonNodeFactory.

Fixed in:
- CoreTracer.java
- RemoteWriter.java
- PayloadDispatcherImpl.java

Author: robertomonteromiguel

dd-trace-core/src/main/java/datadog/trace/common/writer/PayloadDispatcherImpl.java

@@ -1,6 +1,8 @@
 package datadog.trace.common.writer;
 
 import com.antithesis.sdk.Assert;
+import com.fasterxml.jackson.databind.node.JsonNodeFactory;
+import com.fasterxml.jackson.databind.node.ObjectNode;
 import datadog.communication.monitor.Monitoring;
 import datadog.communication.monitor.Recording;
 import datadog.communication.serialization.ByteBufferConsumer;
@@ -110,7 +112,7 @@ public void accept(int messageCount, ByteBuffer buffer) {
       healthMetrics.onSerialize(sizeInBytes);
 
       // Antithesis: Track all send attempts
-      java.util.Map<String, Object> sendAttemptDetails = new java.util.HashMap<>();
+      ObjectNode sendAttemptDetails = JsonNodeFactory.instance.objectNode();
       sendAttemptDetails.put("trace_count", messageCount);
       sendAttemptDetails.put("payload_size_bytes", sizeInBytes);
       sendAttemptDetails.put("dropped_traces_in_payload", payload.droppedTraces());
@@ -122,7 +124,7 @@ public void accept(int messageCount, ByteBuffer buffer) {
 
       if (response.success()) {
         // Antithesis: Track successful sends
-        java.util.Map<String, Object> successDetails = new java.util.HashMap<>();
+        ObjectNode successDetails = JsonNodeFactory.instance.objectNode();
         successDetails.put("decision", "sent_success");
         successDetails.put("trace_count", messageCount);
         successDetails.put("payload_size_bytes", sizeInBytes);
@@ -134,7 +136,7 @@ public void accept(int messageCount, ByteBuffer buffer) {
         healthMetrics.onSend(messageCount, sizeInBytes, response);
       } else {
         // Antithesis: Track failed sends
-        java.util.Map<String, Object> failedDetails = new java.util.HashMap<>();
+        ObjectNode failedDetails = JsonNodeFactory.instance.objectNode();
         failedDetails.put("decision", "dropped_send_failed");
         failedDetails.put("trace_count", messageCount);
         failedDetails.put("payload_size_bytes", sizeInBytes);

dd-trace-core/src/main/java/datadog/trace/common/writer/RemoteWriter.java

@@ -4,6 +4,8 @@
 import static java.util.concurrent.TimeUnit.MINUTES;
 
 import com.antithesis.sdk.Assert;
+import com.fasterxml.jackson.databind.node.JsonNodeFactory;
+import com.fasterxml.jackson.databind.node.ObjectNode;
 import datadog.trace.core.DDSpan;
 import datadog.trace.core.monitor.HealthMetrics;
 import datadog.trace.relocate.api.RatelimitedLogger;
@@ -70,7 +72,7 @@ protected RemoteWriter(
   public void write(final List<DDSpan> trace) {
     if (closed) {
       // Antithesis: Track traces dropped during shutdown
-      java.util.Map<String, Object> shutdownDetails = new java.util.HashMap<>();
+      ObjectNode shutdownDetails = JsonNodeFactory.instance.objectNode();
       shutdownDetails.put("decision", "dropped_shutdown");
       shutdownDetails.put("span_count", trace.size());
       Assert.sometimes(true, "trace_dropped_writer_closed", shutdownDetails);
@@ -87,7 +89,7 @@ public void write(final List<DDSpan> trace) {
         switch (traceProcessingWorker.publish(root, samplingPriority, trace)) {
           case ENQUEUED_FOR_SERIALIZATION:
             // Antithesis: Track traces enqueued for sending
-            java.util.Map<String, Object> enqueuedDetails = new java.util.HashMap<>();
+            ObjectNode enqueuedDetails = JsonNodeFactory.instance.objectNode();
             enqueuedDetails.put("decision", "enqueued");
             enqueuedDetails.put("trace_id", root.getTraceId().toString());
             enqueuedDetails.put("span_count", trace.size());
@@ -101,7 +103,7 @@ public void write(final List<DDSpan> trace) {
             break;
           case DROPPED_BY_POLICY:
             // Antithesis: Track traces dropped by policy
-            java.util.Map<String, Object> policyDetails = new java.util.HashMap<>();
+            ObjectNode policyDetails = JsonNodeFactory.instance.objectNode();
             policyDetails.put("decision", "dropped_policy");
             policyDetails.put("trace_id", root.getTraceId().toString());
             policyDetails.put("span_count", trace.size());
@@ -112,7 +114,7 @@ public void write(final List<DDSpan> trace) {
             break;
           case DROPPED_BUFFER_OVERFLOW:
             // Antithesis: Track traces dropped due to buffer overflow
-            java.util.Map<String, Object> overflowDetails = new java.util.HashMap<>();
+            ObjectNode overflowDetails = JsonNodeFactory.instance.objectNode();
             overflowDetails.put("decision", "dropped_buffer_overflow");
             overflowDetails.put("trace_id", root.getTraceId().toString());
             overflowDetails.put("span_count", trace.size());

dd-trace-core/src/main/java/datadog/trace/core/CoreTracer.java

@@ -20,6 +20,8 @@
 import static java.util.concurrent.TimeUnit.SECONDS;
 
 import com.antithesis.sdk.Assert;
+import com.fasterxml.jackson.databind.node.JsonNodeFactory;
+import com.fasterxml.jackson.databind.node.ObjectNode;
 
 import datadog.communication.ddagent.DDAgentFeaturesDiscovery;
 import datadog.communication.ddagent.ExternalAgentLauncher;
@@ -1249,7 +1251,7 @@ void write(final List<DDSpan> trace) {
     boolean published = forceKeep || traceCollector.sample(spanToSample);
     if (published) {
       // Antithesis: Track traces accepted by sampling
-      java.util.Map<String, Object> acceptedDetails = new java.util.HashMap<>();
+      ObjectNode acceptedDetails = JsonNodeFactory.instance.objectNode();
       acceptedDetails.put("decision", "accepted");
       acceptedDetails.put("trace_id", writtenTrace.get(0).getTraceId().toString());
       acceptedDetails.put("span_count", writtenTrace.size());
@@ -1258,7 +1260,7 @@ void write(final List<DDSpan> trace) {
       writer.write(writtenTrace);
     } else {
       // Antithesis: Track traces dropped by sampling
-      java.util.Map<String, Object> droppedDetails = new java.util.HashMap<>();
+      ObjectNode droppedDetails = JsonNodeFactory.instance.objectNode();
       droppedDetails.put("decision", "dropped_sampling");
       droppedDetails.put("trace_id", writtenTrace.get(0).getTraceId().toString());
       droppedDetails.put("span_count", writtenTrace.size());