feat: TodoMutationEvent 방출

Author: opficdev

Application/DevLogData/Sources/DataAssembler.swift

@@ -32,11 +32,16 @@ public final class DataAssembler: Assembler {
             )
         }
 
+        container.register(TodoMutationEventBus.self) {
+            TodoMutationEventBusImpl()
+        }
+
         container.register(TodoRepository.self) {
             TodoRepositoryImpl(
                 todoService: container.resolve(TodoService.self),
                 todoCategoryService: container.resolve(TodoCategoryService.self),
-                widgetSyncEventBus: container.resolve(WidgetSyncEventBus.self)
+                widgetSyncEventBus: container.resolve(WidgetSyncEventBus.self),
+                todoMutationEventBus: container.resolve(TodoMutationEventBus.self)
             )
         }
 

Application/DevLogData/Sources/Repository/TodoRepositoryImpl.swift

@@ -13,15 +13,18 @@ final class TodoRepositoryImpl: TodoRepository {
     private let todoService: TodoService
     private let todoCategoryService: TodoCategoryService
     private let widgetSyncEventBus: WidgetSyncEventBus
+    private let todoMutationEventBus: TodoMutationEventBus
 
     init(
         todoService: TodoService,
         todoCategoryService: TodoCategoryService,
-        widgetSyncEventBus: WidgetSyncEventBus
+        widgetSyncEventBus: WidgetSyncEventBus,
+        todoMutationEventBus: TodoMutationEventBus
     ) {
         self.todoService = todoService
         self.todoCategoryService = todoCategoryService
         self.widgetSyncEventBus = widgetSyncEventBus
+        self.todoMutationEventBus = todoMutationEventBus
     }
 
     func fetchTodos(_ query: TodoQuery, cursor: TodoCursor?) async throws -> TodoPage {
@@ -107,6 +110,7 @@ final class TodoRepositoryImpl: TodoRepository {
     func upsertTodo(_ todo: Todo) async throws {
         let todoRequest = TodoRequest.fromDomain(todo)
         try await upsertTodo(todoRequest)
+        await todoMutationEventBus.publish(.updated(todo.id))
     }
 
     func upsertTodo(_ todoDraft: TodoDraft) async throws {
@@ -127,6 +131,7 @@ final class TodoRepositoryImpl: TodoRepository {
         do {
             try await todoService.deleteTodo(todoId: todoId)
             widgetSyncEventBus.publish(.syncRequested)
+            await todoMutationEventBus.publish(.deleted(todoId))
         } catch {
             throw error.toDomain()
         }
@@ -136,6 +141,7 @@ final class TodoRepositoryImpl: TodoRepository {
         do {
             try await todoService.undoDeleteTodo(todoId: todoId)
             widgetSyncEventBus.publish(.syncRequested)
+            await todoMutationEventBus.publish(.restored(todoId))
         } catch {
             throw error.toDomain()
         }

Application/DevLogData/Tests/Repository/TodoRepositoryImplTests.swift

@@ -10,11 +10,11 @@ import Foundation
 import Testing
 import DevLogCore
 import DevLogDomain
-@testable import DevLogData
+@testable @preconcurrency import DevLogData
 
 struct TodoRepositoryImplTests {
-    @Test("Todo 변경 성공 시 위젯 동기화 이벤트를 발행한다")
-    func todo_변경_성공_시_위젯_동기화_이벤트를_발행한다() async throws {
+    @Test("Todo 변경 성공 시 위젯 동기화와 mutation 이벤트를 발행한다")
+    func todo_변경_성공_시_위젯_동기화와_mutation_이벤트를_발행한다() async throws {
         let fixture = makeFixture()
         let todo = makeTodo()
 
@@ -24,10 +24,13 @@ struct TodoRepositoryImplTests {
 
         let events = fixture.widgetSyncEventBus.events
         #expect(events == [.syncRequested, .syncRequested, .syncRequested])
+
+        let mutationEvents = await fixture.todoMutationEventBus.publishedEvents()
+        #expect(mutationEvents == [.updated(todo.id), .deleted(todo.id), .restored(todo.id)])
     }
 
-    @Test("Todo 변경 실패 시 위젯 동기화 이벤트를 발행하지 않는다")
-    func todo_변경_실패_시_위젯_동기화_이벤트를_발행하지_않는다() async throws {
+    @Test("Todo 변경 실패 시 위젯 동기화와 mutation 이벤트를 발행하지 않는다")
+    func todo_변경_실패_시_위젯_동기화와_mutation_이벤트를_발행하지_않는다() async throws {
         let fixture = makeFixture()
         let todo = makeTodo()
 
@@ -52,24 +55,30 @@ struct TodoRepositoryImplTests {
             #expect(error as? TodoRepositoryImplTestsError == .serviceFailed)
         }
 
-        let events = fixture.widgetSyncEventBus.events
-        #expect(events.isEmpty)
+        let syncEvents = fixture.widgetSyncEventBus.events
+        #expect(syncEvents.isEmpty)
+
+        let mutationEvents = await fixture.todoMutationEventBus.publishedEvents()
+        #expect(mutationEvents.isEmpty)
     }
 
     private func makeFixture() -> Fixture {
         let todoService = TodoServiceSpy()
         let todoCategoryService = TodoCategoryServiceSpy()
         let widgetSyncEventBus = WidgetSyncEventBusSpy()
+        let todoMutationEventBus = TodoMutationEventBusSpy()
         let repository = TodoRepositoryImpl(
             todoService: todoService,
             todoCategoryService: todoCategoryService,
-            widgetSyncEventBus: widgetSyncEventBus
+            widgetSyncEventBus: widgetSyncEventBus,
+            todoMutationEventBus: todoMutationEventBus
         )
 
         return Fixture(
             repository: repository,
             todoService: todoService,
-            widgetSyncEventBus: widgetSyncEventBus
+            widgetSyncEventBus: widgetSyncEventBus,
+            todoMutationEventBus: todoMutationEventBus
         )
     }
 
@@ -97,6 +106,7 @@ private struct Fixture {
     let repository: TodoRepositoryImpl
     let todoService: TodoServiceSpy
     let widgetSyncEventBus: WidgetSyncEventBusSpy
+    let todoMutationEventBus: TodoMutationEventBusSpy
 }
 
 private actor TodoServiceSpy: TodoService {
@@ -159,6 +169,24 @@ private final class WidgetSyncEventBusSpy: WidgetSyncEventBus {
     }
 }
 
+private actor TodoMutationEventBusSpy: TodoMutationEventBus {
+    private var capturedEvents = [TodoMutationEvent]()
+
+    func publish(_ event: TodoMutationEvent) async {
+        capturedEvents.append(event)
+    }
+
+    func publishedEvents() -> [TodoMutationEvent] {
+        capturedEvents
+    }
+
+    func events() async -> AsyncStream<TodoMutationEvent> {
+        AsyncStream { continuation in
+            continuation.finish()
+        }
+    }
+}
+
 private enum TodoRepositoryImplTestsError: Error, Equatable {
     case serviceFailed
     case unexpectedCall