fix: Auth 세션 관찰 흐름 단일화

Author: opficdev

Application/DevLogData/Sources/Repository/AuthSessionRepositoryImpl.swift

@@ -17,6 +17,7 @@ final class AuthSessionRepositoryImpl: AuthSessionRepository {
     private let todoCategoryService: TodoCategoryService
     private let store: MemoryCacheStore
     private let provider: AuthSessionStateProvider
+    private var cancellables = Set<AnyCancellable>()
 
     init(
         authService: AuthService,
@@ -28,30 +29,34 @@ final class AuthSessionRepositoryImpl: AuthSessionRepository {
         self.todoCategoryService = todoCategoryService
         self.store = store
         self.provider = provider
+
+        setupObservation()
     }
 
     func observeSignedIn() -> AnyPublisher<Bool, Never> {
+        provider.observeSignedIn()
+    }
+}
+
+private extension AuthSessionRepositoryImpl {
+    func setupObservation() {
         authService.observeSignedIn()
             .removeDuplicates()
-            .map { [self] isSignedIn in
-                Future { promise in
-                    Task {
-                        if isSignedIn {
-                            await self.cachePreferencesIfNeeded()
-                        } else {
-                            self.clearPreferencesCache()
-                        }
-                        self.provider.publish(isSignedIn)
-                        promise(.success(isSignedIn))
+            .sink { [weak self] isSignedIn in
+                Task { [weak self] in
+                    guard let self else { return }
+
+                    if isSignedIn {
+                        await self.cachePreferencesIfNeeded()
+                    } else {
+                        self.clearPreferencesCache()
                     }
+                    self.provider.publish(isSignedIn)
                 }
             }
-            .switchToLatest()
-            .eraseToAnyPublisher()
+            .store(in: &cancellables)
     }
-}
 
-private extension AuthSessionRepositoryImpl {
     func cachePreferencesIfNeeded() async {
         if store.value(forKey: Key.preferences) as [TodoCategoryPreferenceResponse]? != nil {
             return

Application/DevLogData/Tests/Repository/AuthSessionRepositoryImplTests.swift

@@ -40,7 +40,7 @@ struct AuthSessionRepositoryImplTests {
         #expect(await valueTask.value)
         #expect(store.value(forKey: Key.preferences) == [preference])
         #expect(await todoCategoryService.fetchCategoryPreferencesCallCount() == 1)
-        #expect(provider.events == [true])
+        #expect(provider.events.contains(true))
     }
 
     @Test("로그아웃 세션은 category preference 캐시를 제거한다")
@@ -68,7 +68,7 @@ struct AuthSessionRepositoryImplTests {
 
         #expect(await valueTask.value == false)
         #expect(store.value(forKey: Key.preferences) == Optional<[TodoCategoryPreferenceResponse]>.none)
-        #expect(provider.events == [false])
+        #expect(provider.events.contains(false))
     }
 
     private func makePreferenceResponse() -> TodoCategoryPreferenceResponse {
@@ -86,14 +86,16 @@ struct AuthSessionRepositoryImplTests {
 }
 
 private final class AuthSessionStateProviderSpy: AuthSessionStateProvider {
+    private let subject = PassthroughSubject<Bool, Never>()
     private(set) var events = [Bool]()
 
     func publish(_ isSignedIn: Bool) {
         events.append(isSignedIn)
+        subject.send(isSignedIn)
     }
 
     func observeSignedIn() -> AnyPublisher<Bool, Never> {
-        Empty().eraseToAnyPublisher()
+        subject.eraseToAnyPublisher()
     }
 }