wip

ConversationsClassic/AppCore/Actions/ChatsActions.swift

@@ -2,4 +2,9 @@ enum ChatsAction: Codable {
     case chatsListUpdated(chats: [Chat])
 
     case startChat(accountJid: String, participantJid: String)
+    case chatStarted(chat: Chat)
+
+    case createNewChat(accountJid: String, participantJid: String)
+    case chatCreated(chat: Chat)
+    case chatCreationFailed(reason: String)
 }

ConversationsClassic/AppCore/Middlewares/ChatsMiddleware.swift

@@ -11,14 +11,24 @@ final class ChatsMiddleware {
 
         case .chatsAction(.startChat(accountJid: let accountJid, participantJid: let participantJid)):
             return Future<AppAction, Never> { promise in
-                // find existing chat
+                if let exist = state.chatsState.chats.first(where: { $0.account == accountJid && $0.participant == participantJid }) {
-                let exist = state.chatsState.chats.first {
+                    // open existing chat
-                    $0.account == accountJid && $0.participant == participantJid
+                    promise(.success(.chatsAction(.chatStarted(chat: exist))))
+                } else {
+                    // create new chat
+                    promise(.success(.chatsAction(.createNewChat(accountJid: accountJid, participantJid: participantJid))))
                 }
-                promise(.success(.empty))
             }
             .eraseToAnyPublisher()
 
+        case .chatsAction(.chatCreated(let chat)):
+            return Just(.chatsAction(.chatStarted(chat: chat)))
+                .eraseToAnyPublisher()
+
+        case .chatsAction(.chatStarted(let chat)):
+            // TODO: make transition to chat screen
+            return Empty().eraseToAnyPublisher()
+
         default:
             return Empty().eraseToAnyPublisher()
         }

ConversationsClassic/AppCore/Middlewares/DatabaseMiddleware.swift

@@ -125,6 +125,31 @@ final class DatabaseMiddleware {
             }
             .eraseToAnyPublisher()
 
+        case .chatsAction(.createNewChat(let accountJid, let participantJid)):
+            return Future<AppAction, Never> { promise in
+                Task(priority: .background) { [weak self] in
+                    guard let database = self?.database else {
+                        promise(.success(.chatsAction(.chatCreationFailed(reason: L10n.Global.Error.genericDbError))))
+                        return
+                    }
+                    do {
+                        try database._db.write { db in
+                            let chat = Chat(
+                                id: UUID().uuidString,
+                                account: accountJid,
+                                participant: participantJid,
+                                type: .chat
+                            )
+                            try chat.insert(db)
+                            promise(.success(.chatsAction(.chatCreated(chat: chat))))
+                        }
+                    } catch {
+                        promise(.success(.chatsAction(.chatCreationFailed(reason: L10n.Global.Error.genericDbError))))
+                    }
+                }
+            }
+            .eraseToAnyPublisher()
+
         default:
             return Empty().eraseToAnyPublisher()
         }

ConversationsClassic/AppCore/Reducers/ChatsReducer.swift

@@ -4,6 +4,9 @@ extension ChatsState {
         case .chatsListUpdated(let chats):
             state.chats = chats
 
+        case .chatStarted(let chat):
+            state.currentChat = chat
+
         default:
             break
         }

ConversationsClassic/AppCore/State/ChatsState.swift

@@ -1,5 +1,6 @@
 struct ChatsState: Stateable {
     var chats: [Chat]
+    var currentChat: Chat?
 }
 
 // MARK: Init