fixing writer

Signed-off-by: Jaydip Gabani <[email protected]>

pkg/pubsub/diskwriter/diskwriter.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"log"
 	"os"
 	"path"
 	"syscall"
@@ -39,7 +38,7 @@ func (r *DiskWriter) Publish(_ context.Context, data interface{}, _ string) erro
 	if r.file == nil {
         // Open a new file and acquire a lock
         filePath := path.Join(r.Path, "violations.txt")
-        file, err := os.OpenFile(filePath, os.O_CREATE|os.O_WRONLY|os.O_TRUNC, 0644)
+        file, err := os.OpenFile(filePath, os.O_CREATE|os.O_WRONLY, 0644)
         if err != nil {
             return fmt.Errorf("failed to open file: %w", err)
         }
@@ -53,6 +52,11 @@ func (r *DiskWriter) Publish(_ context.Context, data interface{}, _ string) erro
         }
 
 		r.file = file
+		err = r.file.Truncate(0)
+		if err != nil {
+			r.file = nil
+            return fmt.Errorf("failed to truncate file: %w", err)
+        }
 	}
 
 	_, err = r.file.WriteString(string(jsonData) + "\n")