From 1721a4ff7df253644e037342e70df2a3bb6067aa Mon Sep 17 00:00:00 2001 From: Dmitri Dolguikh Date: Tue, 16 Jun 2026 17:03:49 +0200 Subject: [PATCH] fix event aggregation test Signed-off-by: Dmitri Dolguikh --- client/internal/netflow/store/event_aggregation_test.go | 2 +- client/internal/netflow/store/memory.go | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/client/internal/netflow/store/event_aggregation_test.go b/client/internal/netflow/store/event_aggregation_test.go index 8064e0e4a..411177331 100644 --- a/client/internal/netflow/store/event_aggregation_test.go +++ b/client/internal/netflow/store/event_aggregation_test.go @@ -176,7 +176,7 @@ func generateEvents(srcIp, dstIp netip.Addr, dstPort uint16, eventTypes []types. Timestamp: inEvents[0].Timestamp, EventFields: types.EventFields{ FlowID: flowId, - Type: inEvents[0].Type, + Type: types.TypeUnknown, Protocol: inEvents[0].Protocol, RuleID: []byte("rule-id-1"), Direction: inEvents[0].Direction, diff --git a/client/internal/netflow/store/memory.go b/client/internal/netflow/store/memory.go index fa2a0a3e1..b264bfd4a 100644 --- a/client/internal/netflow/store/memory.go +++ b/client/internal/netflow/store/memory.go @@ -134,7 +134,6 @@ func (am *AggregatingMemory) GetAggregatedEvents() []*types.Event { if aggregatedEvent.Timestamp.Compare(v.Timestamp) > 0 { aggregatedEvent.Timestamp = v.Timestamp aggregatedEvent.ID = v.ID - aggregatedEvent.Type = v.Type } }