address pr comments

elastic · Sep 28, 2023 · 35de580 · 35de580
1 parent e0327b6
commit 35de580
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 4 deletions.
diff --git a/libbeat/processors/cache/config.go b/libbeat/processors/cache/config.go
@@ -103,7 +103,7 @@ type memConfig struct {
 
 type fileConfig struct {
 	ID            string        `config:"id"`
-	WriteOutEvery time.Duration `config:"write_frequency"`
+	WriteOutEvery time.Duration `config:"write_interval"`
 }
 
 func (cfg *storeConfig) Validate() error {

diff --git a/libbeat/processors/cache/config_test.go b/libbeat/processors/cache/config_test.go
@@ -48,7 +48,7 @@ put:
 backend:
   file:
     id: aidmaster
-    write_frequency: 15m
+    write_interval: 15m
 put:
   ttl: 168h
   key_field: crowdstrike.aid

diff --git a/libbeat/processors/cache/file_store.go b/libbeat/processors/cache/file_store.go
@@ -169,7 +169,12 @@ func (c *fileStore) readState() {
 		err = dec.Decode(&e)
 		if err != nil {
 			if err != io.EOF {
-				c.log.Errorw("failed to read state element", "error", err)
+				switch err := err.(type) {
+				case *json.SyntaxError:
+					c.log.Errorw("failed to read state element", "error", err, "path", c.path, "offset", err.Offset)
+				default:
+					c.log.Errorw("failed to read state element", "error", err, "path", c.path)
+				}
 			}
 			break
 		}
@@ -219,7 +224,7 @@ func (c *fileStore) writeState(final bool) {
 		}
 		return
 	}
-	f, err := os.CreateTemp("", "")
+	f, err := os.CreateTemp(filepath.Dir(c.path), "")
 	if err != nil {
 		c.log.Errorw("failed to open file to write state", "error", err)
 		return
@@ -232,6 +237,11 @@ func (c *fileStore) writeState(final bool) {
 	}
 	tmp := f.Name()
 	defer func() {
+		err = f.Sync()
+		if err != nil {
+			c.log.Errorw("failed to sync file after writing state", "error", err)
+			return
+		}
 		err = f.Close()
 		if err != nil {
 			c.log.Errorw("failed to close file after writing state", "error", err)