Messenger example - send auth request

• Refactor user search
• Add contact feature
• Save found contacts
• Add send request feature
• Send auth request
• Fix saving my contact during registration

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

+import AppCore
+import ComposableArchitecture
+import ComposablePresentation
+import Foundation
+import SendRequestFeature
+import XCTestDynamicOverlay
+import XXClient
+import XXMessengerClient
+import XXModels
+
+public struct ContactState: Equatable {
+  public init(
+    id: Data,
+    dbContact: XXModels.Contact? = nil,
+    xxContact: XXClient.Contact? = nil,
+    importUsername: Bool = true,
+    importEmail: Bool = true,
+    importPhone: Bool = true,
+    sendRequest: SendRequestState? = nil
+  ) {
+    self.id = id
+    self.dbContact = dbContact
+    self.xxContact = xxContact
+    self.importUsername = importUsername
+    self.importEmail = importEmail
+    self.importPhone = importPhone
+    self.sendRequest = sendRequest
+  }
+
+  public var id: Data
+  public var dbContact: XXModels.Contact?
+  public var xxContact: XXClient.Contact?
+  @BindableState public var importUsername: Bool
+  @BindableState public var importEmail: Bool
+  @BindableState public var importPhone: Bool
+  public var sendRequest: SendRequestState?
+}
+
+public enum ContactAction: Equatable, BindableAction {
+  case start
+  case dbContactFetched(XXModels.Contact?)
+  case importFactsTapped
+  case sendRequestTapped
+  case sendRequestDismissed
+  case sendRequest(SendRequestAction)
+  case binding(BindingAction<ContactState>)
+}
+
+public struct ContactEnvironment {
+  public init(
+    messenger: Messenger,
+    db: DBManagerGetDB,
+    mainQueue: AnySchedulerOf<DispatchQueue>,
+    bgQueue: AnySchedulerOf<DispatchQueue>,
+    sendRequest: @escaping () -> SendRequestEnvironment
+  ) {
+    self.messenger = messenger
+    self.db = db
+    self.mainQueue = mainQueue
+    self.bgQueue = bgQueue
+    self.sendRequest = sendRequest
+  }
+
+  public var messenger: Messenger
+  public var db: DBManagerGetDB
+  public var mainQueue: AnySchedulerOf<DispatchQueue>
+  public var bgQueue: AnySchedulerOf<DispatchQueue>
+  public var sendRequest: () -> SendRequestEnvironment
+}
+
+#if DEBUG
+extension ContactEnvironment {
+  public static let unimplemented = ContactEnvironment(
+    messenger: .unimplemented,
+    db: .unimplemented,
+    mainQueue: .unimplemented,
+    bgQueue: .unimplemented,
+    sendRequest: { .unimplemented }
+  )
+}
+#endif
+
+public let contactReducer = Reducer<ContactState, ContactAction, ContactEnvironment>
+{ state, action, env in
+  enum DBFetchEffectID {}
+
+  switch action {
+  case .start:
+    return try! env.db().fetchContactsPublisher(.init(id: [state.id]))
+      .assertNoFailure()
+      .map(\.first)
+      .map(ContactAction.dbContactFetched)
+      .subscribe(on: env.bgQueue)
+      .receive(on: env.mainQueue)
+      .eraseToEffect()
+      .cancellable(id: DBFetchEffectID.self, cancelInFlight: true)
+
+  case .dbContactFetched(let contact):
+    state.dbContact = contact
+    return .none
+
+  case .importFactsTapped:
+    guard let xxContact = state.xxContact else { return .none }
+    return .fireAndForget { [state] in
+      var dbContact = state.dbContact ?? XXModels.Contact(id: state.id)
+      dbContact.marshaled = xxContact.data
+      if state.importUsername {
+        dbContact.username = try? xxContact.getFact(.username)?.fact
+      }
+      if state.importEmail {
+        dbContact.email = try? xxContact.getFact(.email)?.fact
+      }
+      if state.importPhone {
+        dbContact.phone = try? xxContact.getFact(.phone)?.fact
+      }
+      _ = try! env.db().saveContact(dbContact)
+    }
+    .subscribe(on: env.bgQueue)
+    .receive(on: env.mainQueue)
+    .eraseToEffect()
+
+  case .sendRequestTapped:
+    if let xxContact = state.xxContact {
+      state.sendRequest = SendRequestState(contact: xxContact)
+    } else if let marshaled = state.dbContact?.marshaled {
+      state.sendRequest = SendRequestState(contact: .live(marshaled))
+    }
+    return .none
+
+  case .sendRequestDismissed:
+    state.sendRequest = nil
+    return .none
+
+  case .sendRequest(.sendSucceeded):
+    state.sendRequest = nil
+    return .none
+
+  case .sendRequest(_):
+    return .none
+
+  case .binding(_):
+    return .none
+  }
+}
+.binding()
+.presenting(
+  sendRequestReducer,
+  state: .keyPath(\.sendRequest),
+  id: .notNil(),
+  action: /ContactAction.sendRequest,
+  environment: { $0.sendRequest() }
+)