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

Updated EventReader for CSV files to read only files with extension .csv

Browse Source
This commit is contained in:
Trial97
2019-11-17 14:06:55 +02:00
committed by Dan Christian Bogos
parent 8020fa1614
commit 41728e690a
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
ers/filecsv.go
View File

@@ -91,13 +91,16 @@ func (rdr *CSVFileER) Serve() (err error) {
}
filesInDir, _ := ioutil.ReadDir(rdr.rdrDir)
for _, file := range filesInDir {
go func() {
if err := rdr.processFile(rdr.rdrDir, file.Name()); err != nil {
if !strings.HasSuffix(file.Name(), utils.CSVSuffix) { // hardcoded file extension for csv event reader
continue // used in order to filter the files from directory
}
go func(fileName string) {
if err := rdr.processFile(rdr.rdrDir, fileName); err != nil {
utils.Logger.Warning(
fmt.Sprintf("<%s> processing file %s, error: %s",
utils.ERs, file, err.Error()))
utils.ERs, fileName, err.Error()))
}
}()
}(file.Name())
}
time.Sleep(rdr.Config().RunDelay)
}