From 5327b19e042139ea26eccd82c0607fcd764ed363 Mon Sep 17 00:00:00 2001
From: Maksym Sadovnychyy <maksym.sadovnychyy@gmail.com>
Date: Sun, 25 May 2025 20:29:49 +0200
Subject: [PATCH] (feature): add traceI id if available

---
 src/MaksIT.Dapr/DaprService.cs     | 12 +++++++++++-
 src/MaksIT.Dapr/MaksIT.Dapr.csproj |  2 +-
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/src/MaksIT.Dapr/DaprService.cs b/src/MaksIT.Dapr/DaprService.cs
index 67be652..6dd6242 100644
--- a/src/MaksIT.Dapr/DaprService.cs
+++ b/src/MaksIT.Dapr/DaprService.cs
@@ -39,7 +39,17 @@ public class DaprService : IDaprPublisherService, IDaprStateStoreService {
   /// <returns></returns>
   public async Task<Result> PublishEventAsync(string pubSubName, string topicName, string payload) {
     try {
-      await _client.PublishEventAsync(pubSubName, topicName, payload);
+
+      var traceId = System.Diagnostics.Activity.Current?.TraceId.ToString();
+
+      if (!string.IsNullOrEmpty(traceId)) {
+        var metadata = new Dictionary<string, string> { ["traceid"] = traceId };
+        await _client.PublishEventAsync(pubSubName, topicName, payload, metadata);
+      }
+      else {
+        await _client.PublishEventAsync(pubSubName, topicName, payload);
+      }
+
       return Result.Ok();
     }
     catch (Exception ex) {
diff --git a/src/MaksIT.Dapr/MaksIT.Dapr.csproj b/src/MaksIT.Dapr/MaksIT.Dapr.csproj
index 6fa6d68..3c87dcc 100644
--- a/src/MaksIT.Dapr/MaksIT.Dapr.csproj
+++ b/src/MaksIT.Dapr/MaksIT.Dapr.csproj
@@ -7,7 +7,7 @@
 
     <!-- NuGet package metadata -->
     <PackageId>MaksIT.Dapr</PackageId>
-    <Version>1.0.6</Version>
+    <Version>1.0.7</Version>
     <Authors>Maksym Sadovnychyy</Authors>
     <Company>MAKS-IT</Company>
     <Product>MaksIT.Dapr</Product>