ForwardRTCP -> RTCPReceived

Signed-off-by: Šimon Brandner <[email protected]>

Author: SimonBrandner

pkg/conference/messsage_processor.go

@@ -62,7 +62,7 @@ func (c *Conference) processPeerMessage(message common.Message[ParticipantID, pe
 		c.processDataChannelMessage(participant, msg)
 	case peer.DataChannelAvailable:
 		c.processDataChannelAvailableMessage(participant, msg)
-	case peer.ForwardRTCP:
+	case peer.RTCPReceived:
 		c.processForwardRTCPMessage(msg)
 	case peer.PLISent:
 		c.processPLISentMessage(msg)

pkg/conference/peer_message_processor.go

@@ -113,7 +113,7 @@ func (c *Conference) processDataChannelAvailableMessage(participant *Participant
 	})
 }
 
-func (c *Conference) processForwardRTCPMessage(msg peer.ForwardRTCP) {
+func (c *Conference) processForwardRTCPMessage(msg peer.RTCPReceived) {
 	for _, participant := range c.participants {
 		for _, publishedTrack := range participant.publishedTracks {
 			if publishedTrack.Track.StreamID() == msg.StreamID && publishedTrack.Track.ID() == msg.TrackID {

pkg/peer/messages.go

@@ -40,7 +40,7 @@ type DataChannelMessage struct {
 
 type DataChannelAvailable struct{}
 
-type ForwardRTCP struct {
+type RTCPReceived struct {
 	Packets  []rtcp.Packet
 	StreamID string
 	TrackID  string

pkg/peer/peer.go

@@ -112,7 +112,7 @@ func (p *Peer[ID]) SubscribeTo(track *webrtc.TrackLocalStaticRTP) error {
 				p.logger.WithError(err).Warn("failed to read RTCP on track")
 			}
 
-			p.sink.Send(ForwardRTCP{Packets: packets, TrackID: track.ID(), StreamID: track.StreamID()})
+			p.sink.Send(RTCPReceived{Packets: packets, TrackID: track.ID(), StreamID: track.StreamID()})
 		}
 	}()