diff --git a/cdrc/csv.go b/cdrc/csv.go index 78fde3964..207c6de28 100644 --- a/cdrc/csv.go +++ b/cdrc/csv.go @@ -110,6 +110,9 @@ func (self *CsvRecordsProcessor) processRecord(record []string) ([]*engine.CDR, if err != nil { return nil, err } + if tenant == "" { + tenant = config.CgrConfig().GeneralCfg().DefaultTenant + } // Make sure filters are matching if len(cdrcCfg.Filters) != 0 { if pass, err := self.filterS.Pass(tenant, diff --git a/cdrc/fwv.go b/cdrc/fwv.go index 5e5114f37..db63ce8b5 100644 --- a/cdrc/fwv.go +++ b/cdrc/fwv.go @@ -121,6 +121,9 @@ func (self *FwvRecordsProcessor) ProcessNextRecord() ([]*engine.CDR, error) { if err != nil { return nil, err } + if tenant == "" { + tenant = config.CgrConfig().GeneralCfg().DefaultTenant + } if len(cdrcCfg.Filters) != 0 { if pass, err := self.filterS.Pass(tenant, cdrcCfg.Filters, fwvProvider); err != nil || !pass { diff --git a/cdrc/xml.go b/cdrc/xml.go index d46d70872..d5c2b1319 100644 --- a/cdrc/xml.go +++ b/cdrc/xml.go @@ -121,6 +121,9 @@ func (xmlProc *XMLRecordsProcessor) ProcessNextRecord() (cdrs []*engine.CDR, err if err != nil { return nil, err } + if tenant == "" { + tenant = config.CgrConfig().GeneralCfg().DefaultTenant + } if len(cdrcCfg.Filters) != 0 { if pass, err := xmlProc.filterS.Pass(tenant, cdrcCfg.Filters, xmlProvider); err != nil || !pass { diff --git a/data/conf/samples/cdrcxmlwithfilter/cgrates.json b/data/conf/samples/cdrcxmlwithfilter/cgrates.json index 2de0c8351..620c2a29c 100755 --- a/data/conf/samples/cdrcxmlwithfilter/cgrates.json +++ b/data/conf/samples/cdrcxmlwithfilter/cgrates.json @@ -29,7 +29,7 @@ "cdr_in_dir": "/tmp/cdrcxmlwithfilters/xmlit1/in", "cdr_out_dir": "/tmp/cdrcxmlwithfilters/xmlit1/out", "cdr_path": "broadWorksCDR.cdrData", - "cdr_source_id": "xmlit1", + "cdr_source_id": "xmlit1", "filters": ["*string:~broadWorksCDR.cdrData.basicModule.userNumber:1002","*string:~broadWorksCDR.cdrData.headerModule.type:Normal"], "content_fields":[ // import content_fields template, id will match internally CDR field, in case of .csv value will be represented by index of the field value {"tag": "TOR", "field_id": "ToR", "type": "*composed", "value": "*voice", "mandatory": true}, @@ -46,54 +46,54 @@ ], }, { - "id": "msw_xml", // identifier of the CDRC runner - "enabled": true, // enable CDR client functionality - "cdr_format": "xml", // CDR file format