From bdb24e72ab2f664b7fd14b1bf5240720f0c88c5d Mon Sep 17 00:00:00 2001
From: "Sascha L. Teichmann" <sascha.teichmann@intevation.de>
Date: Tue, 2 Aug 2022 22:12:56 +0200
Subject: [PATCH] Ensure that interims.csv is deleted as soon as the last entry
 is removed from it.

---
 cmd/csaf_aggregator/interim.go | 18 ++++++++----------
 1 file changed, 8 insertions(+), 10 deletions(-)

diff --git a/cmd/csaf_aggregator/interim.go b/cmd/csaf_aggregator/interim.go
index 7ca0108..5cc32ad 100644
--- a/cmd/csaf_aggregator/interim.go
+++ b/cmd/csaf_aggregator/interim.go
@@ -221,16 +221,14 @@ func (w *worker) interimWork(wg *sync.WaitGroup, jobs <-chan *interimJob) {
 				// a greater interims interval later.
 				notFinalized = append(notFinalized, olds...)
 
-				if len(notFinalized) > 0 {
-					// We want to write in the transaction folder.
-					dst, err := tx.Dst()
-					if err != nil {
-						return err
-					}
-					interCSV := filepath.Join(dst, label, interimsCSV)
-					if err := writeInterims(interCSV, notFinalized); err != nil {
-						return err
-					}
+				// We want to write in the transaction folder.
+				dst, err := tx.Dst()
+				if err != nil {
+					return err
+				}
+				ninterCSV := filepath.Join(dst, label, interimsCSV)
+				if err := writeInterims(ninterCSV, notFinalized); err != nil {
+					return err
 				}
 			}
 			return tx.commit()