From 31c19a0e7dd37db240a7020a4acd2cff3a90a5ad Mon Sep 17 00:00:00 2001
From: Luan Freitas <ludufre@gmail.com>
Date: Mon, 16 Mar 2026 18:33:01 -0300
Subject: [PATCH] fix: incoming pcma and pcmu

---
 pkg/mpegts/producer.go | 26 +++++++++++++++++++++++++-
 1 file changed, 25 insertions(+), 1 deletion(-)

diff --git a/pkg/mpegts/producer.go b/pkg/mpegts/producer.go
index 2c72d8aa..592f121b 100644
--- a/pkg/mpegts/producer.go
+++ b/pkg/mpegts/producer.go
@@ -91,7 +91,7 @@ func (c *Producer) probe() error {
 		case StreamTypeMetadata:
 			for _, streamType := range pkt.Payload {
 				switch streamType {
-				case StreamTypeH264, StreamTypeH265, StreamTypeAAC, StreamTypePrivateOPUS:
+				case StreamTypeH264, StreamTypeH265, StreamTypeAAC, StreamTypePrivateOPUS, StreamTypePCMATapo, StreamTypePCMUTapo:
 					waitType = append(waitType, streamType)
 				}
 			}
@@ -135,6 +135,30 @@ func (c *Producer) probe() error {
 				Codecs:    []*core.Codec{codec},
 			}
 			c.Medias = append(c.Medias, media)
+
+		case StreamTypePCMATapo:
+			codec := &core.Codec{
+				Name:      core.CodecPCMA,
+				ClockRate: 8000,
+			}
+			media := &core.Media{
+				Kind:      core.KindAudio,
+				Direction: core.DirectionRecvonly,
+				Codecs:    []*core.Codec{codec},
+			}
+			c.Medias = append(c.Medias, media)
+
+		case StreamTypePCMUTapo:
+			codec := &core.Codec{
+				Name:      core.CodecPCMU,
+				ClockRate: 8000,
+			}
+			media := &core.Media{
+				Kind:      core.KindAudio,
+				Direction: core.DirectionRecvonly,
+				Codecs:    []*core.Codec{codec},
+			}
+			c.Medias = append(c.Medias, media)
 		}
 	}