Fix adding of missing ID

Fixes: #150
magnusbaeck · Dec 14, 2021 · 5ee6436 · 5ee6436
1 parent 69c0af2
commit 5ee6436
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/internal/daemon/logstashconfig/file.go b/internal/daemon/logstashconfig/file.go
@@ -205,7 +205,7 @@ func (v *validator) walk(c *astutil.Cursor) {
 	if err != nil {
 		if v.addMissingID {
 			plugin := c.Plugin()
-			id = fmt.Sprintf("%s-%d", name, v.count)
+			id = fmt.Sprintf("id_missing_%0000d", v.count)
 			plugin.Attributes = append(plugin.Attributes, ast.NewStringAttribute("id", id, ast.DoubleQuoted))
 
 			c.Replace(plugin)

diff --git a/internal/daemon/pipeline/pipeline.go b/internal/daemon/pipeline/pipeline.go
@@ -156,7 +156,7 @@ func (a Archive) ZipWithPreprocessor(addMissingID bool, preprocess func([]byte)
 				outputs[id] += count
 			}
 
-			_, err = f.Write(body)
+			_, err = f.Write(configFile.Body)
 			if err != nil {
 				return nil, nil, err
 			}