uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Fixed failing api call

Browse Source
This commit is contained in:
edwardro22
2017-12-18 13:00:09 +02:00
committed by Dan Christian Bogos
parent 5a8430aabc
commit 1e40457f6e
5 changed files with 39 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
console/atributes_process_event.go
View File

@@ -58,14 +58,25 @@ func (self *CmdAttributesProcessEvent) RpcParams(reset bool) interface{} {
}
func (self *CmdAttributesProcessEvent) PostprocessRpcParams() error { //utils.CGREvent
var tenant, context string
param := self.rpcParams.(*map[string]interface{})
if (*param)[utils.Tenant] != nil && (*param)[utils.Tenant].(string) != "" {
tenant = (*param)[utils.Tenant].(string)
delete((*param), utils.Tenant)
} else {
tenant = config.CgrConfig().DefaultTenant
}
if (*param)[utils.Context] != nil && (*param)[utils.Context].(string) != "" {
context = (*param)[utils.Context].(string)
delete((*param), utils.Context)
}
cgrev := utils.CGREvent{
Tenant: config.CgrConfig().DefaultTenant,
Tenant: tenant,
ID: utils.UUIDSha1Prefix(),
Event: *param,
}
if (*param)[utils.Tenant] != nil && (*param)[utils.Tenant].(string) != "" {
cgrev.Tenant = (*param)[utils.Tenant].(string)
if context != "" {
cgrev.Context = &context
}
self.rpcParams = cgrev
return nil

12
console/statqueue_for_event.go
View File

@@ -58,15 +58,19 @@ func (self *CmdStatsQueueProcessEvent) RpcParams(reset bool) interface{} {
}
func (self *CmdStatsQueueProcessEvent) PostprocessRpcParams() error { //utils.CGREvent
var tenant string
param := self.rpcParams.(*map[string]interface{})
if (*param)[utils.Tenant] != nil && (*param)[utils.Tenant].(string) != "" {
tenant = (*param)[utils.Tenant].(string)
delete((*param), utils.Tenant)
} else {
tenant = config.CgrConfig().DefaultTenant
}
cgrev := utils.CGREvent{
Tenant: config.CgrConfig().DefaultTenant,
Tenant: tenant,
ID: utils.UUIDSha1Prefix(),
Event: *param,
}
if (*param)[utils.Tenant] != nil && (*param)[utils.Tenant].(string) != "" {
cgrev.Tenant = (*param)[utils.Tenant].(string)
}
self.rpcParams = cgrev
return nil
}

12
console/statqueue_process_event.go
View File

@@ -57,15 +57,19 @@ func (self *CmdStatQueueProcessEvent) RpcParams(reset bool) interface{} {
}
func (self *CmdStatQueueProcessEvent) PostprocessRpcParams() error { //utils.CGREvent
var tenant string
param := self.rpcParams.(*map[string]interface{})
if (*param)[utils.Tenant] != nil && (*param)[utils.Tenant].(string) != "" {
tenant = (*param)[utils.Tenant].(string)
delete((*param), utils.Tenant)
} else {
tenant = config.CgrConfig().DefaultTenant
}
cgrev := utils.CGREvent{
Tenant: config.CgrConfig().DefaultTenant,
Tenant: tenant,
ID: utils.UUIDSha1Prefix(),
Event: *param,
}
if (*param)[utils.Tenant] != nil && (*param)[utils.Tenant].(string) != "" {
cgrev.Tenant = (*param)[utils.Tenant].(string)
}
self.rpcParams = cgrev
return nil
}

12
console/threshold_process_event.go
View File

@@ -57,15 +57,19 @@ func (self *CmdThresholdProcessEvent) RpcParams(reset bool) interface{} {
}
func (self *CmdThresholdProcessEvent) PostprocessRpcParams() error { //utils.CGREvent
var tenant string
param := self.rpcParams.(*map[string]interface{})
if (*param)[utils.Tenant] != nil && (*param)[utils.Tenant].(string) != "" {
tenant = (*param)[utils.Tenant].(string)
delete((*param), utils.Tenant)
} else {
tenant = config.CgrConfig().DefaultTenant
}
cgrev := utils.CGREvent{
Tenant: config.CgrConfig().DefaultTenant,
Tenant: tenant,
ID: utils.UUIDSha1Prefix(),
Event: *param,
}
if (*param)[utils.Tenant] != nil && (*param)[utils.Tenant].(string) != "" {
cgrev.Tenant = (*param)[utils.Tenant].(string)
}
self.rpcParams = cgrev
return nil
}

1
utils/consts.go
View File

@@ -129,6 +129,7 @@ const (
DIRECTION = "Direction"
Tenant = "Tenant"
Category = "Category"
Context = "Context"
Account = "Account"
SUBJECT = "Subject"
Destination = "Destination"