From 637e0f935fae046368371e0573fb7f1977207eb2 Mon Sep 17 00:00:00 2001
From: ionutboangiu <ionut.boangiu@itsyscom.com>
Date: Mon, 16 Jan 2023 18:37:43 +0200
Subject: [PATCH] Implement fix for fwv single file processing

---
 ers/filefwv.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/ers/filefwv.go b/ers/filefwv.go
index 8d4c5bad9..ea9cc280b 100644
--- a/ers/filefwv.go
+++ b/ers/filefwv.go
@@ -176,6 +176,9 @@ func (rdr *FWVFileER) processFile(fPath, fName string) (err error) {
 				continue
 			}
 		}
+		if rdr.offset >= rdr.trailerOffset {
+			break
+		}
 
 		buf := make([]byte, rdr.lineLen)
 		if nRead, err := file.Read(buf); err != nil {
@@ -224,7 +227,7 @@ func (rdr *FWVFileER) processFile(fPath, fName string) (err error) {
 			return
 		}
 	}
-
+	rdr.offset = 0
 	utils.Logger.Info(
 		fmt.Sprintf("%s finished processing file <%s>. Total records processed: %d, events posted: %d, run duration: %s",
 			utils.ERs, absPath, rowNr, evsPosted, time.Now().Sub(timeStart)))