import AVFoundation import Combine import Foundation import GRDB import Photos @MainActor final class ConversationStore: ObservableObject { @Published private(set) var messages: [Message] = [] @Published var replyText = "" private(set) var roster: Roster private let client: Client private let blockSize = Const.messagesPageSize private let messagesMax = Const.messagesMaxSize private var messagesCancellable: AnyCancellable? init(roster: Roster, client: Client) { self.client = client self.roster = roster subscribe() } } extension ConversationStore { func sendMessage(_ message: String) async { // prepare message let message = Message( id: UUID().uuidString, type: .chat, date: Date(), contentType: .text, status: .pending, from: roster.bareJid, to: roster.contactBareJid, body: message, subject: nil, thread: nil, oobUrl: nil ) // store as pending on db, and send do { try await message.save() try await client.sendMessage(message) try await message.setStatus(.sent) } catch { try? await message.setStatus(.error) } } } extension ConversationStore { var attachmentsStore: AttachmentsStore { AttachmentsStore() } func sendMedia(_ items: [GalleryItem]) async { print("media!", items) // guard !ids.isEmpty else { return } // let items = galleryItems.filter { ids.contains($0.id) } // for item in items { // await client.uploadMedia(item.url) // } } func sendCaptured(_ data: Data, _ type: GalleryMediaType) async { print("captured!", data, type) // // // } func sendDocuments(_ data: [Data], _ extensions: [String]) async { print("documents!", data, extensions) // // // } func sendContact(_ jidStr: String) async { print("contact!", jidStr) // // // } } extension ConversationStore { var contacts: [Roster] { get async { do { let rosters = try await Database.shared.dbQueue.read { db in try Roster .filter(Column("locallyDeleted") == false) .fetchAll(db) } return rosters } catch { return [] } } } } private extension ConversationStore { func subscribe() { messagesCancellable = ValueObservation.tracking(Message .filter( (Column("to") == roster.bareJid && Column("from") == roster.contactBareJid) || (Column("from") == roster.bareJid && Column("to") == roster.contactBareJid) ) .order(Column("date").desc) .fetchAll ) .publisher(in: Database.shared.dbQueue, scheduling: .immediate) .receive(on: DispatchQueue.main) .sink { _ in } receiveValue: { [weak self] messages in self?.messages = messages } } }