feat: 알림 기능 구현

src/Projects/BKData/Sources/API/UserAPI.swift

@@ -5,6 +5,8 @@ import Foundation
 enum UserAPI {
     case me
     case termsAgreement(termsAgreed: Bool)
+    case upsertFCMToken(fcmToken: String)
+    case upsertNotificationSettings(notificationEnabled: Bool)
 }
 
 extension UserAPI: RequestTarget {
@@ -18,21 +20,25 @@ extension UserAPI: RequestTarget {
             return ""
         case .termsAgreement:
             return "/terms-agreement"
+        case .upsertFCMToken:
+            return "/fcm-token"
+        case .upsertNotificationSettings:
+            return "/notification-settings"
         }
     }
 
     var method: HTTPMethod {
         switch self {
         case .me:
             return .get
-        case .termsAgreement:
+        case .termsAgreement, .upsertFCMToken, .upsertNotificationSettings:
             return .put
         }
     }
 
     var headers: [String: String] {
         switch self {
-        case .termsAgreement:
+        case .termsAgreement, .upsertFCMToken, .upsertNotificationSettings:
             return [
                 "Content-Type": "application/json"
             ]
@@ -45,6 +51,10 @@ extension UserAPI: RequestTarget {
         switch self {
         case .termsAgreement(let termsAgreed):
             return TermsAgreementRequestDTO(termsAgreed: termsAgreed)
+        case .upsertFCMToken(let fcmToken):
+            return UpsertFCMTokenRequestDTO(fcmToken: fcmToken)
+        case .upsertNotificationSettings(let notificationEnabled):
+            return NotificationStatusRequestDTO(notificationEnabled: notificationEnabled)
         case .me:
             return nil
         }

src/Projects/BKData/Sources/DTO/Request/NotificationStatusRequestDTO.swift

@@ -0,0 +1,7 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import Foundation
+
+struct NotificationStatusRequestDTO: Encodable {
+    let notificationEnabled: Bool
+}

src/Projects/BKData/Sources/DTO/Request/UpsertFCMTokenRequestDTO.swift

@@ -0,0 +1,7 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import Foundation
+
+struct UpsertFCMTokenRequestDTO: Encodable {
+    let fcmToken: String
+}

src/Projects/BKData/Sources/DTO/Response/UserProfileResponseDTO.swift

@@ -9,14 +9,16 @@ public struct UserProfileResponseDTO: Decodable {
     public let nickname: String
     public let provider: String
     public let termsAgreed: Bool
+    public let notificationEnabled: Bool
 
     public func toUserProfile() -> UserProfile {
         return UserProfile(
             id: self.id,
             email: self.email,
             nickname: self.nickname,
             provider: self.provider,
-            termsAgreed: self.termsAgreed
+            termsAgreed: self.termsAgreed,
+            notificationEnabled: self.notificationEnabled
         )
     }
 }

src/Projects/BKData/Sources/DataAssembly.swift

@@ -129,5 +129,23 @@ public struct DataAssembly: Assembly {
             @Autowired var networkProvider: NetworkProvider
             return DefaultAppStoreRepository(networkProvider: networkProvider)
         }
+
+        container.register(
+            type: NotificationRepository.self
+        ) { _ in
+            @Autowired(name: "OAuth") var networkProvider: NetworkProvider
+            return DefaultNotificationRepository(networkProvider: networkProvider)
+        }
+
+        container.register(
+            type: PushTokenRepository.self
+        ) { _ in
+            @Autowired var pushTokenProvider: PushTokenProvider
+            @Autowired var pushTokenStore: PushTokenStore
+            return DefaultPushTokenRepository(
+                pushTokenProvider: pushTokenProvider,
+                pushTokenStore: pushTokenStore
+            )
+        }
     }
 }

src/Projects/BKData/Sources/Interface/Storage/PushTokenProvider.swift

@@ -0,0 +1,7 @@
+// Copyright © 2025 Booket. All rights reserved
+
+public protocol PushTokenProvider {
+    var fcmToken: String? { get }
+    var isSyncNeeded: Bool? { get }
+    func clearCache()
+}

src/Projects/BKData/Sources/Interface/Storage/PushTokenStore.swift

@@ -0,0 +1,14 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import BKDomain
+import Combine
+
+public protocol PushTokenStore {
+    func save(
+        fcmToken: String
+    ) -> AnyPublisher<Void, TokenError>
+
+    func resetSyncNeeded() -> AnyPublisher<Void, TokenError>
+
+    func clear() -> AnyPublisher<Void, TokenError>
+}

src/Projects/BKData/Sources/Repository/DefaultNotificationRepository.swift

@@ -0,0 +1,41 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import BKCore
+import BKDomain
+import Combine
+
+public struct DefaultNotificationRepository: NotificationRepository {
+    private let networkProvider: NetworkProvider
+
+    public init(networkProvider: NetworkProvider) {
+        self.networkProvider = networkProvider
+    }
+
+    public func upsertFCMToken(
+        fcmToken: String
+    ) -> AnyPublisher<Void, DomainError> {
+        networkProvider.request(
+            target: UserAPI.upsertFCMToken(fcmToken: fcmToken),
+            type: UserProfileResponseDTO.self
+        )
+        .debugError(logger: AppLogger.network)
+        .mapError { $0.toDomainError() }
+        .map { _ in }
+        .eraseToAnyPublisher()
+    }
+
+    public func upsertNotificationSettings(
+        notificationSettings: Bool
+    ) -> AnyPublisher<Bool, DomainError> {
+        networkProvider.request(
+            target: UserAPI.upsertNotificationSettings(
+                notificationEnabled: notificationSettings
+            ),
+            type: UserProfileResponseDTO.self
+        )
+        .debugError(logger: AppLogger.network)
+        .mapError { $0.toDomainError() }
+        .map { $0.notificationEnabled }
+        .eraseToAnyPublisher()
+    }
+}

src/Projects/BKData/Sources/Repository/DefaultPushTokenRepository.swift

@@ -0,0 +1,43 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import BKCore
+import BKDomain
+import Combine
+
+public struct DefaultPushTokenRepository: PushTokenRepository {
+    private let pushTokenProvider: PushTokenProvider
+    private let pushTokenStore: PushTokenStore
+
+    public init(
+        pushTokenProvider: PushTokenProvider,
+        pushTokenStore: PushTokenStore
+    ) {
+        self.pushTokenProvider = pushTokenProvider
+        self.pushTokenStore = pushTokenStore
+    }
+
+    public func getFCMToken() -> String? {
+        return pushTokenProvider.fcmToken
+    }
+
+    public func isSyncNeeded() -> Bool {
+        return pushTokenProvider.isSyncNeeded ?? false
+    }
+
+    public func resetSyncNeeded() -> AnyPublisher<Void, DomainError> {
+        return pushTokenStore
+            .resetSyncNeeded()
+            .map { _ in
+                self.pushTokenProvider.clearCache()
+            }
+            .mapError { error in
+                Log.error("Failed to reset isSyncNeeded flag: \(error)", logger: AppLogger.storage)
+                return .clientError
+            }
+            .eraseToAnyPublisher()
+    }
+
+    public func clearCache() {
+        pushTokenProvider.clearCache()
+    }
+}

src/Projects/BKDomain/Sources/DomainAssembly.swift

@@ -228,5 +228,25 @@ public struct DomainAssembly: Assembly {
             @Autowired var repository: BookRepository
             return DefaultDeleteBookUseCase(repository: repository)
         }
+
+        container.register(
+            type: SyncFCMTokenUseCase.self
+        ) { _ in
+            @Autowired var pushTokenRepository: PushTokenRepository
+            @Autowired var notificationRepository: NotificationRepository
+            return DefaultSyncFCMTokenUseCase(
+                pushTokenRepository: pushTokenRepository,
+                notificationRepository: notificationRepository
+            )
+        }
+
+        container.register(
+            type: UpdateNotificationSettingsUseCase.self
+        ) { _ in
+            @Autowired var notificationRepository: NotificationRepository
+            return DefaultUpdateNotificationSettingsUseCase(
+                notificationRepository: notificationRepository
+            )
+        }
     }
 }

