Cleanup logs

Author: pblazej

Sources/LiveKit/Core/Room+Engine.swift

@@ -38,7 +38,6 @@ extension Room {
 
     // Resets state of transports
     func cleanUpRTC() async {
-        log("[Connect] Cleaning up RTC resources")
         // Close data channels
         publisherDataChannel.reset()
         subscriberDataChannel.reset()

Sources/LiveKit/Core/Room+SignalClientDelegate.swift

@@ -322,7 +322,7 @@ extension Room: SignalClientDelegate {
     }
 
     func signalClient(_: SignalClient, didReceiveAnswer answer: LKRTCSessionDescription, offerId: UInt32) async {
-        log("Received answer with offerId: \(offerId)")
+        log("Received answer for offerId: \(offerId)")
 
         do {
             let publisher = try requirePublisher()
@@ -346,7 +346,7 @@ extension Room: SignalClientDelegate {
             try await subscriber.set(localDescription: answer)
             try await signalClient.send(answer: answer, offerId: offerId)
         } catch {
-            log("Failed to send answer with offerId: \(offerId), error: \(error)", .error)
+            log("Failed to send answer for offerId: \(offerId), error: \(error)", .error)
         }
     }
 

Sources/LiveKit/Core/SignalClient.swift

@@ -127,26 +127,20 @@ actor SignalClient: Loggable {
                                      adaptiveStream: adaptiveStream)
 
         let isReconnect = reconnectMode != nil
-        let connectStartedAt = Date()
-        let connectLabel = isReconnect ? "reconnect" : "join"
 
         if isReconnect {
-            log("[Connect] with url: \(url)")
+            log("Reconnecting with url: \(url)")
         } else {
             log("Connecting with url: \(url)")
         }
 
         _state.mutate { $0.connectionState = (isReconnect ? .reconnecting : .connecting) }
 
         do {
-            log("[Connect] Opening SignalClient socket for \(connectLabel)")
             let socket = try await WebSocket(url: url,
                                              token: token,
                                              connectOptions: connectOptions)
 
-            let socketReadyDuration = Date().timeIntervalSince(connectStartedAt)
-            log(String(format: "[Connect] SignalClient socket ready in %.2fs", socketReadyDuration))
-
             let task = Task.detached {
                 self.log("Did enter WebSocket message loop...")
                 do {
@@ -159,11 +153,7 @@ actor SignalClient: Loggable {
             }
             _state.mutate { $0.messageLoopTask = task }
 
-            let waitStartedAt = Date()
-            log("[Connect] Waiting for \(connectLabel) response")
             let connectResponse = try await _connectResponseCompleter.wait()
-            let waitDuration = Date().timeIntervalSince(waitStartedAt)
-            log(String(format: "[Connect] %@ response received in %.2fs", connectLabel.capitalized, waitDuration))
             // Check cancellation after received join response
             try Task.checkCancellation()
 
@@ -175,8 +165,6 @@ actor SignalClient: Loggable {
 
             return connectResponse
         } catch {
-            log("Connect failed with error: \(error)", .error)
-
             // Skip validation if user cancelled
             if error is CancellationError {
                 await cleanUp(withError: error)
@@ -366,7 +354,6 @@ private extension SignalClient {
 
 extension SignalClient {
     func resumeQueues() async {
-        log("Resuming response/request queues")
         await _responseQueue.resume()
         await _requestQueue.resume()
     }

Sources/LiveKit/Core/Transport.swift

@@ -167,7 +167,6 @@ actor Transport: NSObject, Loggable {
 
         if signalingState == .haveLocalOffer, !(iceRestart && remoteDescription != nil) {
             _reNegotiate = true
-            log("Already have local offer, deferring renegotiation")
             return
         }
 
@@ -181,7 +180,6 @@ actor Transport: NSObject, Loggable {
 
         if signalingState == .haveLocalOffer, iceRestart, let sd = remoteDescription {
             _reNegotiate = false // Clear flag to prevent double offer
-            log("Rolling back remote description before ICE restart offer")
             try await set(remoteDescription: sd)
             return try await _negotiateSequence()
         }