🔗 :: (#256) 알림 설정 개발

ray3238 · web-flow · commit 3e407a11d2fa · 2024-09-17T16:43:49.000+09:00
diff --git a/Projects/Core/Sources/Steps/MyPageStep.swift b/Projects/Core/Sources/Steps/MyPageStep.swift
@@ -3,6 +3,7 @@ import RxFlow
 public enum MyPageStep: Step {
     case myPageIsRequired
     case tabsIsRequired
+    case notificationSettingIsRequired
     case writableReviewIsRequired(_ id: Int)
     case noticeIsRequired
     case confirmIsRequired
diff --git a/Projects/Core/Sources/Steps/NotificationSettingStep.swift b/Projects/Core/Sources/Steps/NotificationSettingStep.swift
@@ -0,0 +1,5 @@
+import RxFlow
+
+public enum NotificationSettingStep: Step {
+    case notificationSettingIsRequired
+}
diff --git a/Projects/Data/Sources/DI/UseCaseAssembly.swift b/Projects/Data/Sources/DI/UseCaseAssembly.swift
@@ -228,5 +228,20 @@ public final class UseCaseAssembly: Assembly {
                 notificationsRepository: resolver.resolve(NotificationsRepository.self)!
             )
         }
+        container.register(SubscribeNotificationUseCase.self) { resolver in
+            SubscribeNotificationUseCase(
+                notificationsRepository: resolver.resolve(NotificationsRepository.self)!
+            )
+        }
+        container.register(SubscribeAllNotificationUseCase.self) { resolver in
+            SubscribeAllNotificationUseCase(
+                notificationsRepository: resolver.resolve(NotificationsRepository.self)!
+            )
+        }
+        container.register(FetchSubscribeStateUseCase.self) { resolver in
+            FetchSubscribeStateUseCase(
+                notificationsRepository: resolver.resolve(NotificationsRepository.self)!
+            )
+        }
     }
 }
diff --git a/Projects/Data/Sources/DTO/Notifications/SubscribeStateListResponseDTO.swift b/Projects/Data/Sources/DTO/Notifications/SubscribeStateListResponseDTO.swift
@@ -0,0 +1,27 @@
+import Foundation
+import Domain
+
+struct SubscribeStateListResponseDTO: Codable {
+    let topics: [SubscribeStateResponseDTO]
+}
+
+public struct SubscribeStateResponseDTO: Codable {
+    let topic: NotificationType
+    let isSubscribed: Bool
+
+    enum CodingKeys: String, CodingKey {
+        case topic
+        case isSubscribed = "subscribed"
+    }
+}
+
+extension SubscribeStateListResponseDTO {
+        func toDomain() -> [SubscribeStateEntity] {
+            topics.map {
+                return SubscribeStateEntity.init(
+                    topic: $0.topic,
+                    isSubscribed: $0.isSubscribed
+                )
+            }
+        }
+}
diff --git a/Projects/Data/Sources/DataSource/API/NotificationsAPI.swift b/Projects/Data/Sources/DataSource/API/NotificationsAPI.swift
@@ -5,6 +5,9 @@ import Domain
 public enum NotificationsAPI {
     case fetchNotificationList
     case patchReadNotification(id: Int)
+    case subscribeNotification(token: String, notificationType: NotificationType)
+    case subscribeAllNotification
+    case fetchSubscribeState
 }
 
 extension NotificationsAPI: JobisAPI {
@@ -21,16 +24,28 @@ extension NotificationsAPI: JobisAPI {
 
         case let .patchReadNotification(id):
             return "/\(id)"
+
+        case .subscribeNotification:
+            return "/topic"
+
+        case .subscribeAllNotification:
+            return "/topics"
+
+        case .fetchSubscribeState:
+            return "/topic"
         }
     }
 
     public var method: Method {
         switch self {
-        case .fetchNotificationList:
+        case .fetchNotificationList, .fetchSubscribeState:
             return .get
 
         case .patchReadNotification:
             return .patch
+
+        case .subscribeNotification, .subscribeAllNotification:
+            return .patch
         }
     }
 
@@ -42,6 +57,16 @@ extension NotificationsAPI: JobisAPI {
 //                  // TODO: 추후 읽음와 안읽음 분기처리 필요
                     ["is_new": ""],
                 encoding: URLEncoding.queryString)
+
+        case let .subscribeNotification(token, notificationType):
+            return .requestParameters(
+                parameters: [
+                    "token": token,
+                    "topic": notificationType.rawValue
+                ],
+                encoding: URLEncoding.queryString
+            )
+
         default:
             return .requestPlain
         }
