skip reinterpret direction for conversations (#430)

netobserv · Jun 8, 2023 · a05a86d · a05a86d
1 parent d25d469
commit a05a86d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/pipeline/transform/transform_network.go b/pkg/pipeline/transform/transform_network.go
@@ -151,7 +151,10 @@ func (n *Network) Transform(inputEntry config.GenericMap) (config.GenericMap, bo
 				}
 			}
 		case api.OpReinterpretDirection:
-			reinterpretDirection(outputEntry, &n.DirectionInfo)
+			// only reinterpret direction on flowlogs
+			if rt, ok := outputEntry["_RecordType"]; !ok || rt == "flowLog" {
+				reinterpretDirection(outputEntry, &n.DirectionInfo)
+			}
 		case api.OpAddIPCategory:
 			if strIP, ok := outputEntry[rule.Input].(string); ok {
 				cat, ok := n.ipCatCache.GetCacheEntry(strIP)