Decapitalize

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

Author: SimonBrandner

pkg/conference/participant.go

@@ -21,8 +21,8 @@ type ParticipantID struct {
 }
 
 type PublishedTrack struct {
-	Track            *webrtc.TrackLocalStaticRTP
-	LastPLITimestamp atomic.Int64
+	track            *webrtc.TrackLocalStaticRTP
+	lastPLITimestamp atomic.Int64
 }
 
 // Participant represents a participant in the conference.

pkg/conference/peer_message_processor.go

@@ -30,7 +30,7 @@ func (c *Conference) processNewTrackPublishedMessage(participant *Participant, m
 		return
 	}
 
-	participant.publishedTracks[key] = PublishedTrack{Track: msg.Track}
+	participant.publishedTracks[key] = PublishedTrack{track: msg.Track}
 	c.resendMetadataToAllExcept(participant.id)
 }
 
@@ -116,8 +116,8 @@ func (c *Conference) processDataChannelAvailableMessage(participant *Participant
 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 {
-				participant.peer.WriteRTCP(msg.Packets, msg.StreamID, msg.TrackID, publishedTrack.LastPLITimestamp.Load())
+			if publishedTrack.track.StreamID() == msg.StreamID && publishedTrack.track.ID() == msg.TrackID {
+				participant.peer.WriteRTCP(msg.Packets, msg.StreamID, msg.TrackID, publishedTrack.lastPLITimestamp.Load())
 			}
 		}
 	}
@@ -126,8 +126,8 @@ func (c *Conference) processForwardRTCPMessage(msg peer.RTCPReceived) {
 func (c *Conference) processPLISentMessage(msg peer.PLISent) {
 	for _, participant := range c.participants {
 		for _, publishedTrack := range participant.publishedTracks {
-			if publishedTrack.Track.StreamID() == msg.StreamID && publishedTrack.Track.ID() == msg.TrackID {
-				publishedTrack.LastPLITimestamp.Store(msg.Timestamp)
+			if publishedTrack.track.StreamID() == msg.StreamID && publishedTrack.track.ID() == msg.TrackID {
+				publishedTrack.lastPLITimestamp.Store(msg.Timestamp)
 			}
 		}
 	}

pkg/conference/state.go

@@ -57,7 +57,7 @@ func (c *Conference) removeParticipant(participantID ParticipantID) {
 	// Remove the participant's tracks from all participants who might have subscribed to them.
 	obsoleteTracks := []*webrtc.TrackLocalStaticRTP{}
 	for _, publishedTrack := range participant.publishedTracks {
-		obsoleteTracks = append(obsoleteTracks, publishedTrack.Track)
+		obsoleteTracks = append(obsoleteTracks, publishedTrack.track)
 	}
 	for _, otherParticipant := range c.participants {
 		otherParticipant.peer.UnsubscribeFrom(obsoleteTracks)
@@ -74,7 +74,7 @@ func (c *Conference) getAvailableStreamsFor(forParticipant ParticipantID) event.
 			// Now, find out which of published tracks belong to the streams for which we have metadata
 			// available and construct a metadata map for a given participant based on that.
 			for _, track := range participant.publishedTracks {
-				trackID, streamID := track.Track.ID(), track.Track.StreamID()
+				trackID, streamID := track.track.ID(), track.track.StreamID()
 
 				if metadata, ok := streamsMetadata[streamID]; ok {
 					metadata.Tracks[trackID] = event.CallSDPStreamMetadataTrack{}
@@ -99,7 +99,7 @@ func (c *Conference) getTracks(identifiers []event.SFUTrackDescription) []*webrt
 		// Check if this participant has any of the tracks that we're looking for.
 		for _, identifier := range identifiers {
 			if track, ok := participant.publishedTracks[identifier]; ok {
-				tracks = append(tracks, track.Track)
+				tracks = append(tracks, track.track)
 			}
 		}
 	}