diff --git a/Projects/Data/Sources/DataSource/Remote/RemoteNotificationsDataSource.swift b/Projects/Data/Sources/DataSource/Remote/RemoteNotificationsDataSource.swift
@@ -5,6 +5,9 @@ import Domain
 public protocol RemoteNotificationsDataSource {
     func fetchNotificationList() -> Single<[NotificationEntity]>
     func patchReadNotification(id: Int) -> Completable
+    func subscribeNotification(token: String, notificationType: NotificationType) -> Completable
+    func subscribeAllNotification() -> Completable
+    func fetchSubscribeState() -> Single<[SubscribeStateEntity]>
 }
 
 final class RemoteNotificationsDataSourceImpl: RemoteBaseDataSource<NotificationsAPI>, RemoteNotificationsDataSource {
@@ -18,4 +21,20 @@ final class RemoteNotificationsDataSourceImpl: RemoteBaseDataSource<Notification
         request(.patchReadNotification(id: id))
             .asCompletable()
     }
+
+    func subscribeNotification(token: String, notificationType: NotificationType) -> Completable {
+        request(.subscribeNotification(token: token, notificationType: notificationType))
+            .asCompletable()
+    }
+
+    func subscribeAllNotification() -> Completable {
+        request(.subscribeAllNotification)
+            .asCompletable()
+    }
+
+    func fetchSubscribeState() -> RxSwift.Single<[Domain.SubscribeStateEntity]> {
+        request(.fetchSubscribeState)
+            .map(SubscribeStateListResponseDTO.self)
+            .map { $0.toDomain() }
+    }
 }
diff --git a/Projects/Data/Sources/Repositories/NotificationsRepositoryImpl.swift b/Projects/Data/Sources/Repositories/NotificationsRepositoryImpl.swift
@@ -17,4 +17,16 @@ struct NotificationsRepositoryImpl: NotificationsRepository {
     func patchReadNotification(id: Int) -> Completable {
         remoteNotificationsDataSource.patchReadNotification(id: id)
     }
+
+    func subscribeNotification(token: String, notificationType: NotificationType) -> Completable {
+        remoteNotificationsDataSource.subscribeNotification(token: token, notificationType: notificationType)
+    }
+
+    func subscribeAllNotification() -> Completable {
+        remoteNotificationsDataSource.subscribeAllNotification()
+    }
+
+    func fetchSubscribeState() -> Single<[SubscribeStateEntity]> {
+        remoteNotificationsDataSource.fetchSubscribeState()
+    }
 }
diff --git a/Projects/Domain/Sources/Entities/Notifications/SubscribeStateEntity.swift b/Projects/Domain/Sources/Entities/Notifications/SubscribeStateEntity.swift
@@ -0,0 +1,14 @@
+import Foundation
+
+public struct SubscribeStateEntity: Equatable, Hashable {
+    public let topic: NotificationType
+    public let isSubscribed: Bool
+
+    public init(
+        topic: NotificationType,
+        isSubscribed: Bool
+    ) {
+        self.topic = topic
+        self.isSubscribed = isSubscribed
+    }
+}
diff --git a/Projects/Domain/Sources/Enums/NotificationType.swift b/Projects/Domain/Sources/Enums/NotificationType.swift
@@ -0,0 +1,8 @@
+import Foundation
+
+public enum NotificationType: String, Codable {
+    case notice = "NEW_NOTICE"
+    case recruitment = "RECRUITMENT_DONE"
+    case application = "APPLICATION_STATUS_CHANGED"
+    case interestRecruitment = "NEW_INTERESTED_RECRUITMENT"
+}
diff --git a/Projects/Domain/Sources/Repositories/NotificationsRepository.swift b/Projects/Domain/Sources/Repositories/NotificationsRepository.swift
@@ -3,4 +3,7 @@ import RxSwift
 public protocol NotificationsRepository {
     func fetchNotificationsList() -> Single<[NotificationEntity]>
     func patchReadNotification(id: Int) -> Completable
+    func subscribeNotification(token: String, notificationType: NotificationType) -> Completable
+    func subscribeAllNotification() -> Completable
+    func fetchSubscribeState() -> Single<[SubscribeStateEntity]>
 }
