From 5cbce1ec43718e234fa770f980cd9fab615eb222 Mon Sep 17 00:00:00 2001 From: Trial97 Date: Wed, 7 Aug 2019 15:45:39 +0300 Subject: [PATCH] Removed unused constants --- agents/fsevent.go | 2 +- agents/fsevent_test.go | 2 +- apier/v1/accounts_test.go | 10 +- apier/v1/apier.go | 2 +- apier/v1/apier_it_test.go | 2 +- apier/v1/rals.go | 2 +- console/ratingprofile_rem.go | 4 +- engine/account.go | 4 +- engine/callcost_test.go | 2 +- engine/responder.go | 2 - engine/suppliers.go | 2 +- general_tests/oldtutorial_it_test.go | 2 +- general_tests/suretax_it_test.go | 2 +- loaders/loader_it_test.go | 2 +- packages/debian/debian | 1 - sessions/sessions_birpc_it_test.go | 2 +- sessions/sessions_voice_it_test.go | 2 +- utils/consts.go | 616 ++++++++++++--------------- 18 files changed, 304 insertions(+), 357 deletions(-) delete mode 120000 packages/debian/debian diff --git a/agents/fsevent.go b/agents/fsevent.go index 7b727f2ba..9d996521c 100644 --- a/agents/fsevent.go +++ b/agents/fsevent.go @@ -100,7 +100,7 @@ func (fsev FSEvent) GetDirection(fieldName string) string { return fieldName[len(utils.STATIC_VALUE_PREFIX):] } //TODO: implement direction - return utils.OUT + return utils.META_OUT } // Account calling diff --git a/agents/fsevent_test.go b/agents/fsevent_test.go index 9bc825c4e..ed999f274 100644 --- a/agents/fsevent_test.go +++ b/agents/fsevent_test.go @@ -513,7 +513,7 @@ func TestParseEventValue(t *testing.T) { if parsed, _ := ev.ParseEventValue(config.NewRSRParserMustCompile(utils.REGEXP_PREFIX+utils.RequestType, true), ""); parsed != utils.META_PREPAID { t.Error("Unexpected result parsed", parsed) } - if parsed, _ := ev.ParseEventValue(config.NewRSRParserMustCompile(utils.REGEXP_PREFIX+utils.Direction, true), ""); parsed != utils.OUT { + if parsed, _ := ev.ParseEventValue(config.NewRSRParserMustCompile(utils.REGEXP_PREFIX+utils.Direction, true), ""); parsed != utils.META_OUT { t.Error("Unexpected result parsed", parsed) } if parsed, _ := ev.ParseEventValue(config.NewRSRParserMustCompile(utils.REGEXP_PREFIX+utils.Tenant, true), ""); parsed != "cgrates.org" { diff --git a/apier/v1/accounts_test.go b/apier/v1/accounts_test.go index a7168fc85..8aaa2a97a 100644 --- a/apier/v1/accounts_test.go +++ b/apier/v1/accounts_test.go @@ -42,15 +42,15 @@ func TestSetAccounts(t *testing.T) { iscTenant := "itsyscom.com" b10 := &engine.Balance{Value: 10, Weight: 10} cgrAcnt1 := &engine.Account{ID: utils.ConcatenatedKey(cgrTenant, "account1"), - BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.OUT: engine.Balances{b10}}} + BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.META_OUT: engine.Balances{b10}}} cgrAcnt2 := &engine.Account{ID: utils.ConcatenatedKey(cgrTenant, "account2"), - BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.OUT: engine.Balances{b10}}} + BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.META_OUT: engine.Balances{b10}}} cgrAcnt3 := &engine.Account{ID: utils.ConcatenatedKey(cgrTenant, "account3"), - BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.OUT: engine.Balances{b10}}} + BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.META_OUT: engine.Balances{b10}}} iscAcnt1 := &engine.Account{ID: utils.ConcatenatedKey(iscTenant, "account1"), - BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.OUT: engine.Balances{b10}}} + BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.META_OUT: engine.Balances{b10}}} iscAcnt2 := &engine.Account{ID: utils.ConcatenatedKey(iscTenant, "account2"), - BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.OUT: engine.Balances{b10}}} + BalanceMap: map[string]engine.Balances{utils.MONETARY + utils.META_OUT: engine.Balances{b10}}} for _, account := range []*engine.Account{cgrAcnt1, cgrAcnt2, cgrAcnt3, iscAcnt1, iscAcnt2} { if err := apierAcntsAcntStorage.SetAccount(account); err != nil { t.Error(err) diff --git a/apier/v1/apier.go b/apier/v1/apier.go index e7508862a..c749eccbc 100644 --- a/apier/v1/apier.go +++ b/apier/v1/apier.go @@ -941,7 +941,7 @@ func (arrp *AttrRemoveRatingProfile) GetId() (result string) { func (self *ApierV1) RemoveRatingProfile(attr AttrRemoveRatingProfile, reply *string) error { if attr.Direction == "" { - attr.Direction = utils.OUT + attr.Direction = utils.META_OUT } if (attr.Subject != "" && utils.IsSliceMember([]string{attr.Direction, attr.Tenant, attr.Category}, "")) || (attr.Category != "" && utils.IsSliceMember([]string{attr.Direction, attr.Tenant}, "")) || diff --git a/apier/v1/apier_it_test.go b/apier/v1/apier_it_test.go index 60ea2cc1d..7fc13dd1a 100644 --- a/apier/v1/apier_it_test.go +++ b/apier/v1/apier_it_test.go @@ -960,7 +960,7 @@ func TestApierExecuteAction(t *testing.T) { } func TestApierSetActions(t *testing.T) { - act1 := &V1TPAction{Identifier: utils.TOPUP_RESET, BalanceType: utils.MONETARY, Directions: utils.OUT, Units: 75.0, ExpiryTime: utils.UNLIMITED, Weight: 20.0} + act1 := &V1TPAction{Identifier: utils.TOPUP_RESET, BalanceType: utils.MONETARY, Directions: utils.META_OUT, Units: 75.0, ExpiryTime: utils.UNLIMITED, Weight: 20.0} attrs1 := &V1AttrSetActions{ActionsId: "ACTS_1", Actions: []*V1TPAction{act1}} reply1 := "" if err := rater.Call("ApierV1.SetActions", attrs1, &reply1); err != nil { diff --git a/apier/v1/rals.go b/apier/v1/rals.go index 62ad9b9b9..79d13a00c 100644 --- a/apier/v1/rals.go +++ b/apier/v1/rals.go @@ -68,7 +68,7 @@ func (rsv1 *RALsV1) GetRatingPlansCost(arg *utils.RatingPlanCostArg, reply *disp } for _, rp := range arg.RatingPlanIDs { // loop through RatingPlans until we find one without errors rPrfl := &engine.RatingProfile{ - Id: utils.ConcatenatedKey(utils.OUT, + Id: utils.ConcatenatedKey(utils.META_OUT, tenant, category, subject), RatingPlanActivations: engine.RatingPlanActivations{ &engine.RatingPlanActivation{ diff --git a/console/ratingprofile_rem.go b/console/ratingprofile_rem.go index b8348af7f..cd6d9ccf2 100644 --- a/console/ratingprofile_rem.go +++ b/console/ratingprofile_rem.go @@ -53,13 +53,13 @@ func (self *CmdRemRatingProfile) RpcMethod() string { func (self *CmdRemRatingProfile) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &v1.AttrRemoveRatingProfile{Direction: utils.OUT} + self.rpcParams = &v1.AttrRemoveRatingProfile{Direction: utils.META_OUT} } return self.rpcParams } func (self *CmdRemRatingProfile) PostprocessRpcParams() error { - if reflect.DeepEqual(self.rpcParams, &v1.AttrRemoveRatingProfile{Direction: utils.OUT}) { + if reflect.DeepEqual(self.rpcParams, &v1.AttrRemoveRatingProfile{Direction: utils.META_OUT}) { return utils.ErrMandatoryIeMissing } return nil diff --git a/engine/account.go b/engine/account.go index 455e63137..f577e1ce5 100644 --- a/engine/account.go +++ b/engine/account.go @@ -974,7 +974,7 @@ func (acc *Account) AsOldStructure() interface{} { } result := &Account{ - Id: utils.OUT + ":" + acc.ID, + Id: utils.META_OUT + ":" + acc.ID, BalanceMap: make(map[string]Balances, len(acc.BalanceMap)), UnitCounters: make([]*UnitsCounter, len(acc.UnitCounters)), ActionTriggers: make(ActionTriggers, len(acc.ActionTriggers)), @@ -1037,7 +1037,7 @@ func (acc *Account) AsOldStructure() interface{} { } for key, values := range acc.BalanceMap { if len(values) > 0 { - key += utils.OUT + key += utils.META_OUT result.BalanceMap[key] = make(Balances, len(values)) for i, b := range values { result.BalanceMap[key][i] = &Balance{ diff --git a/engine/callcost_test.go b/engine/callcost_test.go index eb48bc398..b9cc1741d 100644 --- a/engine/callcost_test.go +++ b/engine/callcost_test.go @@ -104,7 +104,7 @@ func TestMultipleInputLeftMerge(t *testing.T) { } /*t1 = time.Date(2012, time.February, 2, 18, 01, 0, 0, time.UTC) t2 = time.Date(2012, time.February, 2, 18, 02, 0, 0, time.UTC) - cd = &CallDescriptor{Direction: utils.OUT, TOR: "0", Tenant: "vdf", Subject: "rif", Destination: "0256", TimeStart: t1, TimeEnd: t2} + cd = &CallDescriptor{Direction: utils.META_OUT, TOR: "0", Tenant: "vdf", Subject: "rif", Destination: "0256", TimeStart: t1, TimeEnd: t2} cc2, _ := cd.getCost() if cc2.Cost != 30 { t.Errorf("expected 30 was %v", cc2.Cost) diff --git a/engine/responder.go b/engine/responder.go index 19dc4ee54..7a8fb1174 100644 --- a/engine/responder.go +++ b/engine/responder.go @@ -26,7 +26,6 @@ import ( "github.com/cgrates/cgrates/config" "github.com/cgrates/cgrates/guardian" "github.com/cgrates/cgrates/utils" - "github.com/cgrates/rpcclient" ) // Individual session run @@ -38,7 +37,6 @@ type SessionRun struct { type Responder struct { ExitChan chan bool - CdrStats rpcclient.RpcClientConnection Timeout time.Duration Timezone string MaxComputedUsage map[string]time.Duration diff --git a/engine/suppliers.go b/engine/suppliers.go index d7a7b8bed..e0ee7469a 100644 --- a/engine/suppliers.go +++ b/engine/suppliers.go @@ -226,7 +226,7 @@ func (spS *SupplierService) costForEvent(ev *utils.CGREvent, } for _, rp := range rpIDs { // loop through RatingPlans until we find one without errors rPrfl := &RatingProfile{ - Id: utils.ConcatenatedKey(utils.OUT, + Id: utils.ConcatenatedKey(utils.META_OUT, ev.Tenant, utils.MetaSuppliers, subj), RatingPlanActivations: RatingPlanActivations{ &RatingPlanActivation{ diff --git a/general_tests/oldtutorial_it_test.go b/general_tests/oldtutorial_it_test.go index ab779bb4c..58d30030c 100644 --- a/general_tests/oldtutorial_it_test.go +++ b/general_tests/oldtutorial_it_test.go @@ -1347,7 +1347,7 @@ package general_tests // Account: "1001", // Subject: "1001", // Tenant: "cgrates.org", -// Direction: utils.OUT, +// Direction: utils.META_OUT, // Destination: "1003", // Timespans: []*engine.TimeSpan{ // &engine.TimeSpan{ diff --git a/general_tests/suretax_it_test.go b/general_tests/suretax_it_test.go index 2523bcc3b..92d1d425e 100644 --- a/general_tests/suretax_it_test.go +++ b/general_tests/suretax_it_test.go @@ -110,7 +110,7 @@ func TestSTICacheStats(t *testing.T) { // Test CDR from external sources func TestSTIProcessExternalCdr(t *testing.T) { cdr := &engine.ExternalCDR{ToR: utils.VOICE, - OriginID: "teststicdr1", OriginHost: "192.168.1.1", Source: "STI_TEST", RequestType: utils.META_RATED, Direction: utils.OUT, + OriginID: "teststicdr1", OriginHost: "192.168.1.1", Source: "STI_TEST", RequestType: utils.META_RATED, Direction: utils.META_OUT, Tenant: "cgrates.org", Category: "call", Account: "1001", Subject: "+14082342500", Destination: "+16268412300", Supplier: "SUPPL1", SetupTime: "2015-10-18T13:00:00Z", AnswerTime: "2015-10-18T13:00:00Z", Usage: "15s", PDD: "7.0", ExtraFields: map[string]string{"CustomerNumber": "000000534", "ZipCode": ""}, diff --git a/loaders/loader_it_test.go b/loaders/loader_it_test.go index 98c8847ec..68011a146 100644 --- a/loaders/loader_it_test.go +++ b/loaders/loader_it_test.go @@ -77,7 +77,7 @@ func testLoaderInitCfg(t *testing.T) { loaderCfgPath = path.Join(loaderDataDir, "conf", "samples", "loaders", loaderConfigDIR) loaderCfg, err = config.NewCGRConfigFromPath(loaderCfgPath) if err != nil { - t.Error(err) + t.Fatal(err) } loaderCfg.DataFolderPath = loaderDataDir // Share DataFolderPath through config towards StoreDb for Flush() config.SetCgrConfig(loaderCfg) diff --git a/packages/debian/debian b/packages/debian/debian deleted file mode 120000 index 3088477d5..000000000 --- a/packages/debian/debian +++ /dev/null @@ -1 +0,0 @@ -packages/debian \ No newline at end of file diff --git a/sessions/sessions_birpc_it_test.go b/sessions/sessions_birpc_it_test.go index 9f0561192..22139b62b 100644 --- a/sessions/sessions_birpc_it_test.go +++ b/sessions/sessions_birpc_it_test.go @@ -184,7 +184,7 @@ func TestSessionsBiRPCSessionAutomaticDisconnects(t *testing.T) { utils.EVENT_NAME: "TEST_EVENT", utils.ToR: utils.VOICE, utils.OriginID: "123451", - utils.Direction: utils.OUT, + utils.Direction: utils.META_OUT, utils.Account: attrSetBalance.Account, utils.Subject: attrSetBalance.Account, utils.Destination: "1004", diff --git a/sessions/sessions_voice_it_test.go b/sessions/sessions_voice_it_test.go index 107842b23..276b426f2 100644 --- a/sessions/sessions_voice_it_test.go +++ b/sessions/sessions_voice_it_test.go @@ -1282,7 +1282,7 @@ func TestSMGDataDerivedChargingNoCredit(t *testing.T) { utils.EVENT_NAME: "TEST_EVENT", utils.TOR: utils.VOICE, utils.OriginID: "1234967", - utils.Direction: utils.OUT, + utils.Direction: utils.META_OUT, utils.Account: "1011", utils.Subject: "1011", utils.Destination: "+49", diff --git a/utils/consts.go b/utils/consts.go index 2a685fa73..f686db281 100755 --- a/utils/consts.go +++ b/utils/consts.go @@ -113,10 +113,10 @@ const ( POSTGRES = "postgres" MYSQL = "mysql" MONGO = "mongo" - INTERNAL = "internal" - DataManager = "DataManager" REDIS = "redis" MAPSTOR = "mapstor" + INTERNAL = "internal" + DataManager = "DataManager" LOCALHOST = "127.0.0.1" FSCDR_FILE_CSV = "freeswitch_file_csv" FSCDR_HTTP_JSON = "freeswitch_http_json" @@ -190,7 +190,6 @@ const ( DRYRUN = "dry_run" META_COMBIMED = "*combimed" MetaInternal = "*internal" - MetaInline = "*inline" ZERO_RATING_SUBJECT_PREFIX = "*zero" OK = "OK" CDRE_FIXED_WIDTH = "fwv" @@ -200,7 +199,6 @@ const ( CDRC = "cdrc" MASK_CHAR = "*" CONCATENATED_KEY_SEP = ":" - FORKED_CDR = "forked_cdr" UNIT_TEST = "UNIT_TEST" HDR_VAL_SEP = "/" MONETARY = "*monetary" @@ -211,19 +209,11 @@ const ( VOICE = "*voice" MAX_COST_FREE = "*free" MAX_COST_DISCONNECT = "*disconnect" - HOURS = "hours" - MINUTES = "minutes" - NANOSECONDS = "nanoseconds" SECONDS = "seconds" - OUT = "*out" - IN = "*in" META_OUT = "*out" META_ANY = "*any" - CDR_IMPORT = "cdr_import" - CDR_EXPORT = "cdr_export" ASR = "ASR" ACD = "ACD" - FILTER_REGEXP_TPL = "$1$2$3$4$5" TASKS_KEY = "tasks" ACTION_PLAN_PREFIX = "apl_" AccountActionPlansPrefix = "aap_" @@ -263,15 +253,9 @@ const ( StatQueuePrefix = "stq_" LoadIDPrefix = "lid_" LOADINST_KEY = "load_history" - SESSION_MANAGER_SOURCE = "SMR" - MEDIATOR_SOURCE = "MED" - CDRS_SOURCE = "CDRS" - SCHED_SOURCE = "SCH" - RATER_SOURCE = "RAT" CREATE_CDRS_TABLES_SQL = "create_cdrs_tables.sql" CREATE_TARIFFPLAN_TABLES_SQL = "create_tariffplan_tables.sql" TEST_SQL = "TEST_SQL" - DESTINATIONS_LOAD_THRESHOLD = 0.1 META_CONSTANT = "*constant" META_FILLER = "*filler" META_HANDLER = "*handler" @@ -286,8 +270,6 @@ const ( MetaSQSjsonMap = "*sqs_json_map" MetaKafkajsonMap = "*kafka_json_map" MetaS3jsonMap = "*s3_json_map" - NANO_MULTIPLIER = 1000000000 - CGR_AUTHORIZE = "CGR_AUTHORIZE" CONFIG_PATH = "/etc/cgrates/" DISCONNECT_CAUSE = "DisconnectCause" MetaKamFlatstore = "*kamailio_flatstore" @@ -303,315 +285,287 @@ const ( COUNTER_EVENT = "*event" COUNTER_BALANCE = "*balance" EVENT_NAME = "EventName" - COMPUTE_LCR = "ComputeLcr" - CGR_AUTHORIZATION = "CgrAuthorization" - CGR_SESSION_START = "CgrSessionStart" - CGR_SESSION_UPDATE = "CgrSessionUpdate" - CGR_SESSION_END = "CgrSessionEnd" - CGR_LCR_REQUEST = "CgrLcrRequest" // action trigger threshold types - TRIGGER_MIN_EVENT_COUNTER = "*min_event_counter" - TRIGGER_MIN_BALANCE_COUNTER = "*min_balance_counter" - TRIGGER_MAX_EVENT_COUNTER = "*max_event_counter" - TRIGGER_MAX_BALANCE_COUNTER = "*max_balance_counter" - TRIGGER_MIN_BALANCE = "*min_balance" - TRIGGER_MAX_BALANCE = "*max_balance" - TRIGGER_BALANCE_EXPIRED = "*balance_expired" - HIERARCHY_SEP = ">" - META_COMPOSED = "*composed" - META_USAGE_DIFFERENCE = "*usage_difference" - MetaDifference = "*difference" - MetaVariable = "*variable" - MetaCCUsage = "*cc_usage" - MetaValueExponent = "*value_exponent" - NegativePrefix = "!" - MatchStartPrefix = "^" - MatchGreaterThanOrEqual = ">=" - MatchLessThanOrEqual = "<=" - MatchGreaterThan = ">" - MatchLessThan = "<" - MatchEndPrefix = "$" - MetaGrouped = "*grouped" - MetaRaw = "*raw" - CreatedAt = "CreatedAt" - UpdatedAt = "UpdatedAt" - HandlerArgSep = "|" - FlagForceDuration = "fd" - NodeID = "NodeID" - ActiveGoroutines = "ActiveGoroutines" - MemoryUsage = "MemoryUsage" - Footprint = "Footprint" - RunningSince = "RunningSince" - GoVersion = "GoVersion" - SessionTTL = "SessionTTL" - SessionTTLMaxDelay = "SessionTTLMaxDelay" - SessionTTLLastUsed = "SessionTTLLastUsed" - SessionTTLUsage = "SessionTTLUsage" - HandlerSubstractUsage = "*substract_usage" - XML = "xml" - MetaGOBrpc = "*gob" - MetaJSONrpc = "*json" - MetaDateTime = "*datetime" - MetaMaskedDestination = "*masked_destination" - MetaUnixTimestamp = "*unix_timestamp" - MetaPostCDR = "*post_cdr" - MetaDumpToFile = "*dump_to_file" - NonTransactional = "" // used in transactional cache mechanism - EVT_ACCOUNT_BALANCE_MODIFIED = "ACCOUNT_BALANCE_MODIFIED" - EVT_ACTION_TRIGGER_FIRED = "ACTION_TRIGGER_FIRED" - EVT_ACTION_TIMING_FIRED = "ACTION_TRIGGER_FIRED" - SMAsterisk = "sm_asterisk" - DataDB = "data_db" - StorDB = "stor_db" - Cache = "cache" - NotFoundCaps = "NOT_FOUND" - NotCloneableCaps = "NOT_CLONEABLE" - ServerErrorCaps = "SERVER_ERROR" - MandatoryIEMissingCaps = "MANDATORY_IE_MISSING" - AttributesNotFoundCaps = "ATTRIBUTES_NOT_FOUND" - AttributesNotFound = "attributes not found" - UnsupportedCachePrefix = "unsupported cache prefix" - CDRSCtx = "cdrs" - MandatoryInfoMissing = "mandatory information missing" - UnsupportedServiceIDCaps = "UNSUPPORTED_SERVICE_ID" - ServiceManager = "service_manager" - ServiceAlreadyRunning = "service already running" - ServiceNotRunning = "service not running" - RunningCaps = "RUNNING" - StoppedCaps = "STOPPED" - SchedulerNotRunningCaps = "SCHEDULLER_NOT_RUNNING" - MetaScheduler = "*scheduler" - MetaCostDetails = "*cost_details" - MetaSessionsCosts = "*sessions_costs" - MetaAccounts = "*accounts" - MetaActionPlans = "*action_plans" - MetaActionTriggers = "*action_triggers" - MetaActions = "*actions" - MetaSharedGroups = "*shared_groups" - MetaRALs = "*rals" - MetaStats = "*stats" - MetaResponder = "*responder" - MetaCore = "*core" - MetaThresholds = "*thresholds" - MetaSuppliers = "*suppliers" - MetaAttributes = "*attributes" - MetaServiceManager = "*servicemanager" - MetaChargers = "*chargers" - MetaConfig = "*config" - MetaDispatchers = "*dispatchers" - MetaDispatcherHosts = "*dispatcher_hosts" - MetaFilters = "*filters" - MetaCDRs = "*cdrs" - MetaCaches = "*caches" - MetaGuardian = "*guardians" - Migrator = "migrator" - UnsupportedMigrationTask = "unsupported migration task" - NoStorDBConnection = "not connected to StorDB" - UndefinedVersion = "undefined version" - UnsupportedDB = "unsupported database" - ACCOUNT_SUMMARY = "AccountSummary" - TxtSuffix = ".txt" - JSNSuffix = ".json" - FormSuffix = ".form" - CSVSuffix = ".csv" - FWVSuffix = ".fwv" - CONTENT_JSON = "json" - CONTENT_FORM = "form" - CONTENT_TEXT = "text" - FileLockPrefix = "file_" - ActionsPoster = "act" - CDRPoster = "cdr" - MetaFileCSV = "*file_csv" - MetaFileFWV = "*file_fwv" - MetaFScsv = "*freeswitch_csv" - Accounts = "Accounts" - AccountService = "AccountS" - Actions = "Actions" - ActionPlans = "ActionPlans" - ActionTriggers = "ActionTriggers" - SharedGroups = "SharedGroups" - Timings = "Timings" - Rates = "Rates" - DestinationRates = "DestinationRates" - RatingPlans = "RatingPlans" - RatingProfiles = "RatingProfiles" - AccountActions = "AccountActions" - Resources = "Resources" - Stats = "Stats" - Filters = "Filters" - DispatcherProfiles = "DispatcherProfiles" - DispatcherHosts = "DispatcherHosts" - MetaEveryMinute = "*every_minute" - MetaHourly = "*hourly" - ID = "ID" - Thresholds = "Thresholds" - Suppliers = "Suppliers" - Attributes = "Attributes" - Chargers = "Chargers" - Dispatchers = "Dispatchers" - StatS = "Stats" - RALService = "RALs" - CostSource = "CostSource" - ExtraInfo = "ExtraInfo" - Meta = "*" - MetaSysLog = "*syslog" - MetaStdLog = "*stdout" - MetaNever = "*never" - EventType = "EventType" - EventSource = "EventSource" - AccountID = "AccountID" - ResourceID = "ResourceID" - TotalUsage = "TotalUsage" - StatID = "StatID" - BalanceType = "BalanceType" - BalanceID = "BalanceID" - Units = "Units" - AccountUpdate = "AccountUpdate" - BalanceUpdate = "BalanceUpdate" - StatUpdate = "StatUpdate" - ResourceUpdate = "ResourceUpdate" - CDR = "CDR" - CDRs = "CDRs" - ExpiryTime = "ExpiryTime" - AllowNegative = "AllowNegative" - Disabled = "Disabled" - Action = "Action" - MetaNow = "*now" - SessionsCosts = "SessionsCosts" - SessionSCosts = "SessionSCosts" - Timing = "Timing" - RQF = "RQF" - Resource = "Resource" - User = "User" - Subscribers = "Subscribers" - DerivedChargersV = "DerivedChargers" - CdrStats = "CdrStats" - Destinations = "Destinations" - ReverseDestinations = "ReverseDestinations" - LCR = "LCR" - RatingPlan = "RatingPlan" - RatingProfile = "RatingProfile" - MetaRatingPlans = "*ratingplans" - MetaRatingProfiles = "*ratingprofiles" - MetaReverseDestinations = "*reversedestinations" - MetaLCR = "*lcr" - MetaCdrStats = "*cdrstats" - MetaUsers = "*users" - MetaSubscribers = "*subscribers" - MetaDerivedChargersV = "*derivedchargers" - MetaStorDB = "*stordb" - MetaDataDB = "*datadb" - MetaWeight = "*weight" - MetaLeastCost = "*least_cost" - MetaHighestCost = "*highest_cost" - MetaQOS = "*qos" - MetaReas = "*reas" - MetaReds = "*reds" - Weight = "Weight" - Cost = "Cost" - RatingPlanID = "RatingPlanID" - MetaSessionS = "*sessions" - MetaDefault = "*default" - Error = "Error" - MetaCgreq = "*cgreq" - MetaCgrep = "*cgrep" - MetaCGRAReq = "*cgrareq" - MetaCGRRequest = "*cgrRequest" - MetaCGRReply = "*cgrReply" - CGR_ACD = "cgr_acd" - FilterIDs = "FilterIDs" - FieldName = "FieldName" - Initial = "Initial" - Substitute = "Substitute" - Append = "Append" - MetaRound = "*round" - Pong = "Pong" - MetaEventCost = "*event_cost" - MetaSuppliersEventCost = "*suppliers_event_cost" - MetaSuppliersIgnoreErrors = "*suppliers_ignore_errors" - Freeswitch = "freeswitch" - Kamailio = "kamailio" - Opensips = "opensips" - Asterisk = "asterisk" - SchedulerS = "SchedulerS" - MetaMultiply = "*multiply" - MetaDivide = "*divide" - MetaUrl = "*url" - MetaXml = "*xml" - ApiKey = "apikey" - MetaReq = "*req" - MetaVars = "*vars" - MetaRep = "*rep" - CGROriginHost = "cgr_originhost" - MetaInitiate = "*initiate" - MetaUpdate = "*update" - MetaTerminate = "*terminate" - MetaEvent = "*event" - MetaMessage = "*message" - MetaDryRun = "*dryrun" - Event = "Event" - EmptyString = "" - AgentRequest = "AgentRequest" - DynamicDataPrefix = "~" - AttrValueSep = "=" - ANDSep = "&" - PipeSep = "|" - MetaApp = "*app" - MetaAppID = "*appid" - MetaCmd = "*cmd" - MetaEnv = "*env:" // use in config for describing enviormant variables - MetaTemplate = "*template" - MetaCCA = "*cca" - MetaErr = "*err" - OriginRealm = "OriginRealm" - ProductName = "ProductName" - IdxStart = "[" - IdxEnd = "]" - MetaLog = "*log" - MetaRemoteHost = "*remote_host" - Local = "local" - TCP = "tcp" - CGRDebitInterval = "CGRDebitInterval" - Version = "Version" - MetaTenant = "*tenant" - ResourceUsage = "ResourceUsage" - MetaDuration = "*duration" - MetaLibPhoneNumber = "*libphonenumber" - MetaReload = "*reload" - MetaLoad = "*load" - MetaRemove = "*remove" - MetaClear = "*clear" - LoadIDs = "load_ids" - DNSAgent = "DNSAgent" - TLSNoCaps = "tls" - MetaRouteID = "*route_id" - MetaApiKey = "*api_key" - UsageID = "UsageID" - Status = "status" - Rcode = "Rcode" - Replacement = "Replacement" - Regexp = "Regexp" - Order = "Order" - Preference = "Preference" - Flags = "Flags" - Service = "Service" - MetaSuppliersLimit = "*suppliers_limit" - MetaSuppliersOffset = "*suppliers_offset" - ActiveSessionPrefix = "act" - PasiveSessionPrefix = "psv" - ApierV = "ApierV" - MetaApier = "*apier" - CGREventString = "CGREvent" - MetaPing = "*ping" - MetaTextPlain = "*text_plain" - MetaIgnoreErrors = "*ignore_errors" - MetaRelease = "*release" - MetaAllocate = "*allocate" - MetaAuthorize = "*authorize" - MetaInit = "*init" - MetaRatingPlanCost = "*rating_plan_cost" - RatingPlanIDs = "RatingPlanIDs" - MetaAccount = "*account" + TRIGGER_MIN_EVENT_COUNTER = "*min_event_counter" + TRIGGER_MIN_BALANCE_COUNTER = "*min_balance_counter" + TRIGGER_MAX_EVENT_COUNTER = "*max_event_counter" + TRIGGER_MAX_BALANCE_COUNTER = "*max_balance_counter" + TRIGGER_MIN_BALANCE = "*min_balance" + TRIGGER_MAX_BALANCE = "*max_balance" + TRIGGER_BALANCE_EXPIRED = "*balance_expired" + HIERARCHY_SEP = ">" + META_COMPOSED = "*composed" + META_USAGE_DIFFERENCE = "*usage_difference" + MetaDifference = "*difference" + MetaVariable = "*variable" + MetaCCUsage = "*cc_usage" + MetaValueExponent = "*value_exponent" + NegativePrefix = "!" + MatchStartPrefix = "^" + MatchGreaterThanOrEqual = ">=" + MatchLessThanOrEqual = "<=" + MatchGreaterThan = ">" + MatchLessThan = "<" + MatchEndPrefix = "$" + MetaRaw = "*raw" + CreatedAt = "CreatedAt" + UpdatedAt = "UpdatedAt" + HandlerArgSep = "|" + NodeID = "NodeID" + ActiveGoroutines = "ActiveGoroutines" + MemoryUsage = "MemoryUsage" + Footprint = "Footprint" + RunningSince = "RunningSince" + GoVersion = "GoVersion" + SessionTTL = "SessionTTL" + SessionTTLMaxDelay = "SessionTTLMaxDelay" + SessionTTLLastUsed = "SessionTTLLastUsed" + SessionTTLUsage = "SessionTTLUsage" + HandlerSubstractUsage = "*substract_usage" + XML = "xml" + MetaGOBrpc = "*gob" + MetaJSONrpc = "*json" + MetaDateTime = "*datetime" + MetaMaskedDestination = "*masked_destination" + MetaUnixTimestamp = "*unix_timestamp" + MetaPostCDR = "*post_cdr" + MetaDumpToFile = "*dump_to_file" + NonTransactional = "" // used in transactional cache mechanism + SMAsterisk = "sm_asterisk" + DataDB = "data_db" + StorDB = "stor_db" + Cache = "cache" + NotFoundCaps = "NOT_FOUND" + ServerErrorCaps = "SERVER_ERROR" + MandatoryIEMissingCaps = "MANDATORY_IE_MISSING" + UnsupportedCachePrefix = "unsupported cache prefix" + CDRSCtx = "cdrs" + MandatoryInfoMissing = "mandatory information missing" + UnsupportedServiceIDCaps = "UNSUPPORTED_SERVICE_ID" + ServiceManager = "service_manager" + ServiceAlreadyRunning = "service already running" + ServiceNotRunning = "service not running" + RunningCaps = "RUNNING" + StoppedCaps = "STOPPED" + SchedulerNotRunningCaps = "SCHEDULLER_NOT_RUNNING" + MetaScheduler = "*scheduler" + MetaCostDetails = "*cost_details" + MetaSessionsCosts = "*sessions_costs" + MetaAccounts = "*accounts" + MetaActionPlans = "*action_plans" + MetaActionTriggers = "*action_triggers" + MetaActions = "*actions" + MetaSharedGroups = "*shared_groups" + MetaRALs = "*rals" + MetaStats = "*stats" + MetaResponder = "*responder" + MetaCore = "*core" + MetaThresholds = "*thresholds" + MetaSuppliers = "*suppliers" + MetaAttributes = "*attributes" + MetaServiceManager = "*servicemanager" + MetaChargers = "*chargers" + MetaConfig = "*config" + MetaDispatchers = "*dispatchers" + MetaDispatcherHosts = "*dispatcher_hosts" + MetaFilters = "*filters" + MetaCDRs = "*cdrs" + MetaCaches = "*caches" + MetaGuardian = "*guardians" + Migrator = "migrator" + UnsupportedMigrationTask = "unsupported migration task" + NoStorDBConnection = "not connected to StorDB" + UndefinedVersion = "undefined version" + UnsupportedDB = "unsupported database" + TxtSuffix = ".txt" + JSNSuffix = ".json" + FormSuffix = ".form" + CSVSuffix = ".csv" + FWVSuffix = ".fwv" + CONTENT_JSON = "json" + CONTENT_FORM = "form" + CONTENT_TEXT = "text" + FileLockPrefix = "file_" + ActionsPoster = "act" + CDRPoster = "cdr" + MetaFileCSV = "*file_csv" + MetaFileFWV = "*file_fwv" + MetaFScsv = "*freeswitch_csv" + Accounts = "Accounts" + AccountService = "AccountS" + Actions = "Actions" + ActionPlans = "ActionPlans" + ActionTriggers = "ActionTriggers" + SharedGroups = "SharedGroups" + Timings = "Timings" + Rates = "Rates" + DestinationRates = "DestinationRates" + RatingPlans = "RatingPlans" + RatingProfiles = "RatingProfiles" + AccountActions = "AccountActions" + Resources = "Resources" + Stats = "Stats" + Filters = "Filters" + DispatcherProfiles = "DispatcherProfiles" + DispatcherHosts = "DispatcherHosts" + MetaEveryMinute = "*every_minute" + MetaHourly = "*hourly" + ID = "ID" + Thresholds = "Thresholds" + Suppliers = "Suppliers" + Attributes = "Attributes" + Chargers = "Chargers" + Dispatchers = "Dispatchers" + StatS = "Stats" + RALService = "RALs" + CostSource = "CostSource" + ExtraInfo = "ExtraInfo" + Meta = "*" + MetaSysLog = "*syslog" + MetaStdLog = "*stdout" + EventType = "EventType" + EventSource = "EventSource" + AccountID = "AccountID" + ResourceID = "ResourceID" + TotalUsage = "TotalUsage" + StatID = "StatID" + BalanceType = "BalanceType" + BalanceID = "BalanceID" + Units = "Units" + AccountUpdate = "AccountUpdate" + BalanceUpdate = "BalanceUpdate" + StatUpdate = "StatUpdate" + ResourceUpdate = "ResourceUpdate" + CDR = "CDR" + CDRs = "CDRs" + ExpiryTime = "ExpiryTime" + AllowNegative = "AllowNegative" + Disabled = "Disabled" + Action = "Action" + MetaNow = "*now" + SessionSCosts = "SessionSCosts" + Timing = "Timing" + RQF = "RQF" + Resource = "Resource" + User = "User" + Subscribers = "Subscribers" + DerivedChargersV = "DerivedChargers" + Destinations = "Destinations" + ReverseDestinations = "ReverseDestinations" + RatingPlan = "RatingPlan" + RatingProfile = "RatingProfile" + MetaRatingPlans = "*ratingplans" + MetaRatingProfiles = "*ratingprofiles" + MetaReverseDestinations = "*reversedestinations" + MetaUsers = "*users" + MetaSubscribers = "*subscribers" + MetaDerivedChargersV = "*derivedchargers" + MetaStorDB = "*stordb" + MetaDataDB = "*datadb" + MetaWeight = "*weight" + MetaLeastCost = "*least_cost" + MetaHighestCost = "*highest_cost" + MetaQOS = "*qos" + MetaReas = "*reas" + MetaReds = "*reds" + Weight = "Weight" + Cost = "Cost" + RatingPlanID = "RatingPlanID" + MetaSessionS = "*sessions" + MetaDefault = "*default" + Error = "Error" + MetaCgreq = "*cgreq" + MetaCgrep = "*cgrep" + MetaCGRAReq = "*cgrareq" + CGR_ACD = "cgr_acd" + FilterIDs = "FilterIDs" + FieldName = "FieldName" + MetaRound = "*round" + Pong = "Pong" + MetaEventCost = "*event_cost" + MetaSuppliersEventCost = "*suppliers_event_cost" + MetaSuppliersIgnoreErrors = "*suppliers_ignore_errors" + Freeswitch = "freeswitch" + Kamailio = "kamailio" + Opensips = "opensips" + Asterisk = "asterisk" + SchedulerS = "SchedulerS" + MetaMultiply = "*multiply" + MetaDivide = "*divide" + MetaUrl = "*url" + MetaXml = "*xml" + ApiKey = "apikey" + MetaReq = "*req" + MetaVars = "*vars" + MetaRep = "*rep" + CGROriginHost = "cgr_originhost" + MetaInitiate = "*initiate" + MetaUpdate = "*update" + MetaTerminate = "*terminate" + MetaEvent = "*event" + MetaMessage = "*message" + MetaDryRun = "*dryrun" + Event = "Event" + EmptyString = "" + DynamicDataPrefix = "~" + AttrValueSep = "=" + ANDSep = "&" + PipeSep = "|" + MetaApp = "*app" + MetaAppID = "*appid" + MetaCmd = "*cmd" + MetaEnv = "*env:" // use in config for describing enviormant variables + MetaTemplate = "*template" + MetaCCA = "*cca" + MetaErr = "*err" + OriginRealm = "OriginRealm" + ProductName = "ProductName" + IdxStart = "[" + IdxEnd = "]" + MetaLog = "*log" + MetaRemoteHost = "*remote_host" + Local = "local" + TCP = "tcp" + CGRDebitInterval = "CGRDebitInterval" + Version = "Version" + MetaTenant = "*tenant" + ResourceUsage = "ResourceUsage" + MetaDuration = "*duration" + MetaLibPhoneNumber = "*libphonenumber" + MetaReload = "*reload" + MetaLoad = "*load" + MetaRemove = "*remove" + MetaClear = "*clear" + LoadIDs = "load_ids" + DNSAgent = "DNSAgent" + TLSNoCaps = "tls" + MetaRouteID = "*route_id" + MetaApiKey = "*api_key" + UsageID = "UsageID" + Rcode = "Rcode" + Replacement = "Replacement" + Regexp = "Regexp" + Order = "Order" + Preference = "Preference" + Flags = "Flags" + Service = "Service" + MetaSuppliersLimit = "*suppliers_limit" + MetaSuppliersOffset = "*suppliers_offset" + ActiveSessionPrefix = "act" + PasiveSessionPrefix = "psv" + ApierV = "ApierV" + MetaApier = "*apier" + CGREventString = "CGREvent" + MetaPing = "*ping" + MetaTextPlain = "*text_plain" + MetaIgnoreErrors = "*ignore_errors" + MetaRelease = "*release" + MetaAllocate = "*allocate" + MetaAuthorize = "*authorize" + MetaInit = "*init" + MetaRatingPlanCost = "*rating_plan_cost" + RatingPlanIDs = "RatingPlanIDs" + MetaAccount = "*account" ) // Migrator Action @@ -773,6 +727,7 @@ const ( MetaBroadcast = "*broadcast" MetaNext = "*next" MetaRoundRobin = "*round_robin" + MetaRatio = "*ratio" ThresholdSv1 = "ThresholdSv1" StatSv1 = "StatSv1" ResourceSv1 = "ResourceSv1" @@ -1073,11 +1028,6 @@ const ( SchedulerSv1Reload = "SchedulerSv1.Reload" ) -// Cdrc -const ( - CdrcPing = "Cdrc.Ping" -) - //cgr_ variables const ( CGR_ACCOUNT = "cgr_account"