mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
Adding cgr-console resources related APIs
This commit is contained in:
committed by
Dan Christian Bogos
parent
1e40457f6e
commit
b02e77978c
@@ -58,15 +58,20 @@ func (self *CmdGetAttributeForEvent) RpcParams(reset bool) interface{} {
|
||||
}
|
||||
|
||||
func (self *CmdGetAttributeForEvent) 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
|
||||
}
|
||||
|
||||
83
console/resource_for_event.go
Normal file
83
console/resource_for_event.go
Normal file
@@ -0,0 +1,83 @@
|
||||
/*
|
||||
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
|
||||
Copyright (C) ITsysCOM GmbH
|
||||
|
||||
This program is free software: you can redistribute it and/or modify
|
||||
it under the terms of the GNU General Public License as published by
|
||||
the Free Software Foundation, either version 3 of the License, or
|
||||
(at your option) any later version.
|
||||
|
||||
This program is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
GNU General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with this program. If not, see <http://www.gnu.org/licenses/>
|
||||
*/
|
||||
|
||||
package console
|
||||
|
||||
import (
|
||||
"github.com/cgrates/cgrates/config"
|
||||
"github.com/cgrates/cgrates/engine"
|
||||
"github.com/cgrates/cgrates/utils"
|
||||
)
|
||||
|
||||
func init() {
|
||||
c := &CmdGetResourceForEvent{
|
||||
name: "get_resources_for_event",
|
||||
rpcMethod: "ResourceSv1.GetResourcesForEvent",
|
||||
}
|
||||
commands[c.Name()] = c
|
||||
c.CommandExecuter = &CommandExecuter{c}
|
||||
}
|
||||
|
||||
// Commander implementation
|
||||
type CmdGetResourceForEvent struct {
|
||||
name string
|
||||
rpcMethod string
|
||||
rpcParams interface{}
|
||||
*CommandExecuter
|
||||
}
|
||||
|
||||
func (self *CmdGetResourceForEvent) Name() string {
|
||||
return self.name
|
||||
}
|
||||
|
||||
func (self *CmdGetResourceForEvent) RpcMethod() string {
|
||||
return self.rpcMethod
|
||||
}
|
||||
|
||||
func (self *CmdGetResourceForEvent) RpcParams(reset bool) interface{} {
|
||||
if reset || self.rpcParams == nil {
|
||||
mp := make(map[string]interface{})
|
||||
self.rpcParams = &mp
|
||||
}
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetResourceForEvent) 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
|
||||
}
|
||||
argres := utils.ArgRSv1ResourceUsage{
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: tenant,
|
||||
ID: utils.UUIDSha1Prefix(),
|
||||
Event: *param,
|
||||
},
|
||||
}
|
||||
self.rpcParams = argres
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetResourceForEvent) RpcResult() interface{} {
|
||||
atr := engine.Resources{}
|
||||
return &atr
|
||||
}
|
||||
Reference in New Issue
Block a user