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

Added cover tests for utils package

Browse Source
This commit is contained in:
andronache
2020-11-09 17:43:53 +02:00
committed by Dan Christian Bogos
parent d6d1fee2b0
commit 9782da930a
1 changed files with 84 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

88
utils/coreutils_test.go
View File

@@ -1304,20 +1304,100 @@ func TestTenantIDWithCache(t *testing.T) {
}
}
type testRPC struct {
type TestRPC struct {
}
func (tRPC *testRPC) Name(args interface{}, reply interface{}) error {
return errors.New("err_test")
func (tRPC *TestRPC) V1Copy(args *string, reply *string) error {
*reply = *args
return nil
}
func (tRPC *testRPC) V1Name(args interface{}, reply interface{}) error {
func (tRPC *TestRPC) V1Error(args *string, reply *string) error {
return errors.New("V1_err_test")
}
func (tRPC *TestRPC) Call(args interface{}, reply interface{}) error {
return nil
}
func (tRPC *TestRPC) V1Error2(args interface{}, reply interface{}) (error, int) {
return nil, 0
}
func (tRPC *TestRPC) V1Error3(args interface{}, reply interface{}) int {
return 0
}
func TestRPCCall(t *testing.T) {
if err := RPCCall("wrong", "test", nil, nil); err == nil || err != rpcclient.ErrUnsupporteServiceMethod {
t.Errorf("Expecting: %+v, received: %+v", rpcclient.ErrUnsupporteServiceMethod, err)
}
var reply string
if err := RPCCall(&TestRPC{}, "TestRPCV1.Copy", StringPointer("test"), &reply); err != nil {
t.Errorf("Expecting: <nil>, received: %+v", err)
}
if err := RPCCall(&TestRPC{}, "TestRPCV1.Error", StringPointer("test"), &reply); err == nil || err.Error() != "V1_err_test" {
t.Errorf("Expecting: <V1_err_test>, received: <%+v>", err)
}
if err := RPCCall(&TestRPC{}, "TestRPCV1.Unexist", StringPointer("test"), &reply); err == nil || err != rpcclient.ErrUnsupporteServiceMethod {
t.Errorf("Expecting: %+v, received: %+v", rpcclient.ErrUnsupporteServiceMethod, err)
}
if err := RPCCall(&TestRPC{}, "TestRPCV1.Error2", StringPointer("test"), &reply); err == nil || err != ErrServerError {
t.Errorf("Expecting: %+v, received: %+v", ErrServerError, err)
}
if err := RPCCall(&TestRPC{}, "TestRPCV1.Error3", StringPointer("test"), &reply); err == nil || err != ErrServerError {
t.Errorf("Expecting: %+v, received: %+v", ErrServerError, err)
}
}
type TestRPC2 struct {
}
func (tRPC *TestRPC2) Copy(args *string, reply *string) error {
*reply = *args
return nil
}
func (tRPC *TestRPC2) Error(args *string, reply *string) error {
return errors.New("V1_err_test")
}
func (tRPC *TestRPC2) Call(args interface{}, reply interface{}) error {
return nil
}
func (tRPC *TestRPC2) Error2(args interface{}, reply interface{}) (error, int) {
return nil, 0
}
func (tRPC *TestRPC2) Error3(args interface{}, reply interface{}) int {
return 0
}
func TestRPCAPICall(t *testing.T) {
if err := APIerRPCCall("wrong", "test", nil, nil); err == nil || err != rpcclient.ErrUnsupporteServiceMethod {
t.Errorf("Expecting: %+v, received: %+v", rpcclient.ErrUnsupporteServiceMethod, err)
}
var reply string
if err := APIerRPCCall(&TestRPC2{}, "TestRPC2.Copy", StringPointer("test"), &reply); err != nil {
t.Errorf("Expecting: <nil>, received: %+v", err)
}
if err := APIerRPCCall(&TestRPC2{}, "TestRPC2.Error", StringPointer("test"), &reply); err == nil || err.Error() != "V1_err_test" {
t.Errorf("Expecting: <V1_err_test>, received: <%+v>", err)
}
if err := APIerRPCCall(&TestRPC2{}, "TestRPC2.Unexist", StringPointer("test"), &reply); err == nil || err != rpcclient.ErrUnsupporteServiceMethod {
t.Errorf("Expecting: %+v, received: %+v", rpcclient.ErrUnsupporteServiceMethod, err)
}
if err := APIerRPCCall(&TestRPC2{}, "TestRPC2.Error2", StringPointer("test"), &reply); err == nil || err != ErrServerError {
t.Errorf("Expecting: %+v, received: %+v", ErrServerError, err)
}
if err := APIerRPCCall(&TestRPC2{}, "TestRPC2.Error3", StringPointer("test"), &reply); err == nil || err != ErrServerError {
t.Errorf("Expecting: %+v, received: %+v", ErrServerError, err)
}
}
func TestCounter(t *testing.T) {