Feat/notification

Koin/Domain/Model/Core/AppPath.swift → Common/Core/AppPath.swift

@@ -7,7 +7,7 @@
 
 import Foundation
 
-enum AppPath: String {
+enum AppPath: String, Codable {
     case home
     case login
     case shop

Common/Core/NotificationHistoryError.swift

@@ -0,0 +1,14 @@
+//
+//  NotificationHistoryError.swift
+//  koin
+//
+//  Created by 홍기정 on 7/7/26.
+//
+
+import Foundation
+
+struct NotificationHistoryError: Error {
+    let message: String
+
+    static let calendarDidFail = Self.init(message: "캘린더 오류 발생")
+}

Common/NotificationHistory/NotificationHistoryService.swift

@@ -0,0 +1,145 @@
+//
+//  NotificationContainer.swift
+//  koin
+//
+//  Created by 홍기정 on 7/6/26.
+//
+
+import SwiftData
+import Foundation
+
+protocol NotificationHistoryService {
+    func insert(record: NotificationRecord) async throws
+    func fetchAll() async throws -> [NotificationRecord]
+    func markAsRead(messageId: String) async throws
+    func markAllAsRead() async throws
+    func delete(messageId: String) async throws
+    func deleteAll() async throws
+}
+
+final class DefaultNotificationHistoryService: NotificationHistoryService {
+
+    // MARK: - Properties
+    private let container: ModelContainer?
+
+    // MARK: - Initializer
+    init() {
+        container = try? ModelContainer(
+            for: NotificationRecord.self,
+            configurations: .init(groupContainer: .identifier("group.com.bcsdlab.koin"))
+        )
+    }
+
+    // MARK: - Create
+    func insert(record: NotificationRecord) async throws {
+        guard let container else {
+            throw SwiftDataError.loadIssueModelContainer
+        }
+
+        switch record.category {
+        case .shop, .dining, .keyword, .chat, .callvan, .callvanChat:
+            try? await MainActor.run { [weak container] in
+                container?.mainContext.insert(record)
+                try container?.mainContext.save()
+            }
+        default:
+            break
+        }
+    }
+
+    // MARK: - Read
+    func fetchAll() async throws -> [NotificationRecord] {
+        guard let container else {
+            throw SwiftDataError.loadIssueModelContainer
+        }
+
+        try await deleteExpiredNotifications()
+
+        return try await MainActor.run {
+            var descriptor = FetchDescriptor<NotificationRecord>(
+                sortBy: [SortDescriptor(\.createdAt, order: .reverse)]
+            )
+            descriptor.fetchLimit = .max
+
+            return try container.mainContext.fetch(descriptor)
+        }
+    }
+
+    // MARK: - Update
+    func markAsRead(messageId: String) async throws {
+        guard let container else {
+            throw SwiftDataError.loadIssueModelContainer
+        }
+
+        try await MainActor.run {
+            var descriptor = FetchDescriptor<NotificationRecord>(
+                predicate: #Predicate { notification in
+                    notification.messageId == messageId
+                }
+            )
+            descriptor.fetchLimit = 1
+            if let notification = try container.mainContext.fetch(descriptor).first {
+                notification.isRead = true
+            }
+            try container.mainContext.save()
+        }
+    }
+
+    func markAllAsRead() async throws {
+        guard let container else {
+            throw SwiftDataError.loadIssueModelContainer
+        }
+
+        try await MainActor.run {
+            var descriptor = FetchDescriptor<NotificationRecord>()
+            descriptor.fetchLimit = .max
+            try container.mainContext.enumerate(descriptor) { notification in
+                notification.isRead = true
+            }
+            try container.mainContext.save()
+        }
+    }
+
+    // MARK: - Delete
+    func delete(messageId: String) async throws {
+        guard let container else {
+            throw SwiftDataError.loadIssueModelContainer
+        }
+
+        try await MainActor.run {
+            try container.mainContext.delete(model: NotificationRecord.self, where: #Predicate { notification in
+                notification.messageId == messageId
+            })
+            try container.mainContext.save()
+        }
+    }
+
+    func deleteAll() async throws {
+        guard let container else {
+            throw SwiftDataError.loadIssueModelContainer
+        }
+
+        try await MainActor.run {
+            try container.mainContext.delete(model: NotificationRecord.self)
+        }
+    }
+}
+
+extension DefaultNotificationHistoryService {
+    private func deleteExpiredNotifications() async throws {
+        guard let container else {
+            throw SwiftDataError.loadIssueModelContainer
+        }
+
+        guard let expirationDate = Calendar.current.date(byAdding: .day, value: -7, to: Date()) else {
+            throw NotificationHistoryError.calendarDidFail
+        }
+
+        try await MainActor.run {
+            try container.mainContext.delete(model: NotificationRecord.self, where: #Predicate { notification in
+                notification.createdAt < expirationDate
+            })
+            try container.mainContext.save()
+        }
+    }
+}

Common/NotificationHistory/NotificationRecord.swift