src/Projects/BKDomain/Sources/Entity/UserProfile.swift

@@ -8,18 +8,21 @@ public struct UserProfile {
     public let nickname: String
     public let provider: String
     public let termsAgreed: Bool
+    public let notificationEnabled: Bool
 
     public init(
         id: String,
         email: String,
         nickname: String,
         provider: String,
-        termsAgreed: Bool
+        termsAgreed: Bool,
+        notificationEnabled: Bool
     ) {
         self.id = id
         self.email = email
         self.nickname = nickname
         self.provider = provider
         self.termsAgreed = termsAgreed
+        self.notificationEnabled = notificationEnabled
     }
 }

src/Projects/BKDomain/Sources/Error/AuthError.swift

@@ -10,3 +10,20 @@ public enum AuthError: Error {
     case termsNotAccepted
     case unknown
 }
+
+public extension AuthError {
+    func toDomainError() -> DomainError {
+        switch self {
+        case .sdkError(message: let message):
+            return .clientError
+        case .serverError(message: let message):
+            return .internalServerError
+        case .missingToken:
+            return .unauthorized
+        case .termsNotAccepted:
+            return .unauthorized
+        case .unknown:
+            return .unknown
+        }
+    }
+}

src/Projects/BKDomain/Sources/Error/DomainError.swift

