mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
Added unit tests for GetLoadedIds in engine/tpreader.go
This commit is contained in:
nickolasdaniel
committed by
Dan Christian Bogos
Dan Christian Bogos
parent
5afa506300
commit
9ce27430ca
@@ -24,7 +24,9 @@ import (
|
||||
"log"
|
||||
"os"
|
||||
"reflect"
|
||||
"sort"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/cgrates/cgrates/config"
|
||||
"github.com/cgrates/cgrates/utils"
|
||||
@@ -403,3 +405,590 @@ func TestCallCacheClear(t *testing.T) {
|
||||
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", nil, err)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsResources(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
resources: []*utils.TenantID{
|
||||
{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "resourcesID",
|
||||
},
|
||||
{
|
||||
Tenant: "tenant.com",
|
||||
ID: "mytenantID",
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.ResourcesPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:resourcesID", "tenant.com:mytenantID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsStatQueues(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
statQueues: []*utils.TenantID{
|
||||
{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "statQueueID",
|
||||
},
|
||||
{
|
||||
Tenant: "tenant.com",
|
||||
ID: "mytenantID",
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.StatQueuePrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:statQueueID", "tenant.com:mytenantID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsThresholds(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
thresholds: []*utils.TenantID{
|
||||
{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "thresholdsID",
|
||||
},
|
||||
{
|
||||
Tenant: "tenant.com",
|
||||
ID: "mytenantID",
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.ThresholdPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:thresholdsID", "tenant.com:mytenantID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsDestinations(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
destinations: map[string]*Destination{
|
||||
"1001": {
|
||||
Id: "1001_ID",
|
||||
Prefixes: []string{"39", "40"},
|
||||
},
|
||||
"1002": {
|
||||
Id: "1002_ID",
|
||||
Prefixes: []string{"75", "82"},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.DestinationPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
//Test fails sometimes because of the order of the returned slice
|
||||
expRcv := []string{"1001", "1002"}
|
||||
sort.Strings(rcv)
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsReverseDestinations(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
destinations: map[string]*Destination{
|
||||
"1001": {
|
||||
Id: "1001_ID",
|
||||
Prefixes: []string{"39", "75"},
|
||||
},
|
||||
"1002": {
|
||||
Id: "1002_ID",
|
||||
Prefixes: []string{"87", "21"},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.ReverseDestinationPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
sort.Strings(rcv)
|
||||
expRcv := []string{"21", "39", "75", "87"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsRatingPlans(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
ratingPlans: map[string]*RatingPlan{
|
||||
"RP_RETAIL1": {
|
||||
Id: "RP_1001",
|
||||
Timings: map[string]*RITiming{
|
||||
"TIMING_1001": {
|
||||
ID: "PEAK",
|
||||
Years: []int{2021},
|
||||
Months: []time.Month{8},
|
||||
MonthDays: []int{31},
|
||||
WeekDays: []time.Weekday{5},
|
||||
StartTime: "15:00:00Z",
|
||||
EndTime: "17:00:00Z",
|
||||
cronString: "21 2 5 25 8 5 2021", //sec, min, hour, monthday, month, weekday, year
|
||||
tag: utils.MetaAny,
|
||||
},
|
||||
},
|
||||
Ratings: map[string]*RIRate{
|
||||
"RATING_1001": {
|
||||
ConnectFee: 0.4,
|
||||
RoundingMethod: utils.MetaUp,
|
||||
RoundingDecimals: 4,
|
||||
MaxCost: 0.60,
|
||||
MaxCostStrategy: utils.MetaMaxCostDisconnect,
|
||||
Rates: []*RGRate{
|
||||
{
|
||||
GroupIntervalStart: 0,
|
||||
Value: 0.2,
|
||||
RateIncrement: 60 * time.Second,
|
||||
RateUnit: 60 * time.Second,
|
||||
},
|
||||
},
|
||||
tag: utils.MetaAny,
|
||||
},
|
||||
},
|
||||
DestinationRates: map[string]RPRateList{
|
||||
"DR_FS_40CNT": {
|
||||
{
|
||||
Timing: "TIMING_1001",
|
||||
Rating: "RATING_1001",
|
||||
Weight: 10,
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.RatingPlanPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"RP_RETAIL1"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsRatingProfiles(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
ratingProfiles: map[string]*RatingProfile{
|
||||
"1001": {
|
||||
Id: "RP_RETAIL1",
|
||||
RatingPlanActivations: []*RatingPlanActivation{
|
||||
{
|
||||
ActivationTime: time.Date(2014, 7, 14, 14, 25, 0, 0, time.UTC),
|
||||
RatingPlanId: "RETAIL1",
|
||||
},
|
||||
},
|
||||
},
|
||||
"1002": {
|
||||
Id: "RP_RETAIL2",
|
||||
RatingPlanActivations: []*RatingPlanActivation{
|
||||
{
|
||||
ActivationTime: time.Date(2014, 7, 21, 14, 15, 0, 0, time.UTC),
|
||||
RatingPlanId: "RETAIL2",
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.RatingProfilePrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
sort.Strings(rcv)
|
||||
expRcv := []string{"1001", "1002"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsActions(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
actions: map[string][]*Action{
|
||||
"TOPUP_RST_10": {
|
||||
{
|
||||
Id: "ACTION_1001",
|
||||
ActionType: utils.MetaSetBalance,
|
||||
ExtraParameters: "",
|
||||
Filter: "",
|
||||
ExpirationString: "",
|
||||
Weight: 10,
|
||||
balanceValue: 9.45,
|
||||
},
|
||||
},
|
||||
"TOPUP_RST_5": {
|
||||
{
|
||||
Id: "ACTION_1002",
|
||||
ActionType: utils.MetaPublishAccount,
|
||||
ExtraParameters: "",
|
||||
Filter: "",
|
||||
ExpirationString: "",
|
||||
Weight: 5,
|
||||
balanceValue: 12.32,
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.ActionPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
sort.Strings(rcv)
|
||||
expRcv := []string{"TOPUP_RST_10", "TOPUP_RST_5"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsActionPlans(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
actionPlans: map[string]*ActionPlan{
|
||||
"PACKAGE_1001": {
|
||||
Id: "TOPUP_RST_10",
|
||||
AccountIDs: map[string]bool{
|
||||
"1001": true,
|
||||
"1002": false,
|
||||
},
|
||||
},
|
||||
"PACKAGE_1002": {
|
||||
Id: "TOPUP_RST_5",
|
||||
AccountIDs: map[string]bool{
|
||||
"1001": false,
|
||||
"1002": true,
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.ActionPlanPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
sort.Strings(rcv)
|
||||
expRcv := []string{"PACKAGE_1001", "PACKAGE_1002"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsSharedGroup(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
sharedGroups: map[string]*SharedGroup{
|
||||
"SHARED_A": {
|
||||
Id: "SHARED_ID1",
|
||||
AccountParameters: map[string]*SharingParameters{
|
||||
"PARAM_1": {
|
||||
Strategy: utils.MetaTopUp,
|
||||
RatingSubject: "1001",
|
||||
},
|
||||
},
|
||||
MemberIds: map[string]bool{
|
||||
"1001": true,
|
||||
"1002": false,
|
||||
},
|
||||
},
|
||||
"SHARED_B": {
|
||||
Id: "SHARED_ID2",
|
||||
AccountParameters: map[string]*SharingParameters{
|
||||
"PARAM_1": {
|
||||
Strategy: utils.MetaTopUp,
|
||||
RatingSubject: "1002",
|
||||
},
|
||||
},
|
||||
MemberIds: map[string]bool{
|
||||
"1001": true,
|
||||
"1002": false,
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.SharedGroupPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
sort.Strings(rcv)
|
||||
expRcv := []string{"SHARED_A", "SHARED_B"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsResourceProfiles(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
resProfiles: map[utils.TenantID]*utils.TPResourceProfile{
|
||||
{Tenant: "cgrates.org", ID: "ResGroup1"}: {
|
||||
TPid: testTPID,
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ResGroup1",
|
||||
FilterIDs: []string{"*string:~*req.Account:1001"},
|
||||
ActivationInterval: &utils.TPActivationInterval{
|
||||
ActivationTime: "2014-07-29T15:00:00Z",
|
||||
},
|
||||
UsageTTL: "1s",
|
||||
AllocationMessage: "call",
|
||||
Weight: 10,
|
||||
Limit: "2",
|
||||
Blocker: true,
|
||||
Stored: true,
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.ResourceProfilesPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:ResGroup1"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsActionTriggers(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
actionsTriggers: map[string]ActionTriggers{
|
||||
"STANDARD_TRIGGERS": {
|
||||
{
|
||||
ID: "ID1",
|
||||
UniqueID: "",
|
||||
ThresholdType: "*max_balance",
|
||||
ThresholdValue: 20,
|
||||
Recurrent: false,
|
||||
MinSleep: 0,
|
||||
Weight: 10,
|
||||
ActionsID: "LOG_WARNING",
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.ActionTriggerPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"STANDARD_TRIGGERS"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsStatQueueProfiles(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
sqProfiles: map[utils.TenantID]*utils.TPStatProfile{
|
||||
{Tenant: "cgrates.org", ID: "cgratesID"}: {
|
||||
TPid: testTPID,
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ResGroup1",
|
||||
FilterIDs: []string{"*string:~*req.Account:1001"},
|
||||
ActivationInterval: &utils.TPActivationInterval{
|
||||
ActivationTime: "2014-07-29T15:00:00Z",
|
||||
},
|
||||
Weight: 10,
|
||||
Blocker: true,
|
||||
Stored: true,
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.StatQueueProfilePrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:cgratesID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsThresholdProfiles(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
thProfiles: map[utils.TenantID]*utils.TPThresholdProfile{
|
||||
{Tenant: "cgrates.org", ID: "cgratesID"}: {
|
||||
TPid: testTPID,
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ResGroup1",
|
||||
FilterIDs: []string{"*string:~*req.Account:1001"},
|
||||
ActivationInterval: &utils.TPActivationInterval{
|
||||
ActivationTime: "2014-07-29T15:00:00Z",
|
||||
},
|
||||
Weight: 10,
|
||||
Blocker: true,
|
||||
MaxHits: 3,
|
||||
MinHits: 1,
|
||||
Async: true,
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.ThresholdProfilePrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:cgratesID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsFilters(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
filters: map[utils.TenantID]*utils.TPFilterProfile{
|
||||
{Tenant: "cgrates.org", ID: "cgratesID"}: {
|
||||
TPid: testTPID,
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ResGroup1",
|
||||
ActivationInterval: &utils.TPActivationInterval{
|
||||
ActivationTime: "2014-07-29T15:00:00Z",
|
||||
},
|
||||
Filters: []*utils.TPFilter{
|
||||
{
|
||||
Type: "~*req",
|
||||
Element: "Account",
|
||||
Values: []string{"1001"},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.FilterPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:cgratesID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsRouteProfiles(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
routeProfiles: map[utils.TenantID]*utils.TPRouteProfile{
|
||||
{Tenant: "cgrates.org", ID: "cgratesID"}: {
|
||||
TPid: testTPID,
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ResGroup1",
|
||||
ActivationInterval: &utils.TPActivationInterval{
|
||||
ActivationTime: "2014-07-29T15:00:00Z",
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.RouteProfilePrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:cgratesID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsAttributeProfiles(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
attributeProfiles: map[utils.TenantID]*utils.TPAttributeProfile{
|
||||
{Tenant: "cgrates.org", ID: "cgratesID"}: {
|
||||
TPid: testTPID,
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ResGroup1",
|
||||
FilterIDs: []string{"*string:~*req.Account:1001"},
|
||||
ActivationInterval: &utils.TPActivationInterval{
|
||||
ActivationTime: "2014-07-29T15:00:00Z",
|
||||
},
|
||||
Contexts: []string{"sessions"},
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.AttributeProfilePrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:cgratesID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsChargerProfiles(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
chargerProfiles: map[utils.TenantID]*utils.TPChargerProfile{
|
||||
{Tenant: "cgrates.org", ID: "cgratesID"}: {
|
||||
TPid: testTPID,
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ResGroup1",
|
||||
ActivationInterval: &utils.TPActivationInterval{
|
||||
ActivationTime: "2014-07-29T15:00:00Z",
|
||||
},
|
||||
RunID: "RUN_ID",
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.ChargerProfilePrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:cgratesID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsDispatcherProfiles(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
dispatcherProfiles: map[utils.TenantID]*utils.TPDispatcherProfile{
|
||||
{Tenant: "cgrates.org", ID: "cgratesID"}: {
|
||||
TPid: testTPID,
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ResGroup1",
|
||||
ActivationInterval: &utils.TPActivationInterval{
|
||||
ActivationTime: "2014-07-29T15:00:00Z",
|
||||
},
|
||||
Strategy: utils.MetaMaxCostDisconnect,
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.DispatcherProfilePrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:cgratesID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsDispatcherHosts(t *testing.T) {
|
||||
tpr := &TpReader{
|
||||
dispatcherHosts: map[utils.TenantID]*utils.TPDispatcherHost{
|
||||
{Tenant: "cgrates.org", ID: "cgratesID"}: {
|
||||
TPid: testTPID,
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ResGroup1",
|
||||
},
|
||||
},
|
||||
}
|
||||
rcv, err := tpr.GetLoadedIds(utils.DispatcherHostPrefix)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
expRcv := []string{"cgrates.org:cgratesID"}
|
||||
if !reflect.DeepEqual(expRcv, rcv) {
|
||||
t.Errorf("\nExpected %v but received \n%v", expRcv, rcv)
|
||||
}
|
||||
}
|
||||
|
||||
func TestGetLoadedIdsError(t *testing.T) {
|
||||
tpr := &TpReader{}
|
||||
errExpect := "Unsupported load category"
|
||||
if _, err := tpr.GetLoadedIds(""); err == nil || err.Error() != errExpect {
|
||||
t.Errorf("\nExpected error %v but received \n%v", errExpect, err)
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user