diff --git a/engine/storage_sql_local_test.go b/engine/storage_sql_local_test.go index 687c66ab2..9fed858ce 100644 --- a/engine/storage_sql_local_test.go +++ b/engine/storage_sql_local_test.go @@ -346,3 +346,27 @@ func TestCallCost(t *testing.T) { t.Errorf("Expecting call cost: %v, received: %v", cc, ccRcv) } } + +func TestRemStoredCdrs(t *testing.T) { + if !*testLocal { + return + } + var timeStart, timeEnd time.Time + if err := mysql.RemStoredCdrs([]string{utils.FSCgrId("bbb1")}); err != nil { + t.Error(err.Error()) + } + if storedCdrs, err := mysql.GetStoredCdrs(nil, "", "", "", "", "", "", "", "", "", "", timeStart, timeEnd, false, false); err != nil { + t.Error(err.Error()) + } else if len(storedCdrs) != 7 { + t.Error("Unexpected number of StoredCdrs returned: ", storedCdrs) + } + if err := mysql.RemStoredCdrs([]string{utils.FSCgrId("aaa1"), utils.FSCgrId("aaa2"), utils.FSCgrId("aaa3"), utils.FSCgrId("aaa4"), utils.FSCgrId("aaa5"), + utils.FSCgrId("bbb2"), utils.FSCgrId("bbb3")}); err != nil { + t.Error(err.Error()) + } + if storedCdrs, err := mysql.GetStoredCdrs(nil, "", "", "", "", "", "", "", "", "", "", timeStart, timeEnd, false, false); err != nil { + t.Error(err.Error()) + } else if len(storedCdrs) != 0 { + t.Error("Unexpected number of StoredCdrs returned: ", storedCdrs) + } +}