feat: add additional event handlers

docker-compose.yml

@@ -379,11 +379,14 @@ services:
         condition: service_healthy
     environment:
       # DataDog APM configuration
+      DD_API_KEY: ${DD_API_KEY}
+      DD_SITE: ${DD_SITE:-datadoghq.com}
       DD_SERVICE: print-service
       DD_ENV: ${ENV:-development}
       DD_VERSION: ${COMMIT_SHA:-latest}
       DD_AGENT_HOST: datadog-agent
       DD_DATA_STREAMS_ENABLED: "true"
+      DD_TRACE_REMOVE_INTEGRATION_SERVICE_NAMES_ENABLED: "true"
       DD_TRACE_OTEL_ENABLED: "true"
       DD_LOGS_INJECTION: "true"
       DD_RUNTIME_METRICS_ENABLED: "true"
@@ -433,11 +436,14 @@ services:
         condition: service_healthy
     environment:
       # DataDog APM configuration
+      DD_API_KEY: ${DD_API_KEY}
+      DD_SITE: ${DD_SITE:-datadoghq.com}
       DD_SERVICE: print-service
       DD_ENV: ${ENV:-development}
       DD_VERSION: ${COMMIT_SHA:-latest}
       DD_AGENT_HOST: datadog-agent
       DD_DATA_STREAMS_ENABLED: "true"
+      DD_TRACE_REMOVE_INTEGRATION_SERVICE_NAMES_ENABLED: "true"
       DD_TRACE_OTEL_ENABLED: "true"
       DD_LOGS_INJECTION: "true"
       DD_RUNTIME_METRICS_ENABLED: "true"
@@ -474,11 +480,14 @@ services:
       - "8086:8080"
     environment:
       # DataDog APM configuration
+      DD_API_KEY: ${DD_API_KEY}
+      DD_SITE: ${DD_SITE:-datadoghq.com}
       DD_SERVICE: print-service-client
       DD_ENV: ${ENV:-development}
       DD_VERSION: ${COMMIT_SHA:-latest}
       DD_AGENT_HOST: datadog-agent
       DD_DATA_STREAMS_ENABLED: "true"
+      DD_TRACE_REMOVE_INTEGRATION_SERVICE_NAMES_ENABLED: "true"
       DD_TRACE_OTEL_ENABLED: "true"
       DD_LOGS_INJECTION: "true"
       DD_RUNTIME_METRICS_ENABLED: "true"
@@ -538,7 +547,8 @@ services:
       DD_ENV: ${ENV:-development}
       DD_VERSION: ${COMMIT_SHA:-latest}
       DD_AGENT_HOST: datadog-agent
-      DD_DATA_STREAMS_ENABLED: true
+      DD_DATA_STREAMS_ENABLED: "true"
+      DD_TRACE_REMOVE_INTEGRATION_SERVICE_NAMES_ENABLED: "true"
       DD_TRACE_OTEL_ENABLED: "true"
       DD_LOGS_INJECTION: "true"
       DD_RUNTIME_METRICS_ENABLED: "true"
@@ -592,7 +602,8 @@ services:
       DD_ENV: ${ENV:-development}
       DD_VERSION: ${COMMIT_SHA:-latest}
       DD_AGENT_HOST: datadog-agent
-      DD_DATA_STREAMS_ENABLED: true
+      DD_DATA_STREAMS_ENABLED: "true"
+      DD_TRACE_REMOVE_INTEGRATION_SERVICE_NAMES_ENABLED: "true"
       DD_TRACE_OTEL_ENABLED: "true"
       DD_LOGS_INJECTION: "true"
       DD_RUNTIME_METRICS_ENABLED: "true"
@@ -716,7 +727,8 @@ services:
       DD_ENV: ${ENV:-development}
       DD_VERSION: ${COMMIT_SHA:-latest}
       DD_AGENT_HOST: datadog-agent
-      DD_DATA_STREAMS_ENABLED: true
+      DD_DATA_STREAMS_ENABLED: "true"
+      DD_TRACE_REMOVE_INTEGRATION_SERVICE_NAMES_ENABLED: "true"
       # Server configuration
       SERVER_PORT: 8080
 
@@ -768,6 +780,7 @@ services:
   # Load testing service - runs k6 load tests against the stack
   load-simulator:
     image: grafana/k6:latest
+    restart: always
     volumes:
       - ./load-tests:/scripts
     environment:

print-service/src/Stickerlandia.PrintService.AWS/EventBridgeEventPublisher.cs

@@ -9,10 +9,12 @@
 // Copyright 2025 Datadog, Inc.
 
 using System.Diagnostics;
+using System.Text.Json.Nodes;
 using Amazon.EventBridge;
 using Amazon.EventBridge.Model;
 using CloudNative.CloudEvents;
 using CloudNative.CloudEvents.SystemTextJson;
+using Datadog.Trace;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
 using Saunter.Attributes;
@@ -139,14 +141,26 @@ internal async Task PublishCloudEventAsync(CloudEvent cloudEvent)
             var data = formatter.EncodeStructuredModeMessage(cloudEvent, out _);
             var jsonString = System.Text.Encoding.UTF8.GetString(data.Span);
 
