diff --git a/console/threshold.go b/console/threshold.go index 72ec1432d..3fd6c99f5 100644 --- a/console/threshold.go +++ b/console/threshold.go @@ -26,7 +26,7 @@ import ( func init() { c := &CmdGetThreshold{ name: "threshold", - rpcMethod: utils.ApierV1GetThresholdProfile, + rpcMethod: utils.ThresholdSv1GetThreshold, rpcParams: &utils.TenantIDWithArgDispatcher{}, } commands[c.Name()] = c @@ -63,6 +63,6 @@ func (self *CmdGetThreshold) PostprocessRpcParams() error { } func (self *CmdGetThreshold) RpcResult() interface{} { - atr := engine.ThresholdProfile{} + atr := engine.Threshold{} return &atr } diff --git a/console/threshold_profile.go b/console/threshold_profile.go new file mode 100644 index 000000000..cae95e017 --- /dev/null +++ b/console/threshold_profile.go @@ -0,0 +1,68 @@ +/* +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 +*/ + +package console + +import ( + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" +) + +func init() { + c := &CmdGetThresholdProfile{ + name: "threshold_profile", + rpcMethod: utils.ApierV1GetThresholdProfile, + rpcParams: &utils.TenantIDWithArgDispatcher{}, + } + commands[c.Name()] = c + c.CommandExecuter = &CommandExecuter{c} +} + +type CmdGetThresholdProfile struct { + name string + rpcMethod string + rpcParams *utils.TenantIDWithArgDispatcher + *CommandExecuter +} + +func (self *CmdGetThresholdProfile) Name() string { + return self.name +} + +func (self *CmdGetThresholdProfile) RpcMethod() string { + return self.rpcMethod +} + +func (self *CmdGetThresholdProfile) RpcParams(reset bool) interface{} { + if reset || self.rpcParams == nil { + self.rpcParams = &utils.TenantIDWithArgDispatcher{ + TenantID: new(utils.TenantID), + ArgDispatcher: new(utils.ArgDispatcher), + } + } + return self.rpcParams +} + +func (self *CmdGetThresholdProfile) PostprocessRpcParams() error { + return nil +} + +func (self *CmdGetThresholdProfile) RpcResult() interface{} { + atr := engine.ThresholdProfile{} + return &atr +}