update newfeed trigger

Authenticate/Sources/Authenticate/Screens/SignIn/SignInView.swift

@@ -12,7 +12,7 @@ import AVFAudio
 import Combine
 
 public struct SignInView: View {
-    //MARK: Property
+    // MARK: Property
     @State private var email = "K@gmail.com"
     @State private var passworld = "02111997"
     @ObservedObject var viewModel: SignInViewModel
@@ -21,6 +21,7 @@ public struct SignInView: View {
     @StateObject var cancelBag: CancelBag
     @StateObject var triggers: Triggers
     @EnvironmentObject private var router: Router
+
     let navigateNewFeed: () -> Void
     public init(viewModel: SignInViewModel, navigateNewFeed: @escaping () -> Void = {}) {
         self.viewModel = viewModel
@@ -94,8 +95,6 @@ public struct SignInView: View {
 
     final class Triggers: ObservableObject {
         var loginTrigger = PassthroughSubject<Void, Never>()
-
     }
 
-
 }

Bookde.xcodeproj/xcuserdata/kevin.xcuserdatad/xcschemes/xcschememanagement.plist

@@ -7,12 +7,12 @@
 		<key>Bookde.xcscheme_^#shared#^_</key>
 		<dict>
 			<key>orderHint</key>
-			<integer>4</integer>
+			<integer>0</integer>
 		</dict>
 		<key>BookdeScenario.xcscheme_^#shared#^_</key>
 		<dict>
 			<key>orderHint</key>
-			<integer>5</integer>
+			<integer>2</integer>
 		</dict>
 		<key>Promises (Playground) 1.xcscheme</key>
 		<dict>

Bookde/Cores/DBService/Sources/DBFireBaseService/FirebaseServiceConfig.swift

@@ -86,6 +86,7 @@ public final class ImplFireRepository: FireRepository {
 
     public func fetchCurrentUser() async -> Result<DocumentDTO, Error> {
         guard let uiid = Auth.auth().currentUser?.uid  else { return .failure(FirbaseError.generic) }
+        print("uiid", uiid)
 
         do {
             let snapshot = try await Firestore.firestore()
@@ -100,6 +101,14 @@ public final class ImplFireRepository: FireRepository {
             let document = DocumentDTO(dic: data)
             return .success(document)
         } catch {
+
+            if let urlError = error as? URLError {
+                print("Network error: \(urlError)")
+            } else if let decodingError = error as? DecodingError {
+                print("Decoding error: \(decodingError)")
+            } else {
+                print("General error: \(error)")
+            }
             return .failure(error)
         }
     }

Bookde/Feature/MessageCenter/Sources/MessageCenter/Screens/Feed/MessageNewFeed.swift

@@ -8,13 +8,19 @@
 import SwiftUI
 import CoreUI
 import Routers
+import Combine
+import DBCore
 
 public struct MessageFeedView: View {
     @State var shouldShowLogOutOptions = false
     @State private var isLoading = true
 
     @State var showNewMessage: Bool = false
     @StateObject var viewModel: MessageNewFeedViewModel
+    @StateObject var output: MessageNewFeedViewModel.Output
+    @StateObject var triggers: Triggers
+    @StateObject var cancelBag: CancelBag
+
     @EnvironmentObject private var router: Router
     let startCreateNewMessage: (UserChat) -> Void
 
@@ -23,16 +29,27 @@ public struct MessageFeedView: View {
         viewModel: MessageNewFeedViewModel,
         startCreateNewMessage: @escaping (UserChat) -> Void = {_ in  }
     ) {
+        let cancelBag = CancelBag()
         self.shouldShowLogOutOptions = shouldShowLogOutOptions
         _viewModel = .init(wrappedValue: viewModel)
         self.startCreateNewMessage = startCreateNewMessage
+        let triggers = Triggers()
+        let input = MessageNewFeedViewModel.Input(
+            loadTrigger: triggers.loadingTriggers.eraseToAnyPublisher()
+        )
+
+        let output = viewModel.transform(input: input, cancelBag: cancelBag)
+        _output = StateObject(wrappedValue: output)
+        _triggers = StateObject(wrappedValue: triggers)
+        _cancelBag = StateObject(wrappedValue: cancelBag)
+        triggers.loadingTriggers.send(())
     }
 
     public var body: some View {
         ZStack {
             VStack {
                 MessageHeaderSectionView(
-                    user: viewModel.user,
+                    user: output.currentUser ?? .init(email: "", profileUrl: "", uiid: ""),
                     didTapLogOut: {
                         Task {
                             await viewModel.signOut()
@@ -43,7 +60,7 @@ public struct MessageFeedView: View {
                         }
                         print("action ==>", actiion)
                     })
-                switch viewModel.messageStatus {
+                switch  output.messageStatus {
                 case .loading(let users):
                     MessageListView(
                         users: users,
@@ -60,11 +77,15 @@ public struct MessageFeedView: View {
                             self.startCreateNewMessage(user)
                         }
                     )
+
+                case .stop:
+                    Text("Opp Something wrong")
+                    Spacer()
+                default:
+                    EmptyView()
                 }
             }.onAppear(perform: {
-                Task {
-                    await viewModel.fetch()
-                }
+                triggers.loadingTriggers.send(())
             })
 
         }.navigationBarHidden(true)
@@ -93,4 +114,9 @@ public struct MessageFeedView: View {
         })
 
     }
+
+    final class Triggers: ObservableObject {
+        var loadingTriggers = PassthroughSubject<Void, Never>()
+    }
+
 }