From 9ef9684a3dbeb0d5dc0c033445ae4377121d445a Mon Sep 17 00:00:00 2001
From: ionutboangiu <ionut.boangiu@itsyscom.com>
Date: Mon, 18 Aug 2025 10:20:17 +0300
Subject: [PATCH] agents: add processor/reader id to stats/th events

---
 agents/libagents.go | 11 ++++++-----
 agents/radagent.go  | 11 ++++++-----
 agents/sipagent.go  | 11 ++++++-----
 ers/ers.go          |  1 +
 utils/consts.go     |  2 ++
 5 files changed, 21 insertions(+), 15 deletions(-)

diff --git a/agents/libagents.go b/agents/libagents.go
index 566ae886b..fb753cc7d 100644
--- a/agents/libagents.go
+++ b/agents/libagents.go
@@ -262,11 +262,12 @@ func processRequest(ctx *context.Context, reqProcessor *config.RequestProcessor,
 		ID:     utils.GenUUID(),
 		Time:   utils.TimePointer(time.Now()),
 		Event: map[string]any{
-			utils.ReplyState:     replyState,
-			utils.StartTime:      startTime,
-			utils.EndTime:        endTime,
-			utils.ProcessingTime: endTime.Sub(startTime),
-			utils.Source:         agentName,
+			utils.ReplyState:         replyState,
+			utils.StartTime:          startTime,
+			utils.EndTime:            endTime,
+			utils.ProcessingTime:     endTime.Sub(startTime),
+			utils.Source:             agentName,
+			utils.RequestProcessorID: reqProcessor.ID,
 		},
 		APIOpts: map[string]any{
 			utils.MetaEventType: utils.ProcessTime,
diff --git a/agents/radagent.go b/agents/radagent.go
index 527ca1178..03f20aa86 100644
--- a/agents/radagent.go
+++ b/agents/radagent.go
@@ -531,11 +531,12 @@ func (ra *RadiusAgent) processRequest(req *radigo.Packet, reqProcessor *config.R
 		ID:     utils.GenUUID(),
 		Time:   utils.TimePointer(time.Now()),
 		Event: map[string]any{
-			utils.ReplyState:     replyState,
-			utils.StartTime:      startTime,
-			utils.EndTime:        endTime,
-			utils.ProcessingTime: endTime.Sub(startTime),
-			utils.Source:         utils.RadiusAgent,
+			utils.ReplyState:         replyState,
+			utils.StartTime:          startTime,
+			utils.EndTime:            endTime,
+			utils.ProcessingTime:     endTime.Sub(startTime),
+			utils.Source:             utils.RadiusAgent,
+			utils.RequestProcessorID: reqProcessor.ID,
 		},
 		APIOpts: map[string]any{
 			utils.MetaEventType: utils.ProcessTime,
diff --git a/agents/sipagent.go b/agents/sipagent.go
index 36d7bce60..db3dabcab 100644
--- a/agents/sipagent.go
+++ b/agents/sipagent.go
@@ -498,11 +498,12 @@ func (sa *SIPAgent) processRequest(reqProcessor *config.RequestProcessor,
 		ID:     utils.GenUUID(),
 		Time:   utils.TimePointer(time.Now()),
 		Event: map[string]any{
-			utils.ReplyState:     replyState,
-			utils.StartTime:      startTime,
-			utils.EndTime:        endTime,
-			utils.ProcessingTime: endTime.Sub(startTime),
-			utils.Source:         utils.SIPAgent,
+			utils.ReplyState:         replyState,
+			utils.StartTime:          startTime,
+			utils.EndTime:            endTime,
+			utils.ProcessingTime:     endTime.Sub(startTime),
+			utils.Source:             utils.SIPAgent,
+			utils.RequestProcessorID: reqProcessor.ID,
 		},
 		APIOpts: map[string]any{
 			utils.MetaEventType: utils.ProcessTime,
diff --git a/ers/ers.go b/ers/ers.go
index bbec14671..2c52a5e49 100644
--- a/ers/ers.go
+++ b/ers/ers.go
@@ -260,6 +260,7 @@ func (erS *ERService) processEvent(cgrEv *utils.CGREvent,
 				utils.EndTime:        endTime,
 				utils.ProcessingTime: endTime.Sub(startTime),
 				utils.Source:         utils.ERs,
+				utils.EventReaderID:  rdrCfg.ID,
 			},
 			APIOpts: map[string]any{
 				utils.MetaEventType: utils.ProcessTime,
diff --git a/utils/consts.go b/utils/consts.go
index de640cc29..079387659 100644
--- a/utils/consts.go
+++ b/utils/consts.go
@@ -616,6 +616,8 @@ const (
 	Categories           = "Categories"
 	Blocker              = "Blocker"
 	RatingPlanID         = "RatingPlanID"
+	RequestProcessorID   = "RequestProcessorID"
+	EventReaderID        = "EventReaderID"
 	StartTime            = "StartTime"
 	EndTime              = "EndTime"
 	ProcessingTime       = "ProcessingTime"