Merge pull request #173 from boostcampwm-2024/feat/#162-mic-mute

[FEAT/#162] 마이크 뮤트 기능을 구현했습니다.

Author: Kiyoung-Kim-57

PhotoGether/DataLayer/PhotoGetherData/PhotoGetherData/ConnectionClientImpl.swift

@@ -76,6 +76,10 @@ public final class ConnectionClientImpl: ConnectionClient {
         return capturedImage
     }
 
+    public func toggleLocalAudioTrackState(isEnable: Bool) {
+        self.webRTCService.setLocalAudioState(isEnable)
+    }
+    
     /// remoteVideoTrack과 상대방의 화면을 볼 수 있는 뷰를 바인딩합니다.
     public func bindRemoteVideo() {
         guard let remoteVideoView = remoteVideoView as? RTCMTLVideoView else { return }

PhotoGether/DataLayer/PhotoGetherData/PhotoGetherData/ConnectionRepositoryImpl.swift

@@ -14,6 +14,14 @@ public final class ConnectionRepositoryImpl: ConnectionRepository {
     public var didEnterNewUserPublisher: AnyPublisher<(UserInfo, UIView), Never> {
         didEnterNewUserSubject.eraseToAnyPublisher()
     }
+    private let didChangeLocalAudioTrackStateSubject = CurrentValueSubject<Bool, Never>(false)
+    public var didChangeLocalAudioTrackStatePublisher: AnyPublisher<Bool, Never> {
+        didChangeLocalAudioTrackStateSubject
+            .eraseToAnyPublisher()
+    }
+    public var currentLocalVideoInputState: Bool {
+        didChangeLocalAudioTrackStateSubject.value
+    }
     private let _localVideoView = CapturableVideoView()
     public private(set) var localUserInfo: UserInfo?
 
@@ -73,7 +81,6 @@ public final class ConnectionRepositoryImpl: ConnectionRepository {
                 let width2 = CMVideoFormatDescriptionGetDimensions(frame2.formatDescription).width
                 return width1 < width2
             }).first else { return }
-
         // 가장 높은 fps 선택
         guard let fps = (format.videoSupportedFrameRateRanges
             .sorted { return $0.maxFrameRate < $1.maxFrameRate })
@@ -144,6 +151,14 @@ public final class ConnectionRepositoryImpl: ConnectionRepository {
             )
         }
     }
+    
+    public func switchLocalAudioTrackState() {
+        let presentAudioState = didChangeLocalAudioTrackStateSubject.value
+        clients.forEach {
+            $0.toggleLocalAudioTrackState(isEnable: !presentAudioState)
+        }
+        didChangeLocalAudioTrackStateSubject.send(!presentAudioState)
+    }
 }
 
 extension ConnectionRepositoryImpl {

PhotoGether/DataLayer/PhotoGetherData/PhotoGetherData/Interface/Service/WebRTCService.swift

@@ -34,4 +34,5 @@ public protocol WebRTCService: RTCPeerConnectionDelegate, RTCDataChannelDelegate
     // MARK: Audio
     func muteAudio()
     func unmuteAudio()
+    func setLocalAudioState(_ isEnabled: Bool)
 }

PhotoGether/DataLayer/PhotoGetherData/PhotoGetherData/ServiceImpl/WebRTCServiceImpl.swift

@@ -33,6 +33,7 @@ public final class WebRTCServiceImpl: NSObject, WebRTCService {
     ]
     private var localVideoTrack: RTCVideoTrack?
     private var remoteVideoTrack: RTCVideoTrack?
+    private var localAudioTrack: RTCAudioTrack
     private var localDataChannel: RTCDataChannel?
     private var remoteDataChannel: RTCDataChannel?
 