+            if (Tracer.Instance.ActiveScope is not null)
+            {
+                var jsonNode = JsonNode.Parse(jsonString)!;
+                new SpanContextInjector().InjectIncludingDsm(jsonNode, SetHeader, Tracer.Instance.ActiveScope.Span.Context, "eventbridge", cloudEvent.Type!);
+                jsonString = jsonNode.ToJsonString();
+            }
+            else
+            {
+                Log.GenericWarning(logger, "Failure publishing event", null);
+                activity?.SetTag("dsm.injection_skipped", "no active scope");
+            }
+
             var response = await client.PutEventsAsync(new PutEventsRequest()
             {
                 Entries = new List<PutEventsRequestEntry>(1)
                 {
                     new()
                     {
                         EventBusName = awsConfiguration.Value.EventBusName,
-                        Source = $"{Environment.GetEnvironmentVariable("ENV") ?? "dev"}.users",
+                        Source = $"{Environment.GetEnvironmentVariable("ENV") ?? "dev"}.print",
                         DetailType = cloudEvent.Type,
                         Detail = jsonString,
                     }
@@ -171,4 +185,11 @@ internal async Task PublishCloudEventAsync(CloudEvent cloudEvent)
             throw;
         }
     }
+
+    private static void SetHeader(JsonNode jsonNode, string key, string value)
+    {
+        if (jsonNode["_datadog"] == null) jsonNode["_datadog"] = new JsonObject();
+
+        jsonNode["_datadog"]![key] = value;
+    }
 }

print-service/src/Stickerlandia.PrintService.AWS/ServiceExtensions.cs

@@ -16,6 +16,7 @@
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Stickerlandia.PrintService.Core;
+using Stickerlandia.PrintService.Core.Observability;
 using Stickerlandia.PrintService.Core.Outbox;
 using Stickerlandia.PrintService.Core.PrintJobs;
 
@@ -61,6 +62,9 @@ public static IServiceCollection AddAwsAdapters(this IServiceCollection services
 
         services.AddSingleton<IPrintServiceEventPublisher, EventBridgeEventPublisher>();
 
+        services.AddHttpClient();
+        services.AddSingleton<DatadogTransactionTracker>();
+
         return services;
     }
 }

print-service/src/Stickerlandia.PrintService.Agnostic/KafkaEventPublisher.cs

@@ -17,7 +17,7 @@
 
 namespace Stickerlandia.PrintService.Agnostic;
 
-public class KafkaEventPublisher(ProducerConfig config, ILogger<KafkaEventPublisher> logger) : IPrintServiceEventPublisher
+public class KafkaEventPublisher(ProducerConfig config, ILogger<KafkaEventPublisher> logger, DatadogTransactionTracker transactionTracker) : IPrintServiceEventPublisher
 {
     [Channel("printJobs.queued.v1")]
     [PublishOperation(typeof(PrintJobQueuedEvent))]
@@ -34,7 +34,8 @@ public async Task PublishPrintJobQueuedEvent(PrintJobQueuedEvent printJobQueuedE
             Data = printJobQueuedEvent
         };
 
-        await Publish<PrinterRegisteredEvent>(cloudEvent);
+        await Publish<PrintJobQueuedEvent>(cloudEvent);
+        await transactionTracker.TrackTransactionAsync(printJobQueuedEvent.PrintJobId, "print-job-queued");
     }
 
     [Channel("printJobs.failed.v1")]
@@ -52,7 +53,7 @@ public async Task PublishPrintJobFailedEvent(PrintJobFailedEvent printJobFailedE
             Data = printJobFailedEvent
         };
 
-        await Publish<PrinterRegisteredEvent>(cloudEvent);
+        await Publish<PrintJobFailedEvent>(cloudEvent);
     }
 
     [Channel("print.printerRegistered.v1")]

print-service/src/Stickerlandia.PrintService.Agnostic/ServiceExtensions.cs

@@ -11,6 +11,7 @@
 using Stickerlandia.PrintService.Agnostic.Data;
 using Stickerlandia.PrintService.Agnostic.Repositories;
 using Stickerlandia.PrintService.Core;
+using Stickerlandia.PrintService.Core.Observability;
 using Stickerlandia.PrintService.Core.Outbox;
 using Stickerlandia.PrintService.Core.PrintJobs;
 
@@ -122,6 +123,9 @@ public static IServiceCollection AddKafkaMessaging(this IServiceCollection servi
         services.AddSingleton(producerConfig);
         services.AddSingleton(consumerConfig);
 
+        services.AddHttpClient();
+        services.AddSingleton<DatadogTransactionTracker>();
+
         // Register event publisher as singleton
         services.AddSingleton<IPrintServiceEventPublisher, KafkaEventPublisher>();
 

print-service/src/Stickerlandia.PrintService.Api/Configurations/AuthenticationExtensions.cs

@@ -10,7 +10,7 @@
 using Microsoft.IdentityModel.Protocols.OpenIdConnect;
 using Microsoft.IdentityModel.Tokens;
 
-#pragma warning disable CA5400
+#pragma warning disable CA5400, CA2000
 
 namespace Stickerlandia.PrintService.Api.Configurations;
 

print-service/src/Stickerlandia.PrintService.Client/Program.cs

@@ -77,6 +77,7 @@
 builder.Services.AddRazorComponents()
     .AddInteractiveServerComponents();
 
+builder.Services.AddSingleton<DatadogTransactionTracker>();
 // Add configuration service (singleton - shared across app)
 builder.Services.AddSingleton<IConfigurationService, ConfigurationService>();