@@ -0,0 +1,35 @@
+//
+//  NotificationRecord.swift
+//  koin
+//
+//  Created by 홍기정 on 7/6/26.
+//
+
+import SwiftData
+import Foundation
+
+@Model
+final class NotificationRecord: Sendable {
+    var body: String
+    var title: String
+    var category: AppPath
+    var schemeUri: String
+    var messageId: String
+
+    var isRead: Bool = false
+    var createdAt: Date = Date()
+
+    init(
+        body: String,
+        title: String,
+        category: AppPath,
+        schemeUri: String,
+        messageId: String
+    ) {
+        self.body = body
+        self.title = title
+        self.category = category
+        self.schemeUri = schemeUri
+        self.messageId = messageId
+    }
+}

Koin/Data/Repository/DefaultNotificationHistoryRepository.swift

@@ -0,0 +1,44 @@
+//
+//  DefaultNotificationHistoryRepository.swift
+//  koin
+//
+//  Created by 홍기정 on 7/7/26.
+//
+
+import Foundation
+
+final class DefaultNotificationHistoryRepository: NotificationHistoryRepository {
+
+    private let service: NotificationHistoryService
+
+    init(service: NotificationHistoryService) {
+        self.service = service
+    }
+
+    func insert(record: NotificationRecord) async throws {
+        try await service.insert(record: record)
+    }
+
+    func fetchAll() async throws -> [NotificationItem] {
+        try await service.fetchAll()
+            .compactMap {
+                NotificationItem.init(from: $0)
+            }
+    }
+
+    func deleteAll() async throws {
+        try await service.deleteAll()
+    }
+
+    func delete(id: String) async throws {
+        try await service.delete(messageId: id)
+    }
+
+    func markAsRead(id: String) async throws {
+        try await service.markAsRead(messageId: id)
+    }
+
+    func makrAllAsRead() async throws {
+        try await service.markAllAsRead()
+    }
+}

Koin/Domain/Model/NewHome/NotificationItem.swift

@@ -8,8 +8,8 @@
 import Foundation
 
 struct NotificationItem {
-    let id: Int
-    let isRead: Bool
+    let id: String
+    var isRead: Bool
     let icon: ImageAsset
     let appPath: AppPath
     let uri: String?
@@ -18,7 +18,7 @@ struct NotificationItem {
     let dateText: String
 
     init(
-        id: Int,
+        id: String,
         isRead: Bool,
         icon: ImageAsset,
         appPath: AppPath,
@@ -37,3 +37,59 @@ struct NotificationItem {
         self.dateText = dateText
     }
 }
+
+extension NotificationItem {
+
+    init?(from record: NotificationRecord) {
+        guard let icon = NotificationItem.icon(for: record.category) else {
+            return nil
+        }
+        self.id = record.messageId
+        self.isRead = record.isRead
+        self.icon = icon
+        self.appPath = record.category
+        self.uri = record.schemeUri
+        self.title = record.title
+        self.content = record.body
+        self.dateText = NotificationItem.dateText(for: record.createdAt)
+    }
+
+    static func icon(for appPath: AppPath) -> ImageAsset? {
+        switch appPath {
+        case .shop:
+            return ImageAsset.notificationShop
+        case .dining:
+            return ImageAsset.notificationDining
+        case .keyword:
+            return ImageAsset.notificationLostItem
+        case .chat:
+            return ImageAsset.notificationChat
+        case .callvan:
+            return ImageAsset.notificationCallVan
+        case .callvanChat:
+            return ImageAsset.notificationChat
+        default:
+            return nil
+        }
+    }
+
+    static func dateText(for createdAt: Date) -> String {
+        let now = Date()
+        let compareComponents = Calendar.current.dateComponents(
+            [.day, .hour, .minute],
+            from: createdAt,
+            to: now
+        )
+
+        if let day = compareComponents.day, 1 <= day {
+            return "\(day)일 전"
+        }
+        if let hour = compareComponents.hour, 1 <= hour {
+            return "\(hour)시간 전"
+        }
+        if let minute = compareComponents.minute, 1 <= minute {
+            return "\(minute)분 전"
+        }
+        return "지금"
+    }
+}

Koin/Domain/Repository/NotificationHistoryRepository.swift

@@ -0,0 +1,16 @@
+//
+//  NotificationHistoryRepository.swift
+//  koin
+//
+//  Created by 홍기정 on 7/7/26.
+//
+
+import Combine
+
+protocol NotificationHistoryRepository {
+    func fetchAll() async throws -> [NotificationItem]
+    func deleteAll() async throws
+    func delete(id: String) async throws
+    func markAsRead(id: String) async throws
+    func makrAllAsRead() async throws
+}

Koin/Domain/UseCase/NewHome/DeleteNotificationHistoryUseCase.swift

@@ -0,0 +1,30 @@
+//
+//  DeleteNotificationHistoryUseCase.swift
+//  koin
+//
+//  Created by 홍기정 on 7/7/26.
+//
+
+import Foundation
+
+protocol DeleteNotificationHistoryUseCase {
+    func delete(id: String) async throws
+    func deleteAll() async throws
+}
+
+final class DefaultDeleteNotificationHistoryUseCase: DeleteNotificationHistoryUseCase {
+
+    private let repository: NotificationHistoryRepository
+
+    init(repository: NotificationHistoryRepository) {
+        self.repository = repository
+    }
+
+    func delete(id: String) async throws {
+        try await repository.delete(id: id)
+    }
+
+    func deleteAll() async throws {
+        try await repository.deleteAll()
+    }
+}