Method serve

pkg/service/rtcservice.go:294–629

(w http.ResponseWriter, r *http.Request, needsJoinRequest bool)

}

func (s *RTCService) serve(w http.ResponseWriter, r *http.Request, needsJoinRequest bool) {
	// reject non websocket requests
	if !websocket.IsWebSocketUpgrade(r) {
		w.WriteHeader(404)
		return
	}

	startedAt := time.Now()
	var (
		roomName            livekit.RoomName
		roomID              livekit.RoomID
		participantIdentity livekit.ParticipantIdentity
		pID                 livekit.ParticipantID
		joinDuration        time.Duration
		loggerResolved      bool

		pi   routing.ParticipantInit
		code int
		err  error
	)

	pLogger, loggerResolver := utils.GetLogger(r.Context()).WithDeferredValues()

	getLoggerFields := func() []any {
		return []any{
			"room", roomName,
			"roomID", roomID,
			"participant", participantIdentity,
			"participantID", pID,
			"joinDuration", joinDuration,
		}
	}

	resolveLogger := func(force bool) {
		if loggerResolved {
			return
		}

		if force {
			if roomName == "" {
				roomName = "unresolved"
			}
			if roomID == "" {
				roomID = "unresolved"
			}
			if participantIdentity == "" {
				participantIdentity = "unresolved"
			}
			if pID == "" {
				pID = "unresolved"
			}
			if joinDuration == 0 {
				joinDuration = time.Since(startedAt)
			}
		}

		if roomName != "" && roomID != "" && participantIdentity != "" && pID != "" {
			loggerResolved = true