feat/#95 :: RoomService의 joinRoom 로직 구현

- RoomService에서 서버로 요청을 보내는 로직을 구현했습니다.

Co-Authored-By: Youngkyu Song <ace_lephant@naver.com>

Author: Kiyoung-Kim-57

PhotoGether/DataLayer/PhotoGetherData/PhotoGetherData/ServiceImpl/RoomServiceImpl.swift

@@ -7,7 +7,11 @@ public final class RoomServiceImpl: RoomService {
     public var createRoomResponsePublisher: AnyPublisher<RoomOwnerEntity, Error> {
         _createRoomResponsePublisher.eraseToAnyPublisher()
     }
+    public var joinRoomResponsePublisher: AnyPublisher<JoinRoomEntity, Error> {
+        _joinRoomResponsePublisher.eraseToAnyPublisher()
+    }
     private let _createRoomResponsePublisher = PassthroughSubject<RoomOwnerEntity, Error>()
+    private let _joinRoomResponsePublisher = PassthroughSubject<JoinRoomEntity, Error>()
     private var cancellables: Set<AnyCancellable> = []
 
     private let decoder = JSONDecoder()
@@ -31,7 +35,18 @@ public final class RoomServiceImpl: RoomService {
         return createRoomResponsePublisher
     }
 
-    public func joinRoom() { }
+    public func joinRoom(to roomID: String) -> AnyPublisher<JoinRoomEntity, Error> {
+        let joinRoomMessage = JoinRoomRequestMessage(roomID: roomID).toData(encoder: encoder)
+        let joinRoomRequest = RoomRequestDTO(messageType: .joinRoom, message: joinRoomMessage)
+        
+        guard let data = joinRoomRequest.toData(encoder: encoder) else {
+            debugPrint("방 참가 요청 데이터 인코딩 실패: \(joinRoomRequest)")
+            return Fail(error: RoomServiceError.failedToEncoding).eraseToAnyPublisher()
+        }
+        
+        webSocketClient.send(data: data)
+        return joinRoomResponsePublisher
+    }
 
     private func bindWebSocketClient() {
         self.webSocketClient.webSocketdidReceiveDataPublisher
@@ -43,19 +58,39 @@ public final class RoomServiceImpl: RoomService {
                 switch response.messageType {
                 case .createRoom:
                     guard let message = response.message else { return }
-                    guard let message = message.toDTO(type: CreateRoomMessage.self) else {
+                    guard let message = message.toDTO(type: CreateRoomResponseMessage.self) else {
                         debugPrint("Decode Failed to CreateRoomMessage: \(message)")
                         return
                     }
-                    let createRoomEntity = RoomOwnerEntity(roomID: message.roomID, userID: message.userID)
-                    _createRoomResponsePublisher.send(createRoomEntity)
+                    let roomOwnerEntity = message.toEntity()
+                    _createRoomResponsePublisher.send(roomOwnerEntity)
 
                     debugPrint("방 생성 성공: \(message.roomID) \n 유저 아이디: \(message.userID)")
                 case .joinRoom:
-                    break
+                    guard let message = decodeMessage(
+                        response.message,
+                        type: JoinRoomResponseMessage.self
+                    ) else {
+                        debugPrint("Decode Failed to JoinRoomEntity: \(String(describing: response.message))")
+                        return
+                    }
+                    let joinRoomEntity = message.toEntity()
+                    _joinRoomResponsePublisher.send(joinRoomEntity)
+                    
+                    debugPrint("방 참가 성공\n 유저 아이디: \(message.userID) \n 방 유저들 아이디: \(message.clientsID)")
                 }
             }.store(in: &cancellables)
     }
+    
+    private func decodeMessage<T: Decodable>(_ message: Data?, type: T.Type) -> T? {
+        guard let message = message else { return nil }
+        guard let dto = message.toDTO(type: type) else {
+            debugPrint("Decode Failed to: \(message)")
+            return nil
+        }
+        
+        return dto
+    }
 }
 
 public enum RoomServiceError: LocalizedError {

PhotoGether/DomainLayer/PhotoGetherDomain/PhotoGetherDomainInterface/Service/RoomService.swift

@@ -5,5 +5,5 @@ public protocol RoomService {
     var createRoomResponsePublisher: AnyPublisher<RoomOwnerEntity, Error> { get }
 
     func createRoom() -> AnyPublisher<RoomOwnerEntity, Error>
-    func joinRoom()
+    func joinRoom(to roomID: String) -> AnyPublisher<JoinRoomEntity, Error>
 }