From 8f8b821f176d7cde33336ed27c802efe4bdc74af Mon Sep 17 00:00:00 2001 From: Anevo Date: Mon, 12 Mar 2018 08:29:47 -0400 Subject: [PATCH] Added time.Now() as CGREvent time for all console commands using it --- console/atributes_process_event.go | 5 +++++ console/resources_for_event.go | 5 +++++ console/stats_process_event.go | 5 +++++ console/thresholds_process_event.go | 8 +++++++- 4 files changed, 22 insertions(+), 1 deletion(-) diff --git a/console/atributes_process_event.go b/console/atributes_process_event.go index 912f43498..f9d675760 100644 --- a/console/atributes_process_event.go +++ b/console/atributes_process_event.go @@ -19,6 +19,8 @@ along with this program. If not, see package console import ( + "time" + "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" ) @@ -56,6 +58,9 @@ func (self *CmdAttributesProcessEvent) RpcParams(reset bool) interface{} { } func (self *CmdAttributesProcessEvent) PostprocessRpcParams() error { //utils.CGREvent + if self.rpcParams.Time == nil { + self.rpcParams.Time = utils.TimePointer(time.Now()) + } return nil } diff --git a/console/resources_for_event.go b/console/resources_for_event.go index adf0e8d03..7802086a3 100644 --- a/console/resources_for_event.go +++ b/console/resources_for_event.go @@ -19,6 +19,8 @@ along with this program. If not, see package console import ( + "time" + "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" ) @@ -57,6 +59,9 @@ func (self *CmdGetResourceForEvent) RpcParams(reset bool) interface{} { } func (self *CmdGetResourceForEvent) PostprocessRpcParams() error { + if self.rpcParams.CGREvent.Time == nil { + self.rpcParams.CGREvent.Time = utils.TimePointer(time.Now()) + } return nil } diff --git a/console/stats_process_event.go b/console/stats_process_event.go index b828c2e48..9c5c7c9ec 100644 --- a/console/stats_process_event.go +++ b/console/stats_process_event.go @@ -19,6 +19,8 @@ along with this program. If not, see package console import ( + "time" + "github.com/cgrates/cgrates/utils" ) @@ -56,6 +58,9 @@ func (self *CmdStatQueueProcessEvent) RpcParams(reset bool) interface{} { } func (self *CmdStatQueueProcessEvent) PostprocessRpcParams() error { + if self.rpcParams.Time == nil { + self.rpcParams.Time = utils.TimePointer(time.Now()) + } return nil } diff --git a/console/thresholds_process_event.go b/console/thresholds_process_event.go index a50d7bd0e..4c7e7269f 100644 --- a/console/thresholds_process_event.go +++ b/console/thresholds_process_event.go @@ -19,14 +19,17 @@ along with this program. If not, see package console import ( + "time" + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" ) func init() { c := &CmdThresholdProcessEvent{ name: "thresholds_process_event", rpcMethod: "ThresholdSv1.ProcessEvent", - rpcParams: &engine.ArgsProcessEvent{}, + rpcParams: new(engine.ArgsProcessEvent), } commands[c.Name()] = c c.CommandExecuter = &CommandExecuter{c} @@ -55,6 +58,9 @@ func (self *CmdThresholdProcessEvent) RpcParams(reset bool) interface{} { } func (self *CmdThresholdProcessEvent) PostprocessRpcParams() error { + if self.rpcParams.Time == nil { + self.rpcParams.Time = utils.TimePointer(time.Now()) + } return nil }