apply swiftlint --fix --format

Author: hiroshihorie

Sources/LiveKit/Broadcast/BroadcastScreenCapturer.swift

@@ -9,33 +9,33 @@ import Foundation
 import WebRTC
 import Promises
 
-class BroadcastScreenCapturer : BufferCapturer {
+class BroadcastScreenCapturer: BufferCapturer {
     static let kRTCScreensharingSocketFD = "rtc_SSFD"
     static let kAppGroupIdentifierKey = "RTCAppGroupIdentifier"
     static let kRTCScreenSharingExtension = "RTCScreenSharingExtension"
-    
+
     var frameReader: SocketConnectionFrameReader?
-    
+
     override func startCapture() -> Promise<Bool> {
         super.startCapture().then(on: .sdk) {didStart -> Promise<Bool> in
-            
+
             guard didStart, self.frameReader == nil else {
                 // already started
                 return Promise(false)
             }
-            
+
             guard let identifier = self.lookUpAppGroupIdentifier(),
                   let filePath = self.filePathForIdentifier(identifier)
             else {
                 return Promise { false }
             }
-            
+
             return Promise { fufill, _ in
                 let bounds = UIScreen.main.bounds
                 let width = bounds.size.width
                 let height = bounds.size.height
                 let screenDimension = CMVideoDimensions(width: Int32(width), height: Int32(height))
-                
+
                 // pre fill dimensions, so that we don't have to wait for the broadcast to start to get actual dimensions.
                 // should be able to safely predict using actual screen dimensions.
                 let targetDimensions = screenDimension
@@ -51,45 +51,45 @@ class BroadcastScreenCapturer : BufferCapturer {
                 }
                 frameReader.didCapture = { pixelBuffer, rotation in
                     self.capture(pixelBuffer, rotation: rotation)
-                    
+
                 }
                 frameReader.startCapture(with: socketConnection)
                 self.frameReader = frameReader
                 fufill(true)
             }
         }
     }
-    
+
     override func stopCapture() -> Promise<Bool> {
         super.stopCapture().then(on: .sdk) { didStop -> Promise<Bool> in
-            
+
             guard didStop, self.frameReader != nil else {
                 // already stopped
                 return Promise(false)
             }
-            
+
             return Promise { fulfill, _ in
                 self.frameReader?.stopCapture()
                 self.frameReader = nil
                 fulfill(true)
             }
         }
     }
-    
+
     private func lookUpAppGroupIdentifier() -> String? {
         return Bundle.main.infoDictionary?[BroadcastScreenCapturer.kAppGroupIdentifierKey] as? String
     }
-    
+
     private func filePathForIdentifier(_ identifier: String) -> String? {
         guard let sharedContainer = FileManager.default.containerURL(forSecurityApplicationGroupIdentifier: identifier)
         else {
             return nil
         }
-        
+
         let filePath = sharedContainer.appendingPathComponent(BroadcastScreenCapturer.kRTCScreensharingSocketFD).path
         return filePath
     }
-    
+
 }
 
 extension LocalVideoTrack {

Sources/LiveKit/Broadcast/BroadcastServerSocketConnection.swift

@@ -12,14 +12,14 @@ import CHeaders
 
 class BroadcastServerSocketConnection: NSObject {
     private let streamDelegate: StreamDelegate
-    
+
     private let filePath: String
     private var socketHandle: Int32 = -1
     private var address: sockaddr_un?
 
     private var inputStream: InputStream?
     private var outputStream: OutputStream?
-    
+
     private var listeningSource: DispatchSourceRead?
     private var networkQueue: DispatchQueue?
     private var shouldKeepRunning = false
@@ -37,17 +37,17 @@ class BroadcastServerSocketConnection: NSObject {
 
     func open() -> Bool {
         logger.log(level: .debug, "open socket connection")
-        
+
         guard setupAddress() == true else {
             logger.log(level: .debug, "failed setting up address")
-            
+
             return false
         }
-        
+
         guard bindSocket() == true else {
             return false
         }
-        
+
         guard FileManager.default.fileExists(atPath: filePath) else {
             logger.log(level: .debug, "failure: socket file missing")
             return false
@@ -56,24 +56,24 @@ class BroadcastServerSocketConnection: NSObject {
             logger.log(level: .debug, "failure: socket failed listening connection")
             return false
         }
-        
+
         let listeningSource = DispatchSource.makeReadSource(fileDescriptor: socketHandle)
         listeningSource.setEventHandler {
             let clientSocket = Darwin.accept(self.socketHandle, nil, nil)
-            
+
             guard clientSocket >= 0 else {
                 logger.log(level: .debug, "failure: socket failed accepting connection")
                 return
             }
-            
+
             self.setupStreams(clientSocket: clientSocket)
-            
+
             self.inputStream?.open()
             self.outputStream?.open()
-            
+
             logger.log(level: .debug, "streams open")
         }
-        
+
         self.listeningSource = listeningSource
         listeningSource.resume()
         return true
@@ -87,10 +87,10 @@ class BroadcastServerSocketConnection: NSObject {
 
         inputStream?.close()
         outputStream?.close()
-        
+
         inputStream = nil
         outputStream = nil
-        
+
         logger.log(level: .debug, "closing server socket")
         listeningSource?.cancel()
         Darwin.close(socketHandle)
@@ -99,25 +99,25 @@ class BroadcastServerSocketConnection: NSObject {
     func writeToStream(buffer: UnsafePointer<UInt8>, maxLength length: Int) -> Int {
         outputStream?.write(buffer, maxLength: length) ?? 0
     }
-    
+
     private func setupAddress() -> Bool {
         var addr = sockaddr_un()
-        addr.sun_family = sa_family_t(AF_UNIX);
+        addr.sun_family = sa_family_t(AF_UNIX)
         guard filePath.count < MemoryLayout.size(ofValue: addr.sun_path) else {
             logger.log(level: .debug, "failure: fd path is too long")
             return false
         }
-        
+
         _ = filePath.withCString {
             unlink($0)
         }
-        
+
         _ = withUnsafeMutablePointer(to: &addr.sun_path.0) { ptr in
             filePath.withCString {
                 strncpy(ptr, $0, filePath.count)
             }
         }
-        
+
         address = addr
         return true
     }
@@ -127,7 +127,7 @@ class BroadcastServerSocketConnection: NSObject {
             logger.log(level: .debug, "failure: no address?")
             return false
         }
-        
+
         let status = withUnsafePointer(to: &addr) { ptr in
             ptr.withMemoryRebound(to: sockaddr.self, capacity: 1) {
                 Darwin.bind(socketHandle, $0, socklen_t(MemoryLayout<sockaddr_un>.size))
@@ -138,7 +138,7 @@ class BroadcastServerSocketConnection: NSObject {
             logger.log(level: .debug, "failure: \(status)")
             return false
         }
-        
+
         return true
     }
 
@@ -157,33 +157,33 @@ class BroadcastServerSocketConnection: NSObject {
 
         scheduleStreams()
     }
-  
+
     private func scheduleStreams() {
         shouldKeepRunning = true
-        
+
         networkQueue = DispatchQueue.global(qos: .userInitiated)
         networkQueue?.async { [weak self] in
             self?.inputStream?.schedule(in: .current, forMode: .default)
             self?.outputStream?.schedule(in: .current, forMode: .default)
-            
+
             logger.log(level: .debug, "streams scheduled")
             var isRunning = false
-                        
+
             repeat {
                 isRunning = self?.shouldKeepRunning ?? false && RunLoop.current.run(mode: .default, before: .distantFuture)
             } while (isRunning)
-            
+
             logger.log(level: .debug, "streams stopped")
         }
     }
-    
+
     private func unscheduleStreams() {
         logger.log(level: .debug, "unscheduleStreams")
         networkQueue?.sync { [weak self] in
             self?.inputStream?.remove(from: .current, forMode: .common)
             self?.outputStream?.remove(from: .current, forMode: .common)
         }
-        
+
         shouldKeepRunning = false
     }
 }