@@ -7,4 +7,5 @@ public enum DomainError: Error, Equatable {
     case clientError
     case internalServerError
     case timeout
+    case unknown
 }

src/Projects/BKDomain/Sources/Interface/Repository/NotificationRepository.swift

@@ -0,0 +1,13 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import Combine
+
+public protocol NotificationRepository {
+    func upsertFCMToken(
+        fcmToken: String
+    ) -> AnyPublisher<Void, DomainError>
+
+    func upsertNotificationSettings(
+        notificationSettings: Bool
+    ) -> AnyPublisher<Bool, DomainError>
+}

src/Projects/BKDomain/Sources/Interface/Repository/PushTokenRepository.swift

@@ -0,0 +1,10 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import Combine
+
+public protocol PushTokenRepository {
+    func getFCMToken() -> String?
+    func isSyncNeeded() -> Bool
+    func resetSyncNeeded() -> AnyPublisher<Void, DomainError>
+    func clearCache()
+}

src/Projects/BKDomain/Sources/Interface/Usecase/SyncFCMTokenUseCase.swift

@@ -0,0 +1,10 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import Combine
+import Foundation
+
+/// FCM 토큰이 동기화가 필요한 경우 서버에 업데이트합니다.
+/// isSyncNeeded 플래그를 확인하고, 필요시 서버에 전송하며, 성공 시 플래그를 리셋합니다.
+public protocol SyncFCMTokenUseCase {
+    func execute() -> AnyPublisher<Void, DomainError>
+}

src/Projects/BKDomain/Sources/Interface/Usecase/UpdateNotificationSettingsUseCase.swift

@@ -0,0 +1,9 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import Combine
+import Foundation
+
+/// 알림 설정을 서버에 업데이트합니다.
+public protocol UpdateNotificationSettingsUseCase {
+    func execute(isEnabled: Bool) -> AnyPublisher<Bool, DomainError>
+}

src/Projects/BKDomain/Sources/UseCase/DefaultSyncFCMTokenUseCase.swift

@@ -0,0 +1,40 @@
+// Copyright © 2025 Booket. All rights reserved
+
+import BKCore
+import Combine
+import Foundation
+
+public struct DefaultSyncFCMTokenUseCase: SyncFCMTokenUseCase {
+    private let pushTokenRepository: PushTokenRepository
+    private let notificationRepository: NotificationRepository
+
+    public init(
+        pushTokenRepository: PushTokenRepository,
+        notificationRepository: NotificationRepository
+    ) {
+        self.pushTokenRepository = pushTokenRepository
+        self.notificationRepository = notificationRepository
+    }
+
+    public func execute() -> AnyPublisher<Void, DomainError> {
+        guard pushTokenRepository.isSyncNeeded() else {
+            return Just(())
+                .setFailureType(to: DomainError.self)
+                .eraseToAnyPublisher()
+        }
+
+        guard let fcmToken = pushTokenRepository.getFCMToken() else {
+            return Just(())
+                .setFailureType(to: DomainError.self)
+                .eraseToAnyPublisher()
+        }
+
+        return notificationRepository
+            .upsertFCMToken(fcmToken: fcmToken)
+            .debugError(logger: AppLogger.network)
+            .flatMap { _ -> AnyPublisher<Void, DomainError> in
+                return self.pushTokenRepository.resetSyncNeeded()
+            }
+            .eraseToAnyPublisher()
+    }
+}