move estimator to peer.

internal/webrtc/manager.go

@@ -369,7 +369,8 @@ func (manager *WebRTCManagerCtx) CreatePeer(session types.Session, bitrate int,
 		dataChannel: dataChannel,
 		rtcpChannel: videoRtcp,
 		// config
-		iceTrickle: manager.config.ICETrickle,
+		iceTrickle:       manager.config.ICETrickle,
+		estimatorPassive: manager.config.EstimatorPassive,
 	}
 
 	logger.Info().
@@ -381,33 +382,6 @@ func (manager *WebRTCManagerCtx) CreatePeer(session types.Session, bitrate int,
 		return nil, err
 	}
 
-	// if estimator is enabled, use it to change video stream
-	if estimator != nil {
-		go func() {
-			// use a ticker to get current client target bitrate
-			ticker := time.NewTicker(bitrateCheckInterval)
-			defer ticker.Stop()
-
-			for range ticker.C {
-				targetBitrate := estimator.GetTargetBitrate()
-				metrics.SetReceiverEstimatedTargetBitrate(float64(targetBitrate))
-
-				if connection.ConnectionState() == webrtc.PeerConnectionStateClosed {
-					break
-				}
-				if !videoTrack.VideoAuto() {
-					continue
-				}
-				if !manager.config.EstimatorPassive {
-					err := peer.SetVideoBitrate(targetBitrate)
-					if err != nil {
-						logger.Warn().Err(err).Msg("failed to set video bitrate")
-					}
-				}
-			}
-		}()
-	}
-
 	connection.OnTrack(func(track *webrtc.TrackRemote, receiver *webrtc.RTPReceiver) {
 		logger := logger.With().
 			Str("kind", track.Kind().String()).
@@ -602,6 +576,9 @@ func (manager *WebRTCManagerCtx) CreatePeer(session types.Session, bitrate int,
 	go metrics.rtcpReceiver(videoRtcp)
 	go metrics.connectionStats(connection)
 
+	// start estimator reader
+	go peer.estimatorReader()
+
 	return offer, nil
 }