[GWL-184] Socket과 HealthKit 연결, CombineCocoa와 Log 수정

iOS/Projects/Core/Network/Sources/MockWebSocketSession.swift

@@ -14,6 +14,8 @@ public final class MockWebSocketTask: WebSocketTaskProtocol {
   private var sentMessage: URLSessionWebSocketTask.Message?
   private var receiveContinuation: CheckedContinuation<URLSessionWebSocketTask.Message, Never>?
 
+  public init() {}
+
   public func send(_ message: URLSessionWebSocketTask.Message) async throws {
     sentMessage = message
     receiveContinuation?.resume(returning: message)
@@ -38,6 +40,8 @@ public final class MockWebSocketTask: WebSocketTaskProtocol {
 public struct MockWebSocketSession: URLSessionWebSocketProtocol {
   var webSocketTask: MockWebSocketTask = .init()
 
+  public init() {}
+
   public func webSocketTask(with _: URLRequest) -> WebSocketTaskProtocol {
     return webSocketTask
   }

iOS/Projects/Features/Onboarding/Tests/OnboardingFeatureTests.swift

@@ -0,0 +1,7 @@
+import XCTest
+
+final class OnboardingFeatureTests: XCTestCase {
+  func testAlwaysPassed() {
+    XCTAssertTrue(true)
+  }
+}

iOS/Projects/Features/Record/Sources/Data/Repositories/HealthRepository.swift

@@ -48,15 +48,15 @@ public final class HealthRepository {
   /// 사용자에게 HealthKit 사용 인가를 요청합니다.
   private func requestAuthorization() {
     if HKHealthStore.isHealthDataAvailable() == false {
-      Log.make().error("Not available HealthKit.")
+      Log.make(with: .healthKit).error("Not available HealthKit.")
       return
     }
 
-    Log.make().notice("Requesting HealthKit authorization...")
+    Log.make(with: .healthKit).notice("Requesting HealthKit authorization...")
 
     healthStore.requestAuthorization(toShare: nil, read: healthDataTypeValues) { _, error in
       if let error {
-        Log.make().error("Received an HealthKit error type: \(error)")
+        Log.make(with: .healthKit).error("Received an HealthKit error type: \(error)")
       }
     }
   }
@@ -70,7 +70,13 @@ public final class HealthRepository {
   private func query(startDate: Date, identifier: HKQuantityTypeIdentifier, anchor: HKQueryAnchor?) async throws -> ([HKSample]?, HKQueryAnchor?) {
     return try await withCheckedThrowingContinuation { continuation in
 
-      let handler: (HKAnchoredObjectQuery, [HKSample]?, [HKDeletedObject]?, HKQueryAnchor?, Error?) -> Void = { _, samples, _, newAnchor, error in
+      let query = HKAnchoredObjectQuery(
+        type: HKQuantityType(identifier),
+        predicate: HKQuery.predicateForSamples(withStart: startDate, end: nil),
+        anchor: anchor,
+        limit: HKObjectQueryNoLimit
+      ) { _, samples, _, newAnchor, error in
+        Log.make(with: .healthKit).notice("\(samples ?? []), \(newAnchor)")
         if let error {
           continuation.resume(throwing: error)
         } else {
@@ -79,20 +85,20 @@ public final class HealthRepository {
         guard let samples,
               samples.isEmpty == false
         else {
-          Log.make().notice("\(identifier.rawValue) Samples are empty.")
+          Log.make(with: .healthKit).notice("\(identifier.rawValue) Samples are empty.")
           return
         }
       }
 
-      let query = HKAnchoredObjectQuery(
-        type: HKQuantityType(identifier),
-        predicate: HKQuery.predicateForSamples(withStart: startDate, end: nil),
-        anchor: anchor,
-        limit: HKObjectQueryNoLimit,
-        resultsHandler: handler
-      )
-
-      query.updateHandler = handler
+      query.updateHandler = { _, samples, _, newAnchor, _ in
+        Log.make(with: .healthKit).notice("\(samples ?? []), \(newAnchor)")
+        guard let samples,
+              samples.isEmpty == false
+        else {
+          Log.make(with: .healthKit).notice("\(identifier.rawValue) Samples are empty.")
+          return
+        }
+      }
 
       switch identifier {
       case .activeEnergyBurned:

iOS/Projects/Features/Record/Sources/Data/Repositories/WorkoutRecordRepository.swift

@@ -24,7 +24,7 @@ public struct WorkoutRecordRepository: WorkoutRecordRepositoryRepresentable {
   /// - Parameter locationData: 사용자의 위치 정보
   /// - Parameter healthData: 사용자의 건강 정보
   /// - Returns: 기록 고유 Identifier
-  func record(usingLocation locationData: [LocationDTO], andHealthData healthData: WorkoutHealth) -> AnyPublisher<Int, Error> {
+  func record(usingLocation locationData: [LocationDTO], andHealthData healthData: WorkoutDataForm) -> AnyPublisher<Int, Error> {
     return Deferred {
       Future<Data, Error> { promise in
         Task {
@@ -65,7 +65,7 @@ extension WorkoutRecordRepository {
 
     var headers: TNHeaders = .init(headers: [])
 
-    init(locationList _: [LocationDTO], health _: WorkoutHealth) {
+    init(locationList _: [LocationDTO], health _: WorkoutDataForm) {
       // TODO: 요청 모델 설정 필요
     }
   }

iOS/Projects/Features/Record/Sources/Data/Repositories/WorkoutSocketRepository.swift

@@ -0,0 +1,118 @@
+//
+//  WorkoutSocketRepository.swift
+//  RecordFeature
+//
+//  Created by 홍승현 on 11/30/23.
+//  Copyright © 2023 kr.codesquad.boostcamp8. All rights reserved.
+//
+
+import Combine
+import Foundation
+import Log
+import Trinet
+
+// MARK: - WorkoutSocketRepositoryDependency
+
+protocol WorkoutSocketRepositoryDependency {
+  var roomID: String { get }
+}
+
+// MARK: - WorkoutSocketRepository
+
+struct WorkoutSocketRepository {
+  private let provider: TNSocketProvider<WorkoutSocketEndPoint>
+
+  private let jsonDecoder: JSONDecoder = .init()
+  private var task: Task<Void, Error>?
+
+  private let subject: PassthroughSubject<WorkoutRealTimeModel, Error> = .init()
+
+  init(session: URLSessionWebSocketProtocol, dependency: WorkoutSocketRepositoryDependency) {
+    provider = .init(
+      session: session,
+      endPoint: .init(headers: [.init(key: "roomId", value: dependency.roomID)])
+    )
+    task = receiveParticipantsData()
+  }
+
+  private func stringToWorkoutRealTimeModel(rawString: String) throws -> WorkoutRealTimeModel {
+    guard let jsonData = rawString.data(using: .utf8) else {
+      throw WorkoutSocketRepositoryError.invalidStringForConversion
+    }
+    return try jsonDecoder.decode(WorkoutRealTimeModel.self, from: jsonData)
+  }
+
+  private func receiveParticipantsData() -> Task<Void, Error> {
+    return Task {
+      Log.make(with: .network).debug("receive Ready")
+      while true {
+        do {
+          switch try await provider.receive() {
+          case let .string(string):
+            Log.make(with: .network).debug("received \(string)")
+            try subject.send(stringToWorkoutRealTimeModel(rawString: string))
+          default:
+            Log.make().error("You can't enter this line")
+          }
+        } catch {
+          subject.send(completion: .failure(error))
+        }
+      }
+      Log.make().fault("You can't enter this line")
+    }
+  }
+}
+
+// MARK: WorkoutSocketRepositoryRepresentable
+
+extension WorkoutSocketRepository: WorkoutSocketRepositoryRepresentable {
+  func fetchParticipantsRealTime() -> AnyPublisher<WorkoutRealTimeModel, Error> {
+    subject.eraseToAnyPublisher()
+  }
+
+  func sendMyWorkout(with model: WorkoutRealTimeModel) -> AnyPublisher<Void, Error> {
+    Future { promise in
+      Task {
+        do {
+          try await provider.send(model: model)
+          promise(.success(()))
+        } catch {
+          promise(.failure(error))
+        }
+      }
+    }
+    .eraseToAnyPublisher()
+  }
+}
+
+// MARK: WorkoutSocketRepository.WorkoutSocketRepositoryError
+
+extension WorkoutSocketRepository {
+  enum WorkoutSocketRepositoryError: LocalizedError {
+    case invalidStringForConversion
+
+    var errorDescription: String? {
+      return "문자열을 Data로 변환할 수 없습니다. 문자열이 비어있는지 확인하세요."
+    }
+  }
+}
+
+// MARK: - WorkoutSocketEndPoint
+
+private struct WorkoutSocketEndPoint: TNEndPoint {
+  let baseURL: String = Bundle.main.infoDictionary?["SocketURL"] as? String ?? ""
+
+  let path: String = ""
+
+  let method: TNMethod = .get
+
+  let query: Encodable? = nil
+
+  let body: Encodable? = nil
+
+  let headers: TNHeaders
+
+  init(headers: TNHeaders) {
+    self.headers = headers
+  }
+}

iOS/Projects/Features/Record/Sources/Domain/Entities/SessionPeerType.swift

@@ -0,0 +1,21 @@
+//
+//  SessionPeerType.swift
+//  RecordFeature
+//
+//  Created by 홍승현 on 11/30/23.
+//  Copyright © 2023 kr.codesquad.boostcamp8. All rights reserved.
+//
+
+import Foundation
+
+/// 운동 세션 중 사용자의 UI 정보를 업데이트 하기 위해 사용합니다.
+struct SessionPeerType: Identifiable {
+  /// 사용자 닉네임
+  let nickname: String
+
+  /// 사용자의 Identifier
+  let id: String
+
+  /// 사용자의 프로필 이미지 주소
+  let profileImageURL: URL
+}

iOS/Projects/Features/Record/Sources/Domain/Entities/WorkoutDataForm.swift

@@ -0,0 +1,39 @@
+//
+//  WorkoutDataForm.swift
+//  RecordFeature
+//
+//  Created by 홍승현 on 11/25/23.
+//  Copyright © 2023 kr.codesquad.boostcamp8. All rights reserved.
+//
+
+import Foundation
+
+/// 건강 데이터를 body로 전달하기 위한 요청(request) 모델입니다. 운동 세션이 종료될 때 이 모델을 사용합니다.
+public struct WorkoutDataForm: Encodable {
+  /// 운동 누적 시간
+  let workoutTime: Int
+
+  /// 총 운동한 거리
+  let distance: Int?
+
+  /// 소모한 칼로리
+  let calorie: Int?
+
+  /// 평균 심박수
+  let averageHeartRate: Int?
+
+  /// 운동 중에 기록한 최소 심박수
+  let minimumHeartRate: Int?
+
+  /// 운동 중에 기록한 최대 심박수
+  let maximumHeartRate: Int?
+
+  enum CodingKeys: String, CodingKey {
+    case workoutTime
+    case distance
+    case calorie
+    case averageHeartRate = "avgHeartRate"
+    case minimumHeartRate = "minHeartRate"
+    case maximumHeartRate = "maxHeartRate"
+  }
+}

iOS/Projects/Features/Record/Sources/Domain/Entities/WorkoutHealth.swift → iOS/Projects/Features/Record/Sources/Domain/Entities/WorkoutHealthForm.swift

@@ -1,17 +1,15 @@
 //
-//  WorkoutHealth.swift
+//  WorkoutHealthForm.swift
 //  RecordFeature
 //
-//  Created by 홍승현 on 11/25/23.
+//  Created by 홍승현 on 11/30/23.
 //  Copyright © 2023 kr.codesquad.boostcamp8. All rights reserved.
 //
 
 import Foundation
 
-// TODO: 서버 API와 맞추어야합니다.
-
-/// 건강 데이터를 body로 전달하기 위한 요청(request) 모델입니다. 운동 세션이 종료될 때 이 모델을 사용합니다.
-public struct WorkoutHealth: Encodable {
+/// 자신이 기록한 건강 데이터를 저장할 때 사용합니다.
+public struct WorkoutHealthForm {
   /// 총 운동한 거리
   let distance: Double?
 

iOS/Projects/Features/Record/Sources/Domain/Entities/WorkoutRealTimeModel.swift

@@ -0,0 +1,46 @@
+//
+//  WorkoutRealTimeModel.swift
+//  RecordFeature
+//
+//  Created by 홍승현 on 11/30/23.
+//  Copyright © 2023 kr.codesquad.boostcamp8. All rights reserved.
+//
+
+import Foundation
+
+// MARK: - WorkoutRealTimeModel
+
+/// 운동 데이터를 송수신하는 모델입니다. 소켓 통신 시 사용합니다.
+struct WorkoutRealTimeModel: Codable, Identifiable {
+  /// User Identifier
+  let id: String
+
+  /// room Identifier
+  let roomID: String
+
+  /// 사용자 닉네임
+  let nickname: String
+
+  /// 사용자 건강 데이터
+  let health: WorkoutHealthRealTimeModel
+
+  enum CodingKeys: String, CodingKey {
+    case id
+    case nickname
+    case health
+    case roomID = "roomId"
+  }
+}
+
+// MARK: - WorkoutHealthRealTimeModel
+
+struct WorkoutHealthRealTimeModel: Codable {
+  /// 총 운동한 거리
+  let distance: Double?
+
+  /// 소모한 총 칼로리
+  let calories: Double?
+
+  /// 현재 심박수
+  let heartRate: Double?
+}

iOS/Projects/Features/Record/Sources/Domain/Interfaces/Repositories/WorkoutRecordRepositoryRepresentable.swift

@@ -10,5 +10,5 @@ import Combine
 import Foundation
 
 protocol WorkoutRecordRepositoryRepresentable {
-  func record(usingLocation locationData: [LocationDTO], andHealthData healthData: WorkoutHealth) -> AnyPublisher<Int, Error>
+  func record(usingLocation locationData: [LocationDTO], andHealthData healthData: WorkoutDataForm) -> AnyPublisher<Int, Error>
 }

iOS/Projects/Features/Record/Sources/Domain/Interfaces/Repositories/WorkoutSocketRepositoryRepresentable.swift

@@ -0,0 +1,18 @@
+//
+//  WorkoutSocketRepositoryRepresentable.swift
+//  RecordFeature
+//
+//  Created by 홍승현 on 11/30/23.
+//  Copyright © 2023 kr.codesquad.boostcamp8. All rights reserved.
+//
+
+import Combine
+import Foundation
+
+protocol WorkoutSocketRepositoryRepresentable {
+  /// 참여자의 실시간 운동 정보를 가져옵니다.
+  func fetchParticipantsRealTime() -> AnyPublisher<WorkoutRealTimeModel, Error>
+
+  /// 나의 운동 정보를 전달합니다.
+  func sendMyWorkout(with model: WorkoutRealTimeModel) -> AnyPublisher<Void, Error>
+}