Merge pull request #94 from rakista112/develop

Attach TransactionID in Net Core logs

Author: kbond-stackify

Src/StackifyLib/Internal/Logs/LogQueue.cs

@@ -3,7 +3,10 @@
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
+using System.Diagnostics;
 using System.Linq;
+using System.Reflection;
+using System.Threading;
 using System.Threading.Tasks;
 
 #if NETFULL
@@ -99,6 +102,7 @@ public void QueueLogMessage(Models.LogMsg msg)
                     // ignore
                 }
 
+       
 #if NETFULL
                 try
                 {
@@ -177,6 +181,34 @@ public void QueueLogMessage(Models.LogMsg msg)
                         }
                     }
                 }
+#else
+                // else if .Net Core
+                // get RequestID
+                if (string.IsNullOrEmpty(msg.TransID))
+                {
+                    var assemblies = AppDomain.CurrentDomain.GetAssemblies();
+
+                    var agentAssemblyQry = assemblies.Where(assembly => assembly.FullName.Contains("Stackify.Agent"));
+                    if(agentAssemblyQry.Count() > 0)
+                    {
+                        var middleware = agentAssemblyQry.First();
+                        var callContextType = middleware.GetType("Stackify.Agent.Threading.StackifyCallContext");
+                        if (callContextType != null)
+                        {
+                            var traceCtxType = middleware.GetType("Stackify.Agent.Tracing.ITraceContext");
+                            if(traceCtxType != null)
+                            {
+                                var traceContextProp = callContextType.GetProperty("TraceContext")?.GetValue(null);
+                                if (traceContextProp != null)
+                                {
+                                    var reqIdProp = traceCtxType.GetProperty("RequestId")?.GetValue(traceContextProp)?.ToString();
+                                    if(!string.IsNullOrEmpty(reqIdProp))
+                                        msg.TransID = reqIdProp;
+                                }
+                            }
+                        }
+                    }
+                }
 #endif
 
                 _MessageBuffer.Enqueue(msg);