mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-17 14:19:54 +05:00
Adding console PostprocessRpcParams method
This commit is contained in:
@@ -56,6 +56,10 @@ func (self *CmdGetAccount) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetAccount) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetAccount) RpcResult() interface{} {
|
||||
return &engine.Account{}
|
||||
}
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdAddAccount) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdAddAccount) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdAddAccount) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdSetAccountActions) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdSetAccountActions) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdSetAccountActions) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -53,6 +53,10 @@ func (self *CmdExecuteAction) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdExecuteAction) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdExecuteAction) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -55,6 +55,10 @@ func (self *CmdDebitBalance) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdDebitBalance) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdDebitBalance) RpcResult() interface{} {
|
||||
return &engine.CallCost{}
|
||||
}
|
||||
|
||||
@@ -55,6 +55,10 @@ func (self *CmdAddBalance) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdAddBalance) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdAddBalance) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdGetCacheAge) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetCacheAge) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetCacheAge) RpcResult() interface{} {
|
||||
return &utils.CachedItemAge{}
|
||||
}
|
||||
|
||||
@@ -53,6 +53,10 @@ func (self *CmdReloadCache) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdReloadCache) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdReloadCache) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdGetCacheStats) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetCacheStats) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetCacheStats) RpcResult() interface{} {
|
||||
return &utils.CacheStats{}
|
||||
}
|
||||
|
||||
@@ -57,6 +57,10 @@ func (self *CmdGetCostDetails) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetCostDetails) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetCostDetails) RpcResult() interface{} {
|
||||
return &engine.CallCost{}
|
||||
}
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdExportCdrs) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdExportCdrs) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdExportCdrs) RpcResult() interface{} {
|
||||
return &utils.ExportedFileCdrs{}
|
||||
}
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdRemCdrs) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdRemCdrs) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdRemCdrs) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdCdrStatsMetrics) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdCdrStatsMetrics) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdCdrStatsMetrics) RpcResult() interface{} {
|
||||
return &map[string]float64{}
|
||||
}
|
||||
|
||||
@@ -49,6 +49,10 @@ func (self *CmdCdrStatsQueueIds) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdCdrStatsQueueIds) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdCdrStatsQueueIds) RpcResult() interface{} {
|
||||
var s []string
|
||||
return &s
|
||||
|
||||
@@ -54,6 +54,10 @@ func (self *CmdCdrReloadQueues) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdCdrReloadQueues) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdCdrReloadQueues) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdCdrResetQueues) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdCdrResetQueues) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdCdrResetQueues) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -34,6 +34,7 @@ type Commander interface {
|
||||
Usage() string // usage message
|
||||
RpcMethod() string // Method which should be called remotely
|
||||
RpcParams() interface{} // Parameters to send out on rpc
|
||||
PostprocessRpcParams() error // Corrects rpc parameters when needed
|
||||
RpcResult() interface{} // Only requirement is to have a String method to print on console
|
||||
ClientArgs() []string // for autocompletion
|
||||
Name() string
|
||||
@@ -74,6 +75,9 @@ func GetCommandValue(command string, verbose bool) (Commander, error) {
|
||||
if err := cmdVal.FromArgs(cmdArgs, verbose); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := cmdVal.PostprocessRpcParams(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return cmdVal, nil
|
||||
}
|
||||
|
||||
|
||||
@@ -54,6 +54,10 @@ func (self *CmdGetCost) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetCost) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetCost) RpcResult() interface{} {
|
||||
return &engine.CallCost{}
|
||||
}
|
||||
|
||||
@@ -58,6 +58,10 @@ func (self *CmdGetDataCost) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetDataCost) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetDataCost) RpcResult() interface{} {
|
||||
return &engine.DataCost{}
|
||||
}
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdGetDestination) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetDestination) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetDestination) RpcResult() interface{} {
|
||||
return &engine.Destination{}
|
||||
}
|
||||
|
||||
@@ -54,6 +54,10 @@ func (self *CmdGetMaxDuration) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetMaxDuration) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetMaxDuration) RpcResult() interface{} {
|
||||
var f float64
|
||||
return &f
|
||||
|
||||
@@ -60,6 +60,10 @@ func (self *CmdParse) RpcResult() interface{} {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdParse) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdParse) LocalExecute() string {
|
||||
if self.rpcParams.Expression == "" {
|
||||
return "Empty expression error"
|
||||
|
||||
@@ -53,6 +53,10 @@ func (self *CmdSetRatingProfile) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdSetRatingProfile) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdSetRatingProfile) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -50,6 +50,10 @@ func (self *CmdReloadScheduler) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdReloadScheduler) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdReloadScheduler) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdGetSharedGroup) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdGetSharedGroup) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdGetSharedGroup) RpcResult() interface{} {
|
||||
return &engine.SharedGroup{}
|
||||
}
|
||||
|
||||
@@ -49,6 +49,10 @@ func (self *CmdStatus) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdStatus) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdStatus) RpcResult() interface{} {
|
||||
var s map[string]interface{}
|
||||
return &s
|
||||
|
||||
@@ -52,6 +52,10 @@ func (self *CmdAddTriggeredAction) RpcParams() interface{} {
|
||||
return self.rpcParams
|
||||
}
|
||||
|
||||
func (self *CmdAddTriggeredAction) PostprocessRpcParams() error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (self *CmdAddTriggeredAction) RpcResult() interface{} {
|
||||
var s string
|
||||
return &s
|
||||
|
||||
Reference in New Issue
Block a user