From 5222899ff5a46a745f392b8281bf04d06f7a2374 Mon Sep 17 00:00:00 2001 From: Radu Ioan Fericean Date: Mon, 18 Jul 2016 22:01:29 +0300 Subject: [PATCH] added event name for published action logs --- engine/action_plan.go | 1 + engine/action_trigger.go | 1 + engine/actions_test.go | 2 ++ 3 files changed, 4 insertions(+) diff --git a/engine/action_plan.go b/engine/action_plan.go index a88bb6500..cf6b82219 100644 --- a/engine/action_plan.go +++ b/engine/action_plan.go @@ -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, diff --git a/engine/action_trigger.go b/engine/action_trigger.go index 409e7d22a..528788f44 100644 --- a/engine/action_trigger.go +++ b/engine/action_trigger.go @@ -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, diff --git a/engine/actions_test.go b/engine/actions_test.go index 157ce5d44..1ddfb7e47 100644 --- a/engine/actions_test.go +++ b/engine/actions_test.go @@ -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,