diff --git a/console/stat_reset_queue.go b/console/stat_reset_queue.go new file mode 100644 index 000000000..0608ea925 --- /dev/null +++ b/console/stat_reset_queue.go @@ -0,0 +1,67 @@ +/* +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/utils" +) + +func init() { + c := &CmdResetStatQueue{ + name: "stat_reset_queue", + rpcMethod: utils.StatSv1ResetStatQueue, + rpcParams: &utils.TenantIDWithAPIOpts{}, + } + commands[c.Name()] = c + c.CommandExecuter = &CommandExecuter{c} +} + +type CmdResetStatQueue struct { + name string + rpcMethod string + rpcParams *utils.TenantIDWithAPIOpts + *CommandExecuter +} + +func (self *CmdResetStatQueue) Name() string { + return self.name +} + +func (self *CmdResetStatQueue) RpcMethod() string { + return self.rpcMethod +} + +func (self *CmdResetStatQueue) RpcParams(reset bool) any { + if reset || self.rpcParams == nil { + self.rpcParams = &utils.TenantIDWithAPIOpts{ + TenantID: new(utils.TenantID), + APIOpts: make(map[string]any), + } + } + return self.rpcParams +} + +func (self *CmdResetStatQueue) PostprocessRpcParams() error { + return nil +} + +func (self *CmdResetStatQueue) RpcResult() any { + var s string + return &s +} diff --git a/console/stat_reset_queue_test.go b/console/stat_reset_queue_test.go new file mode 100644 index 000000000..2fb4da448 --- /dev/null +++ b/console/stat_reset_queue_test.go @@ -0,0 +1,58 @@ +/* +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 ( + "reflect" + "strings" + "testing" + + v1 "github.com/cgrates/cgrates/apier/v1" + "github.com/cgrates/cgrates/utils" +) + +func TestCmdStatResetQueue(t *testing.T) { + command := commands["stat_reset_queue"] + // verify if StatSv1 object has method on it + m, ok := reflect.TypeOf(new(v1.StatSv1)).MethodByName(strings.Split(command.RpcMethod(), utils.NestingSep)[1]) + if !ok { + t.Fatal("method not found") + } + if m.Type.NumIn() != 4 { // expecting 4 inputs + t.Fatalf("invalid number of input parameters ") + } + // verify the type of input parameter + if ok := m.Type.In(2).AssignableTo(reflect.TypeOf(command.RpcParams(true))); !ok { + t.Fatalf("cannot assign input parameter") + } + // verify the type of output parameter + if ok := m.Type.In(3).AssignableTo(reflect.TypeOf(command.RpcResult())); !ok { + t.Fatalf("cannot assign output parameter") + } + // for coverage purpose + if err := command.PostprocessRpcParams(); err != nil { + t.Fatal(err) + } + // for coverage purpose + formatedResult := command.GetFormatedResult(command.RpcResult()) + expected := GetFormatedResult(command.RpcResult(), utils.StringSet{}) + if !reflect.DeepEqual(formatedResult, expected) { + t.Errorf("Expected <%+v>, Received <%+v>", expected, formatedResult) + } +}