diff --git a/Projects/Domain/Sources/UseCases/Notifications/FetchSubscribeStateUseCase.swift b/Projects/Domain/Sources/UseCases/Notifications/FetchSubscribeStateUseCase.swift
@@ -0,0 +1,13 @@
+import RxSwift
+
+public struct FetchSubscribeStateUseCase {
+    private let notificationsRepository: NotificationsRepository
+
+    public init(notificationsRepository: NotificationsRepository) {
+        self.notificationsRepository = notificationsRepository
+    }
+
+    public func execute() -> Single<[SubscribeStateEntity]> {
+        notificationsRepository.fetchSubscribeState()
+    }
+}
diff --git a/Projects/Domain/Sources/UseCases/Notifications/SubscribeAllNotificationUseCase.swift b/Projects/Domain/Sources/UseCases/Notifications/SubscribeAllNotificationUseCase.swift
@@ -0,0 +1,13 @@
+import RxSwift
+
+public struct SubscribeAllNotificationUseCase {
+    private let notificationsRepository: NotificationsRepository
+
+    public init(notificationsRepository: NotificationsRepository) {
+        self.notificationsRepository = notificationsRepository
+    }
+
+    public func execute() -> Completable {
+        notificationsRepository.subscribeAllNotification()
+    }
+}
diff --git a/Projects/Domain/Sources/UseCases/Notifications/SubscribeNotificationUseCase.swift b/Projects/Domain/Sources/UseCases/Notifications/SubscribeNotificationUseCase.swift
@@ -0,0 +1,13 @@
+import RxSwift
+
+public struct SubscribeNotificationUseCase {
+    private let notificationsRepository: NotificationsRepository
+
+    public init(notificationsRepository: NotificationsRepository) {
+        self.notificationsRepository = notificationsRepository
+    }
+
+    public func execute(token: String, notificationType: NotificationType) -> Completable {
+        notificationsRepository.subscribeNotification(token: token, notificationType: notificationType)
+    }
+}
diff --git a/Projects/Flow/Sources/MyPage/MyPageFlow.swift b/Projects/Flow/Sources/MyPage/MyPageFlow.swift
@@ -28,6 +28,9 @@ public final class MyPageFlow: Flow {
         case let .writableReviewIsRequired(id):
             return navigateToWritableReview(id)
 
+        case .notificationSettingIsRequired:
+            return navigateToNotification()
+
         case .noticeIsRequired:
             return navigateToNotice()
 
@@ -76,6 +79,21 @@ extension MyPageFlow {
         ))
     }
 
