From 41728e690ae82012dca5522da35e3defb204f705 Mon Sep 17 00:00:00 2001
From: Trial97 <alexandru.tripon@itsyscom.com>
Date: Sun, 17 Nov 2019 14:06:55 +0200
Subject: [PATCH] Updated EventReader for CSV files to read only files with
 extension .csv

---
 ers/filecsv.go | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/ers/filecsv.go b/ers/filecsv.go
index 60826c1ed..68d123a49 100644
--- a/ers/filecsv.go
+++ b/ers/filecsv.go
@@ -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)
 			}