mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
added event name for published action logs
This commit is contained in:
@@ -361,6 +361,7 @@ func (at *ActionTiming) Execute() (err error) {
|
||||
return err
|
||||
}
|
||||
Publish(CgrEvent{
|
||||
"EventName": utils.EVT_ACTION_TIMING_FIRED,
|
||||
"Uuid": at.Uuid,
|
||||
"Id": at.actionPlanID,
|
||||
"ActionIds": at.ActionsID,
|
||||
|
||||
@@ -108,6 +108,7 @@ func (at *ActionTrigger) Execute(ub *Account, sq *StatsQueueTriggered) (err erro
|
||||
}
|
||||
if !transactionFailed && ub != nil && !removeAccountActionFound {
|
||||
Publish(CgrEvent{
|
||||
"EventName": utils.EVT_ACTION_TRIGGER_FIRED,
|
||||
"Uuid": at.UniqueID,
|
||||
"Id": at.ID,
|
||||
"ActionIds": at.ActionsID,
|
||||
|
||||
@@ -1060,6 +1060,7 @@ func TestActionTriggerLogging(t *testing.T) {
|
||||
t.Error("Error getting actions for the action timing: ", as, err)
|
||||
}
|
||||
Publish(CgrEvent{
|
||||
"EventName": utils.EVT_ACTION_TRIGGER_FIRED,
|
||||
"Uuid": at.UniqueID,
|
||||
"Id": at.ID,
|
||||
"ActionIds": at.ActionsID,
|
||||
@@ -1105,6 +1106,7 @@ func TestActionPlanLogging(t *testing.T) {
|
||||
t.Error("Error getting actions for the action trigger: ", err)
|
||||
}
|
||||
Publish(CgrEvent{
|
||||
"EventName": utils.EVT_ACTION_TIMING_FIRED,
|
||||
"Uuid": at.Uuid,
|
||||
"Id": at.actionPlanID,
|
||||
"ActionIds": at.ActionsID,
|
||||
|
||||
Reference in New Issue
Block a user