From e07352130118d72a81beb5815bedd356f022ac93 Mon Sep 17 00:00:00 2001 From: DanB Date: Mon, 6 Nov 2017 18:20:17 +0100 Subject: [PATCH] Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests --- sessionmanager/data_it_test.go | 326 +++++++++++++++++++++++++++++ sessionmanager/smgreplc_it_test.go | 8 + utils/consts.go | 166 +++++++-------- 3 files changed, 415 insertions(+), 85 deletions(-) diff --git a/sessionmanager/data_it_test.go b/sessionmanager/data_it_test.go index 41c8ebe76..546e9be93 100644 --- a/sessionmanager/data_it_test.go +++ b/sessionmanager/data_it_test.go @@ -298,10 +298,46 @@ func TestSMGDataLastUsedMultipleUpdates(t *testing.T) { utils.CATEGORY: "data", utils.TENANT: acntAttrs.Tenant, utils.REQTYPE: utils.META_PREPAID, +<<<<<<< HEAD utils.SETUP_TIME: "2016-01-05 18:30:50", utils.ANSWER_TIME: "2016-01-05 18:31:05", utils.USAGE: "1024", // 8 MB utils.LastUsed: "5120", // 5 MB +======= + utils.USAGE: "1048576", + utils.LastUsed: "20000", + } + if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil { + t.Error(err) + } + if maxUsage != 1.048576e+06 { + t.Error("Bad max usage: ", maxUsage) + } + eAcntVal = 49998883840.000000 // 20480 + if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { + t.Error(err) + } else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal { + t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue()) + } + if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil { + t.Error(err) + } else if len(aSessions) != 1 || aSessions[0].Usage.Seconds() != 1088576 { + t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds()) + } + smgEv = SMGenericEvent{ + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.DATA, + utils.ACCID: "123492", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1010", + utils.SUBJECT: "1010", + utils.DESTINATION: "222", + utils.CATEGORY: "data", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.USAGE: "1048576", + utils.LastUsed: "20000", +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests } if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil { t.Error(err) @@ -383,7 +419,38 @@ func TestSMGDataLastUsedMultipleUpdates(t *testing.T) { nil, &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() { t.Error(err, aSessions) } +<<<<<<< HEAD if err := smgRPC.Call("SMGenericV1.ProcessCDR", smgEv, &reply); err != nil { +======= +} + +func TestSMGDataDerivedChargingNoCredit(t *testing.T) { + var acnt *engine.Account + attrs := &utils.AttrGetAccount{Tenant: "cgrates.org", Account: "1011"} + eAcntVal := 50000.0 + if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { + t.Error(err) + } else if acnt.BalanceMap[utils.VOICE].GetTotalValue() != eAcntVal { + t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.VOICE].GetTotalValue()) + } + smgEv := SMGenericEvent{ + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.VOICE, + utils.ACCID: "1234967", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1011", + utils.SUBJECT: "1011", + utils.DESTINATION: "+49", + utils.CATEGORY: "call", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.SETUP_TIME: "2016-01-05 18:30:49", + utils.ANSWER_TIME: "2016-01-05 18:31:05", + utils.USAGE: "100", + } + var maxUsage float64 + if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil { +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests t.Error(err) } else if reply != utils.OK { t.Errorf("Received reply: %s", reply) @@ -498,7 +565,11 @@ func TestSMGDataTTLExpMultiUpdates(t *testing.T) { utils.ANSWER_TIME: "2016-01-05 18:31:05", utils.USAGE: "4096", // 3MB } +<<<<<<< HEAD var maxUsage int64 +======= + var maxUsage float64 +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil { t.Error(err) } @@ -519,6 +590,7 @@ func TestSMGDataTTLExpMultiUpdates(t *testing.T) { t.Errorf("wrong active sessions: %d", int64(aSessions[0].Usage)) } smgEv = SMGenericEvent{ +<<<<<<< HEAD utils.EVENT_NAME: "TEST_EVENT", utils.TOR: utils.DATA, utils.ACCID: "123495", @@ -539,6 +611,25 @@ func TestSMGDataTTLExpMultiUpdates(t *testing.T) { t.Error(err) } if maxUsage != 4096 { +======= + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.DATA, + utils.ACCID: "123495", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1010", + utils.SUBJECT: "1010", + utils.DESTINATION: "222", + utils.CATEGORY: "data", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.USAGE: "1048576", + utils.LastUsed: "20000", + } + if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil { + t.Error(err) + } + if maxUsage != 1.048576e+06 { +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests t.Error("Bad max usage: ", maxUsage) } eAcntVal = 97280.000000 // 20480 @@ -596,7 +687,11 @@ func TestSMGDataMultipleDataNoUsage(t *testing.T) { utils.ANSWER_TIME: "2016-01-05 18:31:05", utils.USAGE: "2048", } +<<<<<<< HEAD var maxUsage int64 +======= + var maxUsage float64 +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil { t.Error(err) } @@ -612,14 +707,85 @@ func TestSMGDataMultipleDataNoUsage(t *testing.T) { aSessions := make([]*ActiveSession, 0) if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil { t.Error(err) +<<<<<<< HEAD } else if len(aSessions) != 1 || int64(aSessions[0].Usage) != 2048 { t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage)) +======= + } else if len(aSessions) != 1 || aSessions[0].Usage.Seconds() != 1048576 { + t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds()) } smgEv = SMGenericEvent{ utils.EVENT_NAME: "TEST_EVENT", utils.TOR: utils.DATA, + utils.ACCID: "123496", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1010", + utils.SUBJECT: "1010", + utils.DESTINATION: "222", + utils.CATEGORY: "data", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.USAGE: "1048576", + utils.LastUsed: "0", + } + if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil { + t.Error(err) + } + if maxUsage != 1.048576e+06 { + t.Error("Bad max usage: ", maxUsage) + } + eAcntVal = 49996712960.000000 // 0 + if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { + t.Error(err) + } else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal { + t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue()) + } + if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil { + t.Error(err) + } else if len(aSessions) != 1 || aSessions[0].Usage.Seconds() != 1048576 { + t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds()) +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests + } + smgEv = SMGenericEvent{ + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.DATA, +<<<<<<< HEAD utils.ACCID: "123495", +======= + utils.ACCID: "123496", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1010", + utils.SUBJECT: "1010", + utils.DESTINATION: "222", + utils.CATEGORY: "data", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.USAGE: "1048576", + utils.LastUsed: "0", + } + if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil { + t.Error(err) + } + if maxUsage != 1.048576e+06 { + t.Error("Bad max usage: ", maxUsage) + } + eAcntVal = 49996712960.000000 // 0 + if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { + t.Error(err) + } else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal { + t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue()) + } + if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil { + t.Error(err) + } else if len(aSessions) != 1 || aSessions[0].Usage.Seconds() != 1048576 { + t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds()) + } + smgEv = SMGenericEvent{ + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.DATA, + utils.ACCID: "123496", +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests utils.DIRECTION: utils.OUT, utils.ACCOUNT: acntAttrs.Account, utils.SUBJECT: acntAttrs.Account, @@ -758,7 +924,11 @@ func TestSMGDataTTLUsageProtection(t *testing.T) { utils.ANSWER_TIME: "2016-01-05 18:31:05", utils.USAGE: "2048", } +<<<<<<< HEAD var maxUsage int64 +======= + var maxUsage float64 +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil { t.Error(err) } @@ -774,6 +944,7 @@ func TestSMGDataTTLUsageProtection(t *testing.T) { aSessions := make([]*ActiveSession, 0) if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil { t.Error(err) +<<<<<<< HEAD } else if len(aSessions) != 1 || int64(aSessions[0].Usage) != 2048 { t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage)) @@ -782,5 +953,160 @@ func TestSMGDataTTLUsageProtection(t *testing.T) { if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() { t.Error(err, aSessions) +======= + } else if len(aSessions) != 1 || aSessions[0].Usage.Seconds() != 1048576 { + t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds()) + } + + smgEv = SMGenericEvent{ + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.DATA, + utils.ACCID: "123497", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1010", + utils.SUBJECT: "1010", + utils.DESTINATION: "222", + utils.CATEGORY: "data", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.USAGE: "1048576", + utils.LastUsed: "600", + } + if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil { + t.Error(err) + } + if maxUsage != 1.048576e+06 { + t.Error("Bad max usage: ", maxUsage) + } + eAcntVal = 49996712960.000000 // 0 + if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { + t.Error(err) + } else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal { + t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue()) + } + if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil { + t.Error(err) + } else if len(aSessions) != 1 || aSessions[0].Usage.Seconds() != 1049176 { + t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds()) + } + smgEv = SMGenericEvent{ + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.DATA, + utils.ACCID: "123497", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1010", + utils.SUBJECT: "1010", + utils.DESTINATION: "222", + utils.CATEGORY: "data", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.USAGE: "1048576", + utils.LastUsed: "600", + } + if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil { + t.Error(err) + } + if maxUsage != 1.048576e+06 { + t.Error("Bad max usage: ", maxUsage) + } + eAcntVal = 49996712960.000000 // 0 + if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { + t.Error(err) + } else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal { + t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue()) + } + if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil { + t.Error(err) + } else if len(aSessions) != 1 || aSessions[0].Usage.Seconds() != 1049776 { + t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds()) + } + smgEv = SMGenericEvent{ + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.DATA, + utils.ACCID: "123497", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1010", + utils.SUBJECT: "1010", + utils.DESTINATION: "222", + utils.CATEGORY: "data", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.USAGE: "1048576", + utils.LastUsed: "600", + } + if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil { + t.Error(err) + } + if maxUsage != 1.048576e+06 { + t.Error("Bad max usage: ", maxUsage) + } + eAcntVal = 49996712960.000000 // 0 + if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { + t.Error(err) + } else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal { + t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue()) + } + if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil { + t.Error(err) + } else if len(aSessions) != 1 || aSessions[0].Usage.Seconds() != 1050376 { + t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds()) + } + smgEv = SMGenericEvent{ + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.DATA, + utils.ACCID: "123497", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1010", + utils.SUBJECT: "1010", + utils.DESTINATION: "222", + utils.CATEGORY: "data", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.USAGE: "1048576", + utils.LastUsed: "600", + } + if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil { + t.Error(err) + } + if maxUsage != 1.048576e+06 { + t.Error("Bad max usage: ", maxUsage) + } + eAcntVal = 49996712960.000000 // 0 + if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { + t.Error(err) + } else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal { + t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue()) + } + if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil { + t.Error(err) + } else if len(aSessions) != 1 || aSessions[0].Usage.Seconds() != 1050976 { + t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds()) + } + smgEv = SMGenericEvent{ + utils.EVENT_NAME: "TEST_EVENT", + utils.TOR: utils.DATA, + utils.ACCID: "123497", + utils.DIRECTION: utils.OUT, + utils.ACCOUNT: "1010", + utils.SUBJECT: "1010", + utils.DESTINATION: "222", + utils.CATEGORY: "data", + utils.TENANT: "cgrates.org", + utils.REQTYPE: utils.META_PREPAID, + utils.LastUsed: "0", + } + var rpl string + if err = smgRPC.Call("SMGenericV1.TerminateSession", smgEv, &rpl); err != nil || rpl != utils.OK { + t.Error(err) + } + eAcntVal = 49997757440.000000 // 10240 (from the start) + if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { + t.Error(err) + } else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal { + t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue()) + } + if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() { + t.Error(err) +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests } } diff --git a/sessionmanager/smgreplc_it_test.go b/sessionmanager/smgreplc_it_test.go index 21c664d37..1b551c8ba 100644 --- a/sessionmanager/smgreplc_it_test.go +++ b/sessionmanager/smgreplc_it_test.go @@ -151,7 +151,11 @@ func TestSMGRplcUpdate(t *testing.T) { utils.ACCID: "123451", utils.USAGE: "1m", } +<<<<<<< HEAD var maxUsage time.Duration +======= + var maxUsage float64 +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests if err := smgRplcSlvRPC.Call(utils.SMGenericV2UpdateSession, smgEv, &maxUsage); err != nil { t.Error(err) @@ -256,7 +260,11 @@ func TestSMGRplcManualReplicate(t *testing.T) { utils.USAGE: "1m30s", } for _, smgEv := range []SMGenericEvent{smgEv1, smgEv2} { +<<<<<<< HEAD var maxUsage time.Duration +======= + var maxUsage float64 +>>>>>>> Using SMGenericV2 methods returning time.Duration as maxDuration instead of float, updated smg_it tests if err := smgRplcMstrRPC.Call(utils.SMGenericV2InitiateSession, smgEv, &maxUsage); err != nil { t.Error(err) } diff --git a/utils/consts.go b/utils/consts.go index 9041fd28b..beafe895a 100755 --- a/utils/consts.go +++ b/utils/consts.go @@ -480,6 +480,87 @@ const ( Disabled = "Disabled" Action = "Action" ThresholdSv1ProcessEvent = "ThresholdSv1.ProcessEvent" + MetaNow = "*now" + TpRatingPlans = "TpRatingPlans" + TpLcrs = "TpLcrs" + TpFilters = "TpFilters" + TpDestinationRates = "TpDestinationRates" + TpActionTriggers = "TpActionTriggers" + TpAccountActions = "TpAccountActions" + TpActionPlans = "TpActionPlans" + TpActions = "TpActions" + TpDerivedCharges = "TpDerivedCharges" + TpThresholds = "TpThresholds" + TpStats = "TpStats" + TpSharedGroups = "TpSharedGroups" + TpRatingProfiles = "TpRatingProfiles" + TpResources = "TpResources" + TpRates = "TpRates" + TpTiming = "TpTiming" + TpResource = "TpResource" + TpAliases = "TpAliases" + TpUsers = "TpUsers" + TpDerivedChargersV = "TpDerivedChargers" + TpCdrStats = "TpCdrStats" + TpDestinations = "TpDestinations" + TpLCR = "TpLCR" + TpRatingPlan = "TpRatingPlan" + TpRatingProfile = "TpRatingProfile" + Timing = "Timing" + RQF = "RQF" + Resource = "Resource" + ReverseAlias = "ReverseAlias" + Alias = "Alias" + User = "User" + Subscribers = "Subscribers" + DerivedChargersV = "DerivedChargers" + CdrStats = "CdrStats" + Destinations = "Destinations" + ReverseDestinations = "ReverseDestinations" + LCR = "LCR" + RatingPlan = "RatingPlan" + RatingProfile = "RatingProfile" + MetaRatingPlans = "*ratingplans" + MetaRatingProfile = "*ratingprofile" + MetaDestinations = "*destinations" + MetaReverseDestinations = "*reversedestinations" + MetaLCR = "*lcr" + MetaCdrStats = "*cdrstats" + MetaTiming = "*Timing" + MetaRQF = "*RQF" + MetaResource = "*Resource" + MetaReverseAlias = "*ReverseAlias" + MetaAlias = "*Alias" + MetaUser = "*User" + MetaSubscribers = "*Subscribers" + MetaDerivedChargersV = "*DerivedChargers" + MetaTpRatingPlans = "*TpRatingPlans" + MetaTpLcrs = "*TpLcrs" + MetaTpFilters = "*TpFilters" + MetaTpDestinationRates = "*TpDestinationRates" + MetaTpActionTriggers = "*TpActionTriggers" + MetaTpAccountActions = "*TpAccountActions" + MetaTpActionPlans = "*TpActionPlans" + MetaTpActions = "*TpActions" + MetaTpDerivedCharges = "*TpDerivedCharges" + MetaTpThresholds = "*TpThresholds" + MetaTpStats = "*TpStats" + MetaTpSharedGroups = "*TpSharedGroups" + MetaTpRatingProfiles = "*TpRatingProfiles" + MetaTpResources = "*TpResources" + MetaTpRates = "*TpRates" + MetaTpTiming = "*TpTiming" + MetaTpResource = "*TpResource" + MetaTpAliases = "*TpAliases" + MetaTpUsers = "*TpUsers" + MetaTpDerivedChargersV = "*TpDerivedChargers" + MetaTpCdrStats = "*TpCdrStats" + MetaTpDestinations = "*TpDestinations" + MetaTpLCR = "*TpLCR" + MetaTpRatingPlan = "*TpRatingPlan" + MetaTpRatingProfile = "*TpRatingProfile" + MetaStorDB = "*StorDB" + MetaDataDB = "*DataDB" SMGenericV2UpdateSession = "SMGenericV2.UpdateSession" SMGenericV2InitiateSession = "SMGenericV2.InitiateSession" SMGenericV1UpdateSession = "SMGenericV1.UpdateSession" @@ -495,7 +576,6 @@ const ( MetaTCC = "*tcc" MetaPDD = "*pdd" MetaDDC = "*ddc" - MetaNow = "*now" ) //Migrator Metas @@ -509,92 +589,8 @@ const ( MetaSharedGroups = "*shared_groups" MetaStats = "*stats" MetaThresholds = "*thresholds" - MetaRatingPlans = "*ratingplans" - MetaRatingProfile = "*ratingprofile" - MetaDestinations = "*destinations" - MetaReverseDestinations = "*reversedestinations" - MetaLCR = "*lcr" - MetaCdrStats = "*cdrstats" - MetaTiming = "*Timing" - MetaRQF = "*RQF" - MetaResource = "*Resource" - MetaReverseAlias = "*ReverseAlias" - MetaAlias = "*Alias" - MetaUser = "*User" - MetaSubscribers = "*Subscribers" - MetaDerivedChargersV = "*DerivedChargers" Migrator = "migrator" UnsupportedMigrationTask = "unsupported migration task" - MetaTpRatingPlans = "*TpRatingPlans" - MetaTpLcrs = "*TpLcrs" - MetaTpFilters = "*TpFilters" - MetaTpDestinationRates = "*TpDestinationRates" - MetaTpActionTriggers = "*TpActionTriggers" - MetaTpAccountActions = "*TpAccountActions" - MetaTpActionPlans = "*TpActionPlans" - MetaTpActions = "*TpActions" - MetaTpDerivedCharges = "*TpDerivedCharges" - MetaTpThresholds = "*TpThresholds" - MetaTpStats = "*TpStats" - MetaTpSharedGroups = "*TpSharedGroups" - MetaTpRatingProfiles = "*TpRatingProfiles" - MetaTpResources = "*TpResources" - MetaTpRates = "*TpRates" - MetaTpTiming = "*TpTiming" - MetaTpResource = "*TpResource" - MetaTpAliases = "*TpAliases" - MetaTpUsers = "*TpUsers" - MetaTpDerivedChargersV = "*TpDerivedChargers" - MetaTpCdrStats = "*TpCdrStats" - MetaTpDestinations = "*TpDestinations" - MetaTpLCR = "*TpLCR" - MetaTpRatingPlan = "*TpRatingPlan" - MetaTpRatingProfile = "*TpRatingProfile" - MetaStorDB = "*StorDB" - MetaDataDB = "*DataDB" -) - -//versions -const ( - TpRatingPlans = "TpRatingPlans" - TpLcrs = "TpLcrs" - TpFilters = "TpFilters" - TpDestinationRates = "TpDestinationRates" - TpActionTriggers = "TpActionTriggers" - TpAccountActions = "TpAccountActions" - TpActionPlans = "TpActionPlans" - TpActions = "TpActions" - TpDerivedCharges = "TpDerivedCharges" - TpThresholds = "TpThresholds" - TpStats = "TpStats" - TpSharedGroups = "TpSharedGroups" - TpRatingProfiles = "TpRatingProfiles" - TpResources = "TpResources" - TpRates = "TpRates" - TpTiming = "TpTiming" - TpResource = "TpResource" - TpAliases = "TpAliases" - TpUsers = "TpUsers" - TpDerivedChargersV = "TpDerivedChargers" - TpCdrStats = "TpCdrStats" - TpDestinations = "TpDestinations" - TpLCR = "TpLCR" - TpRatingPlan = "TpRatingPlan" - TpRatingProfile = "TpRatingProfile" - Timing = "Timing" - RQF = "RQF" - Resource = "Resource" - ReverseAlias = "ReverseAlias" - Alias = "Alias" - User = "User" - Subscribers = "Subscribers" - DerivedChargersV = "DerivedChargers" - CdrStats = "CdrStats" - Destinations = "Destinations" - ReverseDestinations = "ReverseDestinations" - LCR = "LCR" - RatingPlan = "RatingPlan" - RatingProfile = "RatingProfile" ) func buildCacheInstRevPrefixes() {