Interface name wasn't populated yet so add func to find ifname

Signed-off-by: Mohamed Mahmoud <[email protected]>

pkg/flow/deduper.go

@@ -7,6 +7,7 @@ import (
 	"github.com/sirupsen/logrus"
 
 	"github.com/netobserv/netobserv-ebpf-agent/pkg/ebpf"
+	"github.com/netobserv/netobserv-ebpf-agent/pkg/utils"
 )
 
 var dlog = logrus.WithField("component", "flow/Deduper")
@@ -89,8 +90,11 @@ func (c *deduperCache) checkDupe(r *Record, justMark, mergeDup bool, fwd *[]*Rec
 				*fwd = append(*fwd, r)
 			}
 			if mergeDup {
-				mergeEntry[r.Interface] = r.Id.Direction
+				ifName := utils.GetInterfaceName(r.Id.IfIndex)
+				mergeEntry[ifName] = r.Id.Direction
 				*fEntry.dupList = append(*fEntry.dupList, mergeEntry)
+				dlog.Debugf("add entry to merge list interface %s dir %d count %d",
+					ifName, r.Id.Direction, len(*fEntry.dupList))
 			}
 			return
 		}
@@ -106,7 +110,8 @@ func (c *deduperCache) checkDupe(r *Record, justMark, mergeDup bool, fwd *[]*Rec
 		expiryTime: timeNow().Add(c.expire),
 	}
 	if mergeDup {
-		mergeEntry[r.Interface] = r.Id.Direction
+		ifName := utils.GetInterfaceName(r.Id.IfIndex)
+		mergeEntry[ifName] = r.Id.Direction
 		r.DupList = append(r.DupList, mergeEntry)
 		e.dupList = &r.DupList
 	}

pkg/utils/utils.go

@@ -91,3 +91,11 @@ func utsnameStr[T int8 | uint8](in []T) string {
 	}
 	return string(out)
 }
+
+func GetInterfaceName(ifIndex uint32) string {
+	iface, err := net.InterfaceByIndex(int(ifIndex))
+	if err != nil {
+		return ""
+	}
+	return iface.Name
+}