Fetch my facts in SendRequestFeature

Examples/xx-messenger/Sources/AppFeature/AppEnvironment+Live.swift

@@ -63,7 +63,12 @@ extension AppEnvironment {
                   mainQueue: mainQueue,
                   bgQueue: bgQueue,
                   sendRequest: {
-                    SendRequestEnvironment()
+                    SendRequestEnvironment(
+                      messenger: messenger,
+                      db: dbManager.getDB,
+                      mainQueue: mainQueue,
+                      bgQueue: bgQueue
+                    )
                   }
                 )
               }

Examples/xx-messenger/Sources/SendRequestFeature/SendRequestFeature.swift

+import AppCore
 import ComposableArchitecture
+import Foundation
 import XCTestDynamicOverlay
 import XXClient
+import XXMessengerClient
 import XXModels
 
 public struct SendRequestState: Equatable {
@@ -35,22 +38,60 @@ public enum SendRequestAction: Equatable, BindableAction {
   case start
   case sendTapped
   case binding(BindingAction<SendRequestState>)
+  case myContactFetched(XXClient.Contact?)
 }
 
 public struct SendRequestEnvironment {
-  public init() {}
+  public init(
+    messenger: Messenger,
+    db: DBManagerGetDB,
+    mainQueue: AnySchedulerOf<DispatchQueue>,
+    bgQueue: AnySchedulerOf<DispatchQueue>
+  ) {
+    self.messenger = messenger
+    self.db = db
+    self.mainQueue = mainQueue
+    self.bgQueue = bgQueue
+  }
+
+  public var messenger: Messenger
+  public var db: DBManagerGetDB
+  public var mainQueue: AnySchedulerOf<DispatchQueue>
+  public var bgQueue: AnySchedulerOf<DispatchQueue>
 }
 
 #if DEBUG
 extension SendRequestEnvironment {
-  public static let unimplemented = SendRequestEnvironment()
+  public static let unimplemented = SendRequestEnvironment(
+    messenger: .unimplemented,
+    db: .unimplemented,
+    mainQueue: .unimplemented,
+    bgQueue: .unimplemented
+  )
 }
 #endif
 
 public let sendRequestReducer = Reducer<SendRequestState, SendRequestAction, SendRequestEnvironment>
 { state, action, env in
+  enum DBFetchEffectID {}
+
   switch action {
   case .start:
+    return Effect
+      .catching { try env.messenger.e2e.tryGet().getContact().getId() }
+      .tryMap { try env.db().fetchContactsPublisher(.init(id: [$0])) }
+      .flatMap { $0 }
+      .assertNoFailure()
+      .map(\.first)
+      .map { $0?.marshaled.map { XXClient.Contact.live($0) } }
+      .map(SendRequestAction.myContactFetched)
+      .subscribe(on: env.bgQueue)
+      .receive(on: env.mainQueue)
+      .eraseToEffect()
+      .cancellable(id: DBFetchEffectID.self, cancelInFlight: true)
+
+  case .myContactFetched(let contact):
+    state.myContact = contact
     return .none
 
   case .sendTapped:
@@ -60,3 +101,4 @@ public let sendRequestReducer = Reducer<SendRequestState, SendRequestAction, Sen
     return .none
   }
 }
+.binding()

Examples/xx-messenger/Tests/SendRequestFeatureTests/SendRequestFeatureTests.swift

+import Combine
 import ComposableArchitecture
 import XCTest
+import XXClient
+import XXModels
 @testable import SendRequestFeature
 
 final class SendRequestFeatureTests: XCTestCase {
@@ -12,6 +15,71 @@ final class SendRequestFeatureTests: XCTestCase {
       environment: .unimplemented
     )
 
+    var dbDidFetchContacts: [XXModels.Contact.Query] = []
+    let dbContactsPublisher = PassthroughSubject<[XXModels.Contact], Error>()
+
+    store.environment.mainQueue = .immediate
+    store.environment.bgQueue = .immediate
+    store.environment.messenger.e2e.get = {
+      var e2e: E2E = .unimplemented
+      e2e.getContact.run = {
+        var contact: XXClient.Contact = .unimplemented("my-contact-data".data(using: .utf8)!)
+        contact.getIdFromContact.run = { _ in "my-contact-id".data(using: .utf8)! }
+        return contact
+      }
+      return e2e
+    }
+    store.environment.db.run = {
+      var db: Database = .failing
+      db.fetchContactsPublisher.run = { query in
+        dbDidFetchContacts.append(query)
+        return dbContactsPublisher.eraseToAnyPublisher()
+      }
+      return db
+    }
+
     store.send(.start)
+
+    XCTAssertNoDifference(dbDidFetchContacts, [.init(id: ["my-contact-id".data(using: .utf8)!])])
+
+    dbContactsPublisher.send([])
+
+    store.receive(.myContactFetched(nil))
+
+    var myDbContact = XXModels.Contact(id: "my-contact-id".data(using: .utf8)!)
+    myDbContact.marshaled = "my-contact-data".data(using: .utf8)!
+    dbContactsPublisher.send([myDbContact])
+
+    store.receive(.myContactFetched(.live("my-contact-data".data(using: .utf8)!))) {
+      $0.myContact = .live("my-contact-data".data(using: .utf8)!)
+    }
+
+    dbContactsPublisher.send(completion: .finished)
+  }
+
+  func testSendRequest() {
+    var myContact: XXClient.Contact = .unimplemented("my-contact-data".data(using: .utf8)!)
+    myContact.getFactsFromContact.run = { _ in
+      [
+        Fact(fact: "my-username", type: 0),
+        Fact(fact: "my-email", type: 1),
+        Fact(fact: "my-phone", type: 2),
+      ]
+    }
+
+    let store = TestStore(
+      initialState: SendRequestState(
+        contact: .unimplemented("contact-data".data(using: .utf8)!),
+        myContact: myContact
+      ),
+      reducer: sendRequestReducer,
+      environment: .unimplemented
+    )
+
+    store.send(.set(\.$sendPhone, false)) {
+      $0.sendPhone = false
+    }
+
+    store.send(.sendTapped)
   }
 }