@@ -42,7 +43,11 @@ public final class WebRTCServiceImpl: NSObject, WebRTCService {
         let audioConfig = RTCAudioSessionConfiguration.webRTC()
         audioConfig.category = AVAudioSession.Category.playAndRecord.rawValue
         audioConfig.mode = AVAudioSession.Mode.voiceChat.rawValue
-        audioConfig.categoryOptions = [.defaultToSpeaker]
+        audioConfig.categoryOptions = [
+            .defaultToSpeaker, // 하단 스피커를 기본으로 설정
+            .allowBluetooth, // 블루투스 기기의 음성 입출력 지원
+            .allowAirPlay // AirPlay를 통해 연결된 다른 기기로 음성 출력 지원
+        ]
         RTCAudioSessionConfiguration.setWebRTC(audioConfig)
 
         let mediaConstraint = PeerConnectionSupport.mediaConstraint()
@@ -57,16 +62,18 @@ public final class WebRTCServiceImpl: NSObject, WebRTCService {
         }
 
         self.peerConnection = peerConnection
+        // MARK: AudioTrack 생성
+        self.localAudioTrack = PeerConnectionSupport.createAudioTrack()
 
         super.init()
 
         // MARK: DataChannel 연결
         self.connectDataChannel(dataChannel: createDataChannel())
 
         // MARK: AudioTrack 연결
-        let audioTrack = PeerConnectionSupport.createAudioTrack()
-        self.connectAudioTrack(audioTrack: audioTrack)
+        self.connectAudioTrack(audioTrack: self.localAudioTrack)
         self.configureAudioSession()
+        self.localAudioTrack.isEnabled = false
 
         self.peerConnection.delegate = self
         self.bindNoti()
@@ -222,12 +229,12 @@ public extension WebRTCServiceImpl {
     private func configureAudioSession() {
         self.rtcAudioSession.lockForConfiguration()
         do {
+            
             try self.rtcAudioSession.setCategory(
                 .playAndRecord,
                 mode: .voiceChat,
                 options: .defaultToSpeaker
             )
-            try self.rtcAudioSession.overrideOutputAudioPort(.speaker)
             try self.rtcAudioSession.setActive(true)
         } catch let error {
             PTGLogger.default.log("Error changeing AVAudioSession category: \(error)")
@@ -269,6 +276,10 @@ public extension WebRTCServiceImpl {
         self.setAudioEnabled(true)
     }
 
+    func setLocalAudioState(_ isEnabled: Bool) {
+        self.localAudioTrack.isEnabled = isEnabled
+    }
+    
     private func setAudioEnabled(_ isEnabled: Bool) {
         setTrackEnabled(RTCAudioTrack.self, isEnabled: isEnabled)
     }

PhotoGether/DomainLayer/PhotoGetherDomain/PhotoGetherDomain/UseCaseImpl/GetVoiceInputStateUseCaseImpl.swift

@@ -0,0 +1,13 @@
+import PhotoGetherDomainInterface
+
+public final class GetVoiceInputStateUseCaseImpl: GetVoiceInputStateUseCase {
+    public func execute() -> Bool {
+        return connectionRepository.currentLocalVideoInputState
+    }
+    
+    private let connectionRepository: ConnectionRepository
+    
+    public init(connectionRepository: ConnectionRepository) {
+        self.connectionRepository = connectionRepository
+    }
+}

PhotoGether/DomainLayer/PhotoGetherDomain/PhotoGetherDomain/UseCaseImpl/ToggleLocalMicStateUseCaseImpl.swift

@@ -0,0 +1,15 @@
+import Combine
+import PhotoGetherDomainInterface
+
+public final class ToggleLocalMicStateUseCaseImpl: ToggleLocalMicStateUseCase {
+    public func execute() -> AnyPublisher<Bool, Never> {
+        connectionRepository.switchLocalAudioTrackState()
+        return connectionRepository.didChangeLocalAudioTrackStatePublisher
+    }
+    
+    private let connectionRepository: ConnectionRepository
+    
+    public init(connectionRepository: ConnectionRepository) {
+        self.connectionRepository = connectionRepository
+    }
+}

PhotoGether/DomainLayer/PhotoGetherDomain/PhotoGetherDomainInterface/ConnectionClient.swift

@@ -19,6 +19,7 @@ public protocol ConnectionClient {
     func setRemoteUserInfo(_ remoteUserInfo: UserInfo)
     func sendData(data: Data)
     func captureVideo() -> UIImage
+    func toggleLocalAudioTrackState(isEnable: Bool)
     func bindLocalVideo(videoSource: RTCVideoSource?, _ localVideoView: UIView)
     func bindRemoteVideo()
 }

PhotoGether/DomainLayer/PhotoGetherDomain/PhotoGetherDomainInterface/Repository/ConnectionRepository.swift

@@ -3,15 +3,18 @@ import Combine
 
 public protocol ConnectionRepository {
     var didEnterNewUserPublisher: AnyPublisher<(UserInfo, UIView), Never> { get }
+    var didChangeLocalAudioTrackStatePublisher: AnyPublisher<Bool, Never> { get }
 
     var localUserInfo: UserInfo? { get }
 
     var clients: [ConnectionClient] { get }
     var localVideoView: UIView { get }
     var capturedLocalVideo: UIImage? { get }
+    var currentLocalVideoInputState: Bool { get }
 
     func createRoom() -> AnyPublisher<RoomOwnerEntity, Error>
     func joinRoom(to roomID: String, hostID: String) -> AnyPublisher<Bool, Error>
     func sendOffer() async throws
-    func stopCaptureLocalVideo() -> Bool 
+    func stopCaptureLocalVideo() -> Bool
+    func switchLocalAudioTrackState()
 }

PhotoGether/DomainLayer/PhotoGetherDomain/PhotoGetherDomainInterface/UseCase/GetVoiceInputStateUseCase.swift

@@ -0,0 +1,3 @@
+public protocol GetVoiceInputStateUseCase {
+    func execute() -> Bool
+}

PhotoGether/DomainLayer/PhotoGetherDomain/PhotoGetherDomainInterface/UseCase/ToggleLocalMicStateUseCase.swift

@@ -0,0 +1,5 @@
+import Combine
+
+public protocol ToggleLocalMicStateUseCase {
+    func execute() -> AnyPublisher<Bool, Never>
+}