Use flags list

jotak · jotak · commit 974b3f54d550 · 2024-11-14T11:05:34.000+01:00
diff --git a/pkg/pipeline/transform/transform_network.go b/pkg/pipeline/transform/transform_network.go
@@ -22,7 +22,6 @@ import (
 	"net"
 	"os"
 	"strconv"
-	"strings"
 	"time"
 
 	"github.com/netobserv/flowlogs-pipeline/pkg/api"
@@ -146,7 +145,7 @@ func (n *Network) Transform(inputEntry config.GenericMap) (config.GenericMap, bo
 			if anyFlags, ok := outputEntry[rule.DecodeTCPFlags.Input]; ok && anyFlags != nil {
 				if flags, ok := anyFlags.(uint16); ok {
 					flags := util.DecodeTCPFlags(flags)
-					outputEntry[rule.DecodeTCPFlags.Output] = strings.Join(flags, ",")
+					outputEntry[rule.DecodeTCPFlags.Output] = flags
 				}
 			}
 

Original file line number	Diff line number	Diff line change
`@@ -22,7 +22,6 @@ import (`
`22`	`22`	`"net"`
`23`	`23`	`"os"`
`24`	`24`	`"strconv"`
`25`		`- "strings"`
`26`	`25`	`"time"`
`27`	`26`
`28`	`27`	`"github.com/netobserv/flowlogs-pipeline/pkg/api"`
`@@ -146,7 +145,7 @@ func (n *Network) Transform(inputEntry config.GenericMap) (config.GenericMap, bo`
`146`	`145`	`if anyFlags, ok := outputEntry[rule.DecodeTCPFlags.Input]; ok && anyFlags != nil {`
`147`	`146`	`if flags, ok := anyFlags.(uint16); ok {`
`148`	`147`	`flags := util.DecodeTCPFlags(flags)`
`149`		`- outputEntry[rule.DecodeTCPFlags.Output] = strings.Join(flags, ",")`
	`148`	`+ outputEntry[rule.DecodeTCPFlags.Output] = flags`
`150`	`149`	`}`
`151`	`150`	`}`
`152`	`151`