[Messenger example] create new group

xx-messenger example

• Add groups list screen
• Add new group screen
• Implement creating new group

Examples/xx-messenger/Sources/NewGroupFeature/NewGroupComponent.swift

@@ -8,31 +8,43 @@ public struct NewGroupComponent: ReducerProtocol {
   public struct State: Equatable {
     public enum Field: String, Hashable {
       case name
+      case message
     }
 
     public init(
       contacts: IdentifiedArrayOf<XXModels.Contact> = [],
       members: IdentifiedArrayOf<XXModels.Contact> = [],
       name: String = "",
-      focusedField: Field? = nil
+      message: String = "",
+      focusedField: Field? = nil,
+      isCreating: Bool = false,
+      failure: String? = nil
     ) {
       self.contacts = contacts
       self.members = members
       self.name = name
+      self.message = message
       self.focusedField = focusedField
+      self.isCreating = isCreating
+      self.failure = failure
     }
 
     public var contacts: IdentifiedArrayOf<XXModels.Contact>
     public var members: IdentifiedArrayOf<XXModels.Contact>
     @BindableState public var name: String
+    @BindableState public var message: String
     @BindableState public var focusedField: Field?
+    public var isCreating: Bool
+    public var failure: String?
   }
 
   public enum Action: Equatable, BindableAction {
     case start
     case didFetchContacts([XXModels.Contact])
     case didSelectContact(XXModels.Contact)
+    case createButtonTapped
     case didFinish
+    case didFail(String)
     case binding(BindingAction<State>)
   }
 
@@ -42,6 +54,7 @@ public struct NewGroupComponent: ReducerProtocol {
   @Dependency(\.app.dbManager.getDB) var db: DBManagerGetDB
   @Dependency(\.app.mainQueue) var mainQueue: AnySchedulerOf<DispatchQueue>
   @Dependency(\.app.bgQueue) var bgQueue: AnySchedulerOf<DispatchQueue>
+  @Dependency(\.date) var date: DateGenerator
 
   public var body: some ReducerProtocol<State, Action> {
     BindingReducer()
@@ -71,7 +84,61 @@ public struct NewGroupComponent: ReducerProtocol {
         }
         return .none
 
+      case .createButtonTapped:
+        state.focusedField = nil
+        state.isCreating = true
+        state.failure = nil
+        return Effect.result { [state] in
+          do {
+            let groupChat = try messenger.groupChat.tryGet()
+            let report = try groupChat.makeGroup(
+              membership: state.members.map(\.id),
+              message: state.message.data(using: .utf8)!,
+              name: state.name.data(using: .utf8)!
+            )
+            let myContactId = try messenger.e2e.tryGet().getContact().getId()
+            let group = XXModels.Group(
+              id: report.id,
+              name: state.name,
+              leaderId: myContactId,
+              createdAt: date(),
+              authStatus: .participating,
+              serialized: try report.encode()
+            )
+            try db().saveGroup(group)
+            if state.message.isEmpty == false {
+              try db().saveMessage(.init(
+                senderId: myContactId,
+                recipientId: nil,
+                groupId: group.id,
+                date: group.createdAt,
+                status: .sent,
+                isUnread: false,
+                text: state.message
+              ))
+            }
+            try state.members.map {
+              GroupMember(groupId: group.id, contactId: $0.id)
+            }.forEach {
+              try db().saveGroupMember($0)
+            }
+            return .success(.didFinish)
+          } catch {
+            return .success(.didFail(error.localizedDescription))
+          }
+        }
+        .subscribe(on: bgQueue)
+        .receive(on: mainQueue)
+        .eraseToEffect()
+
       case .didFinish:
+        state.isCreating = false
+        state.failure = nil
+        return .none
+
+      case .didFail(let failure):
+        state.isCreating = false
+        state.failure = failure
         return .none
 
       case .binding(_):