From b58db8225445396f5331990499bc4a37532c5ab7 Mon Sep 17 00:00:00 2001
From: Raja Subramanian <raja.gobi@tutanota.com>
Date: Sat, 8 Jun 2024 10:36:05 +0530
Subject: [PATCH] Log invalid RTP packet (#2774)

---
 pkg/sfu/buffer/buffer.go | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/pkg/sfu/buffer/buffer.go b/pkg/sfu/buffer/buffer.go
index 06492966a..b050bea49 100644
--- a/pkg/sfu/buffer/buffer.go
+++ b/pkg/sfu/buffer/buffer.go
@@ -316,6 +316,21 @@ func (b *Buffer) Write(pkt []byte) (n int, err error) {
 		return
 	}
 
+	if rtpPacket.Version != 2 || rtpPacket.PayloadType != b.payloadType {
+		b.logger.Warnw(
+			"invalid RTP packet", nil,
+			"version", rtpPacket.Version,
+			"sn", rtpPacket.SequenceNumber,
+			"timestamp", rtpPacket.Timestamp,
+			"payloadSize", len(rtpPacket.Payload),
+			"payloadType", rtpPacket.PayloadType,
+			"ssrc", rtpPacket.SSRC,
+			"rtpStats", b.rtpStats,
+			"snRangeMap", b.snRangeMap,
+		)
+		// TODO-REMOVE-AFTER-DEBUG
+	}
+
 	now := time.Now()
 	if b.twcc != nil && b.twccExtID != 0 && !b.closed.Load() {
 		if ext := rtpPacket.GetExtension(b.twccExtID); ext != nil {