fix(backend, transport): enable packet pool

Author: vasyl-ks

backend/pkg/transport/packet/data/decoder.go

@@ -35,8 +35,7 @@ func (decoder *Decoder) Decode(id abstraction.PacketId, reader io.Reader) (abstr
 		return nil, ErrUnexpectedId{Id: id}
 	}
 
-	//packet := GetPacket(id)
-	packet := NewPacket(id)
+	packet := GetPacket(id)
 	for _, value := range descriptor {
 		val, err := value.Decode(decoder.endianness, reader)
 		if err != nil {

backend/pkg/transport/transport.go

@@ -260,9 +260,9 @@ func (transport *Transport) readLoopTCPConn(conn net.Conn, logger zerolog.Logger
 			logger.Trace().Type("type", packet).Msg("packet")
 			transport.api.Notification(NewPacketNotification(packet, from, to, time.Now()))
 
-			//if dataPacket, ok := packet.(*data.Packet); ok {
-			//	data.ReleasePacket(dataPacket)
-			//}
+			if dataPacket, ok := packet.(*data.Packet); ok {
+				data.ReleasePacket(dataPacket)
+			}
 		}
 	}()
 }
@@ -469,9 +469,9 @@ func (transport *Transport) handleUDPPacket(udpPacket udp.Packet) {
 	// Send notification
 	transport.api.Notification(NewPacketNotification(packet, srcAddr, dstAddr, udpPacket.Timestamp))
 
-	//if dataPacket, ok := packet.(*data.Packet); ok {
-	//	data.ReleasePacket(dataPacket)
-	//s}
+	if dataPacket, ok := packet.(*data.Packet); ok {
+		data.ReleasePacket(dataPacket)
+	}
 }
 
 // handleConversation is called when the sniffer detects a new conversation and handles its specific packets
@@ -497,9 +497,9 @@ func (transport *Transport) handleConversation(socket network.Socket, reader io.
 			// Send notification
 			transport.api.Notification(NewPacketNotification(packet, srcAddr, dstAddr, time.Now()))
 
-			//if dataPacket, ok := packet.(*data.Packet); ok {
-			//	data.ReleasePacket(dataPacket)
-			//}
+			if dataPacket, ok := packet.(*data.Packet); ok {
+				data.ReleasePacket(dataPacket)
+			}
 		}
 	}()
 }