// SPDX-FileCopyrightText: 2023 The Pion community // SPDX-License-Identifier: MIT package webrtc import ( "fmt" "strings" "github.com/pion/webrtc/v4/internal/fmtp" ) // RTPCodecType determines the type of a codec. type RTPCodecType int const ( // RTPCodecTypeUnknown is the enum's zero-value. RTPCodecTypeUnknown RTPCodecType = iota // RTPCodecTypeAudio indicates this is an audio codec. RTPCodecTypeAudio // RTPCodecTypeVideo indicates this is a video codec. RTPCodecTypeVideo ) func (t RTPCodecType) String() string { switch t { case RTPCodecTypeAudio: return "audio" //nolint: goconst case RTPCodecTypeVideo: return "video" //nolint: goconst default: return ErrUnknownType.Error() } } // NewRTPCodecType creates a RTPCodecType from a string. func NewRTPCodecType(r string) RTPCodecType { switch { case strings.EqualFold(r, RTPCodecTypeAudio.String()): return RTPCodecTypeAudio case strings.EqualFold(r, RTPCodecTypeVideo.String()): return RTPCodecTypeVideo default: return RTPCodecType(0) } } // RTPCodecCapability provides information about codec capabilities. // // https://w3c.github.io/webrtc-pc/#dictionary-rtcrtpcodeccapability-members type RTPCodecCapability struct { MimeType string ClockRate uint32 Channels uint16 SDPFmtpLine string RTCPFeedback []RTCPFeedback } // RTPHeaderExtensionCapability is used to define a RFC5285 RTP header extension supported by the codec. // // https://w3c.github.io/webrtc-pc/#dom-rtcrtpcapabilities-headerextensions type RTPHeaderExtensionCapability struct { URI string } // RTPHeaderExtensionParameter represents a negotiated RFC5285 RTP header extension. // // https://w3c.github.io/webrtc-pc/#dictionary-rtcrtpheaderextensionparameters-members type RTPHeaderExtensionParameter struct { URI string ID int } // RTPCodecParameters is a sequence containing the media codecs that an RtpSender // will choose from, as well as entries for RTX, RED and FEC mechanisms. This also // includes the PayloadType that has been negotiated // // https://w3c.github.io/webrtc-pc/#rtcrtpcodecparameters type RTPCodecParameters struct { RTPCodecCapability PayloadType PayloadType statsID string } // RTPParameters is a list of negotiated codecs and header extensions // // https://w3c.github.io/webrtc-pc/#dictionary-rtcrtpparameters-members type RTPParameters struct { HeaderExtensions []RTPHeaderExtensionParameter Codecs []RTPCodecParameters } type codecMatchType int const ( codecMatchNone codecMatchType = 0 codecMatchPartial codecMatchType = 1 codecMatchExact codecMatchType = 2 ) // Do a fuzzy find for a codec in the list of codecs // Used for lookup up a codec in an existing list to find a match // Returns codecMatchExact, codecMatchPartial, or codecMatchNone. func codecParametersFuzzySearch( needle RTPCodecParameters, haystack []RTPCodecParameters, ) (RTPCodecParameters, codecMatchType) { needleFmtp := fmtp.Parse( needle.RTPCodecCapability.MimeType, needle.RTPCodecCapability.ClockRate, needle.RTPCodecCapability.Channels, needle.RTPCodecCapability.SDPFmtpLine) // First attempt to match on MimeType + ClockRate + Channels + SDPFmtpLine for _, c := range haystack { cfmtp := fmtp.Parse( c.RTPCodecCapability.MimeType, c.RTPCodecCapability.ClockRate, c.RTPCodecCapability.Channels, c.RTPCodecCapability.SDPFmtpLine) if needleFmtp.Match(cfmtp) { return c, codecMatchExact } } // Fallback to just MimeType + ClockRate + Channels for _, c := range haystack { if strings.EqualFold(c.RTPCodecCapability.MimeType, needle.RTPCodecCapability.MimeType) && fmtp.ClockRateEqual(c.RTPCodecCapability.MimeType, c.RTPCodecCapability.ClockRate, needle.RTPCodecCapability.ClockRate) && fmtp.ChannelsEqual(c.RTPCodecCapability.MimeType, c.RTPCodecCapability.Channels, needle.RTPCodecCapability.Channels) { return c, codecMatchPartial } } return RTPCodecParameters{}, codecMatchNone } // Given a CodecParameters find the RTX Payload if one exists. func findRTXPayloadType(needle PayloadType, haystack []RTPCodecParameters) PayloadType { aptStr := fmt.Sprintf("apt=%d", needle) for _, c := range haystack { if aptStr == c.SDPFmtpLine { return c.PayloadType } } return PayloadType(0) } // Given a CodecParameters find the RTX CodecParameters if one exists. func findRTXPCodec(needle PayloadType, haystack []RTPCodecParameters) *RTPCodecParameters { aptStr := fmt.Sprintf("apt=%d", needle) for _, c := range haystack { if aptStr == c.SDPFmtpLine { return &c } } return nil } func rtcpFeedbackIntersection(a, b []RTCPFeedback) (out []RTCPFeedback) { for _, aFeedback := range a { for _, bFeeback := range b { if aFeedback.Type == bFeeback.Type && aFeedback.Parameter == bFeeback.Parameter { out = append(out, aFeedback) break } } } return }