+    func navigateToNotification() -> FlowContributors {
+        let notificationSettingFlow = NotificationSettingFlow(container: container)
+
+        Flows.use(notificationSettingFlow, when: .created) { root in
+            self.rootViewController.pushViewController(
+                root, animated: true
+            )
+        }
+
+        return .one(flowContributor: .contribute(
+            withNextPresentable: notificationSettingFlow,
+            withNextStepper: OneStepper(withSingleStep: NotificationSettingStep.notificationSettingIsRequired)
+        ))
+    }
+
     func navigateToNotice() -> FlowContributors {
         let noticeFlow = NoticeFlow(container: container)
 
diff --git a/Projects/Flow/Sources/MyPage/Notification/NotificationSettingFlow.swift b/Projects/Flow/Sources/MyPage/Notification/NotificationSettingFlow.swift
@@ -0,0 +1,36 @@
+import UIKit
+import Presentation
+import Swinject
+import RxFlow
+import Core
+
+public final class NotificationSettingFlow: Flow {
+    public let container: Container
+    private let rootViewController: NotificationSettingViewController
+    public var root: Presentable {
+        return rootViewController
+    }
+
+    public init(container: Container) {
+        self.container = container
+        self.rootViewController = container.resolve(NotificationSettingViewController.self)!
+    }
+
+    public func navigate(to step: Step) -> FlowContributors {
+        guard let step = step as? NotificationSettingStep else { return .none }
+
+        switch step {
+        case .notificationSettingIsRequired:
+            return navigateToNotificationSetting()
+        }
+    }
+}
+
+private extension NotificationSettingFlow {
+    func navigateToNotificationSetting() -> FlowContributors {
+        return .one(flowContributor: .contribute(
+            withNextPresentable: rootViewController,
+            withNextStepper: rootViewController.viewModel
+        ))
+    }
+}
diff --git a/Projects/Modules/DesignSystem/Sources/Image/JobisIcon.swift b/Projects/Modules/DesignSystem/Sources/Image/JobisIcon.swift
@@ -22,6 +22,7 @@ public enum JobisIcon {
     case searchIcon
     case filterIcon
     case profile
+    case bellOnPrimary
     case bell
     case officeBuilding
     case snowman
@@ -89,6 +90,9 @@ public enum JobisIcon {
         case .profile:
             return dsIcons.profile.image
 
+        case .bellOnPrimary:
+            return dsIcons.bellOnPrimary.image
+
         case .bell:
             return dsIcons.bell.image
 
diff --git a/Projects/Presentation/Sources/DI/PresentationAssembly.swift b/Projects/Presentation/Sources/DI/PresentationAssembly.swift
@@ -182,6 +182,18 @@ public final class PresentationAssembly: Assembly {
             )
         }
 
+        container.register(NotificationSettingViewModel.self) { resolver in
+            NotificationSettingViewModel(
+                subscribeNotificationUseCase: resolver.resolve(SubscribeNotificationUseCase.self)!,
+                subscribeAllNotificationUseCase: resolver.resolve(SubscribeAllNotificationUseCase.self)!,
+                fetchSubscribeStateUseCase: resolver.resolve(FetchSubscribeStateUseCase.self)!
+            )
+        }
+
+        container.register(NotificationSettingViewController.self) { resolver in
+            NotificationSettingViewController(resolver.resolve(NotificationSettingViewModel.self)!)
+        }
+
         container.register(NoticeViewModel.self) { resolver in
             NoticeViewModel(
                 fetchNoticeListUseCase: resolver.resolve(FetchNoticeListUseCase.self)!
diff --git a/Projects/Presentation/Sources/MyPage/Components/NotificationSettingSectionView.swift b/Projects/Presentation/Sources/MyPage/Components/NotificationSettingSectionView.swift
@@ -0,0 +1,32 @@
+import UIKit
+import SnapKit
+import Then
+import RxSwift
+import RxCocoa
+import DesignSystem
+
+final class NotificationSettingSectionView: BaseView {
+    enum NotificationSectionType: Int {
+        case notificationSetting
+    }
+    private let notificationSettingSectionView = SectionView(
+        menuText: "알림",
+        items: [
+            ("알림 설정", .jobisIcon(.bellOnPrimary))
+        ]
+    )
+
+    override func addView() {
+        self.addSubview(notificationSettingSectionView)
+    }
+
+    override func setLayout() {
+        notificationSettingSectionView.snp.makeConstraints {
+            $0.edges.equalToSuperview()
+        }
+    }
+
+    func getSelectedItem(type: NotificationSectionType) -> Observable<IndexPath> {
+        self.notificationSettingSectionView.getSelectedItem(index: type.rawValue)
+    }
+}
diff --git a/Projects/Presentation/Sources/MyPage/MyPageViewController.swift b/Projects/Presentation/Sources/MyPage/MyPageViewController.swift
diff --git a/Projects/Presentation/Sources/MyPage/MyPageViewModel.swift b/Projects/Presentation/Sources/MyPage/MyPageViewModel.swift
diff --git a/Projects/Presentation/Sources/NotificationSetting/Component/NotificationSectionView.swift b/Projects/Presentation/Sources/NotificationSetting/Component/NotificationSectionView.swift
diff --git a/Projects/Presentation/Sources/NotificationSetting/NotificationSettingViewController.swift b/Projects/Presentation/Sources/NotificationSetting/NotificationSettingViewController.swift
diff --git a/Projects/Presentation/Sources/NotificationSetting/NotificationSettingViewModel.swift b/Projects/Presentation/Sources/NotificationSetting/NotificationSettingViewModel.swift

Original file line number	Diff line number	Diff line change
`@@ -228,5 +228,20 @@ public final class UseCaseAssembly: Assembly {`
`228`	`228`	`notificationsRepository: resolver.resolve(NotificationsRepository.self)!`
`229`	`229`	`)`
`230`	`230`	`}`
	`231`	`+ container.register(SubscribeNotificationUseCase.self) { resolver in`
	`232`	`+ SubscribeNotificationUseCase(`
	`233`	`+ notificationsRepository: resolver.resolve(NotificationsRepository.self)!`
	`234`	`+ )`
	`235`	`+ }`
	`236`	`+ container.register(SubscribeAllNotificationUseCase.self) { resolver in`
	`237`	`+ SubscribeAllNotificationUseCase(`
	`238`	`+ notificationsRepository: resolver.resolve(NotificationsRepository.self)!`
	`239`	`+ )`
	`240`	`+ }`
	`241`	`+ container.register(FetchSubscribeStateUseCase.self) { resolver in`
	`242`	`+ FetchSubscribeStateUseCase(`
	`243`	`+ notificationsRepository: resolver.resolve(NotificationsRepository.self)!`
	`244`	`+ )`
	`245`	`+ }`
`231`	`246`	`}`
`232`	`247`	`}`
Original file line number	Diff line number	Diff line change
`@@ -3,4 +3,7 @@ import RxSwift`
`3`	`3`	`public protocol NotificationsRepository {`
`4`	`4`	`func fetchNotificationsList() -> Single<[NotificationEntity]>`
`5`	`5`	`func patchReadNotification(id: Int) -> Completable`
	`6`	`+ func subscribeNotification(token: String, notificationType: NotificationType) -> Completable`
	`7`	`+ func subscribeAllNotification() -> Completable`
	`8`	`+ func fetchSubscribeState() -> Single<[SubscribeStateEntity]>`
`6`	`9`	`}`