Make sure new cast options also work on metadata fields

telenornms · Oct 9, 2024 · 0fae1f3 · 0fae1f3
1 parent d1d4159
commit 0fae1f3
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/transformer/cast.go b/transformer/cast.go
@@ -256,20 +256,20 @@ func (cast *Cast) Transform(c *skogul.Container) error {
 		}
 
 		for _, value := range cast.MetadataBlobsToStrings {
-			if c.Metrics[mi].Data[value] != nil {
-				_, ok := c.Metrics[mi].Data[value].(string)
+			if c.Metrics[mi].Metadata[value] != nil {
+				_, ok := c.Metrics[mi].Metadata[value].(string)
 				if ok {
 					continue
 				}
-				c.Metrics[mi].Data[value] = fmt.Sprintf("%s", c.Metrics[mi].Data[value])
+				c.Metrics[mi].Metadata[value] = fmt.Sprintf("%s", c.Metrics[mi].Metadata[value])
 			}
 		}
 		for _, value := range cast.MetadataStringsToBlobs {
-			if c.Metrics[mi].Data[value] != nil {
-				cpy := fmt.Sprintf("%s", c.Metrics[mi].Data[value])
-				delete(c.Metrics[mi].Data, value)
-				c.Metrics[mi].Data[value] = make([]byte, len(cpy))
-				c.Metrics[mi].Data[value] = []byte(cpy)
+			if c.Metrics[mi].Metadata[value] != nil {
+				cpy := fmt.Sprintf("%s", c.Metrics[mi].Metadata[value])
+				delete(c.Metrics[mi].Metadata, value)
+				c.Metrics[mi].Metadata[value] = make([]byte, len(cpy))
+				c.Metrics[mi].Metadata[value] = []byte(cpy)
 			}
 		}
 	}