[Feat-T3-102] 온보딩 서버 통신 구현

Projects/DataSource/Sources/Common/DataSourceDependencyAssembler.swift

@@ -25,13 +25,17 @@ public struct DataSourceDependencyAssembler: DependencyAssemblerProtocol {
             let networkService = DIContainer.shared.resolve(type: NetworkServiceProtocol.self),
             let keychainStorage = DIContainer.shared.resolve(type: KeychainStorageProtocol.self),
             let userDefaultsStorage = DIContainer.shared.resolve(type: UserDefaultsStorageProtocol.self)
-        else { return }
+        else { fatalError("networkService, keychainStorage, userDefaultsStorage 의존성이 등록되지 않았습니다.") }
 
         DIContainer.shared.register(type: AuthRepositoryProtocol.self) { _ in
             return AuthRepository(
                 networkService: networkService,
                 keychainStorage: keychainStorage,
                 userDefaultsStorage: userDefaultsStorage)
         }
+
+        DIContainer.shared.register(type: OnboardingRepositoryProtocol.self) { _ in
+            return OnboardingRepository(networkService: networkService, keychainStorage: keychainStorage)
+        }
     }
 }

Projects/DataSource/Sources/Common/Error/AuthError.swift

@@ -13,6 +13,7 @@ enum AuthError: Error, CustomStringConvertible {
     case nicknameSaveFailed
     case nicknameLoadFailed
     case nicknameRemoveFailed
+    case invalidUserData
     case unknown(Error)
 
     public var description: String {
@@ -31,6 +32,8 @@ enum AuthError: Error, CustomStringConvertible {
             return "닉네임 불러오기에 실패했습니다."
         case .nicknameRemoveFailed:
             return "닉네임 삭제에 실패했습니다."
+        case .invalidUserData:
+            return "서버 응답에 사용자 정보가 포함되어 있지 않습니다."
         case .unknown(let error):
             return "알 수 없는 에러가 발생했습니다. \(error.localizedDescription)"
         }

Projects/DataSource/Sources/DTO/EmptyResponseDTO.swift

@@ -0,0 +1,8 @@
+//
+//  EmptyResponseDTO.swift
+//  DataSource
+//
+//  Created by 최정인 on 7/15/25.
+//
+
+struct EmptyResponseDTO: Decodable {}

Projects/DataSource/Sources/DTO/LoginResponseDTO.swift

@@ -7,9 +7,7 @@
 
 import Domain
 
-typealias LoginResponseDTO = BaseResponseDTO<LoginResponse>
-
-struct LoginResponse: Decodable {
+struct LoginResponseDTO: Decodable {
     let accessToken: String
     let refreshToken: String
     let userState: String
@@ -21,7 +19,7 @@ struct LoginResponse: Decodable {
     }
 }
 
-extension LoginResponse {
+extension LoginResponseDTO {
     func toUserEntity() -> UserEntity {
         return UserEntity(
             accessToken: accessToken,

Projects/DataSource/Sources/DTO/RecommendedRoutineDTO.swift

@@ -0,0 +1,43 @@
+//
+//  RecommendedRoutineDTO.swift
+//  DataSource
+//
+//  Created by 최정인 on 7/15/25.
+//
+
+import Domain
+
+struct RecommendedRoutineListResponseDTO: Decodable {
+    let recommendedRoutines: [RecommendedRoutineDTO]
+}
+
+struct RecommendedRoutineDTO: Decodable {
+    let id: Int
+    let routineName: String
+    let routineDescription: String
+    let subRoutines: [SubRoutine]
+
+    enum CodingKeys: String, CodingKey {
+        case id = "recommendedRoutineId"
+        case routineName = "recommendedRoutineName"
+        case routineDescription
+        case subRoutines = "recommendedSubRoutines"
+    }
+
+    func toRecommendedRoutineEntity() -> RecommendedRoutineEntity {
+        return RecommendedRoutineEntity(
+            id: id,
+            title: routineName,
+            description: routineDescription)
+    }
+}
+
+struct SubRoutine: Decodable {
+    let id: Int
+    let routineName: String
+
+    enum CodingKeys: String, CodingKey {
+        case id = "recommendedSubRoutineId"
+        case routineName = "recommendedSubRoutineName"
+    }
+}

Projects/DataSource/Sources/Endpoint/OnboardingEndpoint.swift

@@ -0,0 +1,59 @@
+//
+//  OnboardingEndpoint.swift
+//  DataSource
+//
+//  Created by 최정인 on 7/15/25.
+//
+
+import Foundation
+
+enum OnboardingEndpoint {
+    case registerOnboarding(accessToken: String, choices: [String: String])
+    case registerRecommendedRoutine(accessToken: String, selectedRoutines: [Int])
+}
+
+extension OnboardingEndpoint: Endpoint {
+    var baseURL: String {
+        return AppProperties.baseURL + "/api/v1/onboardings"
+    }
+
+    var path: String {
+        switch self {
+        case .registerOnboarding: baseURL
+        case .registerRecommendedRoutine: baseURL + "/routines"
+        }
+    }
+
+    var method: HTTPMethod {
+        return .post
+    }
+
+    var headers: [String : String] {
+        var headers: [String: String] = [
+            "Content-Type": "application/json",
+            "accept": "*/*"
+        ]
+
+        switch self {
+        case .registerOnboarding(let accessToken, _):
+            headers["Authorization"] = "Bearer \(accessToken)"
+        case .registerRecommendedRoutine(let accessToken, _):
+            headers["Authorization"] = "Bearer \(accessToken)"
+        }
+
+        return headers
+    }
+
+    var queryParameters: [String : String] {
+        return [:]
+    }
+
+    var bodyParameters: [String : Any] {
+        switch self {
+        case .registerOnboarding(_, let choices):
+            return choices
+        case .registerRecommendedRoutine(_, let selectedRoutines):
+            return ["recommendedRoutineIds": selectedRoutines]
+        }
+    }
+}

Projects/DataSource/Sources/Protocols/NetworkServiceProtocol.swift → Projects/DataSource/Sources/Protocol/NetworkServiceProtocol.swift

@@ -15,5 +15,5 @@ public protocol NetworkServiceProtocol {
     ///   - endpoint: 요청을 보낼 API Endpoint 정보
     ///   - type: 디코딩할 Response DTO 타입
     /// - Returns: 응답 데이터를 디코딩한 객체
-    func request<T: Decodable>(endpoint: Endpoint, type: T.Type) async throws -> T
+    func request<T: Decodable>(endpoint: Endpoint, type: T.Type) async throws -> T?
 }

Projects/DataSource/Sources/Repositories/AuthRepository.swift → Projects/DataSource/Sources/Repository/AuthRepository.swift

@@ -11,12 +11,12 @@ import Shared
 import KakaoSDKUser
 import KakaoSDKAuth
 
-public final class AuthRepository: AuthRepositoryProtocol {
+final class AuthRepository: AuthRepositoryProtocol {
     private let networkService: NetworkServiceProtocol
     private let keychainStorage: KeychainStorageProtocol
     private let userDefaultsStorage: UserDefaultsStorageProtocol
 
-    public init(
+    init(
         networkService: NetworkServiceProtocol,
         keychainStorage: KeychainStorageProtocol,
         userDefaultsStorage: UserDefaultsStorageProtocol
@@ -26,52 +26,60 @@ public final class AuthRepository: AuthRepositoryProtocol {
         self.userDefaultsStorage = userDefaultsStorage
     }
 
-    public func kakaoLogin() async throws {
+    func kakaoLogin() async throws -> UserEntity {
         let accessToken = try await fetchKakaoToken()
-        try await requestServerLogin(socialType: .kakao, nickname: nil, token: accessToken)
+        let user = try await requestServerLogin(
+            socialType: .kakao,
+            nickname: nil,
+            token: accessToken)
+        return user
     }
 
-    public func appleLogin(nickname: String?, authToken: String) async throws {
+    func appleLogin(nickname: String?, authToken: String) async throws -> UserEntity {
         var savedNickname: String = ""
         if let nickname {
             try saveNickname(nickname: nickname)
             savedNickname = nickname
         } else {
             savedNickname = try loadNickname()
         }
-        try await requestServerLogin(socialType: .apple, nickname: savedNickname, token: authToken)
+        let user = try await requestServerLogin(
+            socialType: .apple,
+            nickname: savedNickname,
+            token: authToken)
+        return user
     }
 
-    public func submitAgreement(agreements: [TermsType : Bool]) async throws {
+    func submitAgreement(agreements: [TermsType : Bool]) async throws {
         let accessToken = try loadToken(tokenType: .accessToken)
         let endpoint = AuthEndpoint.agreements(accessToken: accessToken, agreements: agreements)
-        let response = try await networkService.request(endpoint: endpoint, type: BaseResponseDTO<EmptyResponse>.self)
-        BitnagilLogger.log(logType: .debug, message: "\(response)")
+        _ = try await networkService.request(endpoint: endpoint, type: EmptyResponseDTO.self)
     }
 
-    public func logout() async throws {
+    func logout() async throws {
         let accessToken = try loadToken(tokenType: .accessToken)
         let endpoint = AuthEndpoint.logout(accessToken: accessToken)
-        let response = try await networkService.request(endpoint: endpoint, type: BaseResponseDTO<String>.self)
+        _ = try await networkService.request(endpoint: endpoint, type: String.self)
         try removeToken()
-        BitnagilLogger.log(logType: .debug, message: "\(response.message)")
     }
 
-    public func withdraw() async throws {
+    func withdraw() async throws {
         let accessToken = try loadToken(tokenType: .accessToken)
         let endpoint = AuthEndpoint.withdraw(accessToken: accessToken)
-        let response = try await networkService.request(endpoint: endpoint, type: BaseResponseDTO<String>.self)
+        _ = try await networkService.request(endpoint: endpoint, type: String.self)
         try removeToken()
         try removeNickname()
-        BitnagilLogger.log(logType: .debug, message: "\(response.message)")
     }
 
-    public func reissueToken() async throws {
+    func reissueToken() async throws {
         let refreshToken = try loadToken(tokenType: .refreshToken)
         let endpoint = AuthEndpoint.reissue(refreshToken: refreshToken)
-        let userResponse = try await networkService.request(endpoint: endpoint, type: LoginResponseDTO.self)
+
+        guard let userResponse = try await networkService.request(endpoint: endpoint, type: LoginResponseDTO.self)
+        else { return }
+        let userEntity = userResponse.toUserEntity()
+
         guard
-            let userEntity = userResponse.data?.toUserEntity(),
             saveToken(tokenType: .accessToken, token: userEntity.accessToken),
             saveToken(tokenType: .refreshToken, token: userEntity.refreshToken)
         else { throw AuthError.tokenSaveFailed }
@@ -80,7 +88,7 @@ public final class AuthRepository: AuthRepositoryProtocol {
         BitnagilLogger.log(logType: .debug, message: "AccessToken Saved: \(userEntity.accessToken)")
         BitnagilLogger.log(logType: .debug, message: "RefreshToken Saved: \(userEntity.refreshToken)")
     }
-    
+
     private func fetchKakaoToken() async throws -> String {
         try await withCheckedThrowingContinuation { continuation in
             let resultHandler: (OAuthToken?, Error?) -> Void = { oauthToken, error in
@@ -107,22 +115,26 @@ public final class AuthRepository: AuthRepositoryProtocol {
         socialType: SocialLoginType,
         nickname: String?,
         token: String
-    ) async throws {
+    ) async throws -> UserEntity {
         let endpoint = AuthEndpoint.login(
             socialLoginType: socialType,
             nickname: nickname,
             token: token)
 
-        let userResponse = try await networkService.request(endpoint: endpoint, type: LoginResponseDTO.self)
+        guard let userResponse = try await networkService.request(endpoint: endpoint, type: LoginResponseDTO.self)
+        else { throw AuthError.invalidUserData }
+
+        let userEntity = userResponse.toUserEntity()
         guard
-            let userEntity = userResponse.data?.toUserEntity(),
             saveToken(tokenType: .accessToken, token: userEntity.accessToken),
             saveToken(tokenType: .refreshToken, token: userEntity.refreshToken)
         else { throw AuthError.tokenSaveFailed }
 
         BitnagilLogger.log(logType: .debug, message: "User Logined: \(userEntity.userState)")
         BitnagilLogger.log(logType: .debug, message: "AccessToken Saved: \(userEntity.accessToken)")
         BitnagilLogger.log(logType: .debug, message: "RefreshToken Saved: \(userEntity.refreshToken)")
+
+        return userEntity
     }
 
     private func saveToken(tokenType: TokenType, token: String) -> Bool {

Projects/DataSource/Sources/Repository/OnboardingRepository.swift

@@ -0,0 +1,42 @@
+//
+//  OnboardingRepository.swift
+//  DataSource
+//
+//  Created by 최정인 on 7/15/25.
+//
+
+import Domain
+
+final class OnboardingRepository: OnboardingRepositoryProtocol {
+    private let networkService: NetworkServiceProtocol
+    private let keychainStorage: KeychainStorageProtocol
+
+    init(networkService: NetworkServiceProtocol, keychainStorage: KeychainStorageProtocol) {
+        self.networkService = networkService
+        self.keychainStorage = keychainStorage
+    }
+
+    func registerOnboarding(onboardingChoices: [String : String]) async throws -> [RecommendedRoutineEntity] {
+        let accessToken = try loadToken(tokenType: .accessToken)
+        let endpoint = OnboardingEndpoint.registerOnboarding(accessToken: accessToken, choices: onboardingChoices)
+
+        guard let response = try await networkService.request(endpoint: endpoint, type: RecommendedRoutineListResponseDTO.self)
+        else { return [] }
+
+        let recommendedRoutineEntity = response.recommendedRoutines.compactMap({ $0.toRecommendedRoutineEntity() })
+        return recommendedRoutineEntity
+    }
+
+    func registerRecommendedRoutines(selectedRoutines: [Int]) async throws {
+        let accessToken = try loadToken(tokenType: .accessToken)
+        let endpoint = OnboardingEndpoint.registerRecommendedRoutine(accessToken: accessToken, selectedRoutines: selectedRoutines)
+        _ = try await networkService.request(endpoint: endpoint, type: EmptyResponseDTO.self)
+    }
+
+    private func loadToken(tokenType: TokenType) throws -> String {
+        guard let token = keychainStorage.load(forKey: tokenType.rawValue) else {
+            throw AuthError.tokenLoadFailed
+        }
+        return token
+    }
+}

Projects/Domain/Sources/DomainDependencyAssembler.swift

@@ -18,9 +18,8 @@ public struct DomainDependencyAssembler: DependencyAssemblerProtocol {
     public func assemble() {
         preAssembler.assemble()
 
-        guard let authRepository = DIContainer.shared.resolve(type: AuthRepositoryProtocol.self) else {
-            return
-        }
+        guard let authRepository = DIContainer.shared.resolve(type: AuthRepositoryProtocol.self)
+        else { fatalError("authRepository 의존성이 등록되지 않았습니다.") }
 
         DIContainer.shared.register(type: LoginUseCaseProtocol.self) { _ in
             return LoginUseCase(authRepository: authRepository)
@@ -33,5 +32,12 @@ public struct DomainDependencyAssembler: DependencyAssemblerProtocol {
         DIContainer.shared.register(type: WithdrawUseCaseProtocol.self) { _ in
             return WithdrawUseCase(authRepository: authRepository)
         }
+
+        DIContainer.shared.register(type: OnboardingUseCaseProtocol.self) { container in
+            guard let onboardingRepository = container.resolve(type: OnboardingRepositoryProtocol.self)
+            else { fatalError("onboardingRepository 의존성이 등록되지 않았습니다.") }
+
+            return OnboardingUseCase(onboardingRepository: onboardingRepository)
+        }
     }
 }