uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Changed FileName variable for ers

Browse Source
This commit is contained in:
adi
2022-11-18 16:08:46 +02:00
committed by Dan Christian Bogos
parent b1f6028380
commit 1fe0dcbe9a
6 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ers/filecsv.go
View File

@@ -139,7 +139,7 @@ func (rdr *CSVFileER) processFile(fPath, fName string) (err error) {
rowNr := 0 // This counts the rows in the file, not really number of CDRs
evsPosted := 0
timeStart := time.Now()
reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)}
reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)}
for {
var record []string
if record, err = csvReader.Read(); err != nil {

2
ers/filefwv.go
View File

@@ -139,7 +139,7 @@ func (rdr *FWVFileER) processFile(fPath, fName string) (err error) {
rowNr := 0 // This counts the rows in the file, not really number of CDRs
evsPosted := 0
timeStart := time.Now()
reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)}
reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)}
for {
var hasHeader, hasTrailer bool

2
ers/filexml.go
View File

@@ -137,7 +137,7 @@ func (rdr *XMLFileER) processFile(fPath, fName string) (err error) {
rowNr := 0 // This counts the rows in the file, not really number of CDRs
evsPosted := 0
timeStart := time.Now()
reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)}
reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)}
for _, xmlElmt := range xmlElmts {
rowNr++ // increment the rowNr after checking if it's not the end of file
agReq := agents.NewAgentRequest(

2
ers/flatstore.go
View File

@@ -146,7 +146,7 @@ func (rdr *FlatstoreER) processFile(fPath, fName string) (err error) {
rowNr := 0 // This counts the rows in the file, not really number of CDRs
evsPosted := 0
timeStart := time.Now()
reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)}
reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)}
for {
var record []string
if record, err = csvReader.Read(); err != nil {

2
ers/partial_csv.go
View File

@@ -153,7 +153,7 @@ func (rdr *PartialCSVFileER) processFile(fPath, fName string) (err error) {
rowNr := 0 // This counts the rows in the file, not really number of CDRs
evsPosted := 0
timeStart := time.Now()
reqVars := utils.NavigableMap2{utils.FileName: utils.NewNMData(fName)}
reqVars := utils.NavigableMap2{utils.MetaFileName: utils.NewNMData(fName)}
for {
var record []string
if record, err = csvReader.Read(); err != nil {

2
utils/consts.go
View File

@@ -665,7 +665,7 @@ const (
MetaDiamreq = "*diamreq"
MetaGroup = "*group"
InternalRPCSet = "InternalRPCSet"
FileName = "FileName"
MetaFileName = "*fileName"
MetaBusy = "*busy"
MetaQueue = "*queue"
MetaRounding = "*rounding"