another.im-ios/Monal/another.im/XMPP/Wrappers/WrapperChat.swift

152 lines
5.2 KiB
Swift
Raw Normal View History

2024-12-02 15:50:23 +00:00
import Foundation
import monalxmpp
final class WrapperChat: ObservableObject {
@Published private(set) var messages: [Message] = []
@Published var replyText: String = ""
@Published private(set) var mamRequestInProgress = false
@Published var isOmemoEnabled: Bool {
didSet {
toggleOmemo(isOmemoEnabled)
}
}
let contact: Contact
2024-12-06 12:34:31 +00:00
let account: Account
2024-12-02 15:50:23 +00:00
private let xmpp: MLXMPPManager
private let db: DataLayer
2024-12-06 07:55:59 +00:00
private let monalContact: MLContact
2024-12-02 15:50:23 +00:00
private var notificationObservers: [AnyObject] = []
2024-12-06 12:34:31 +00:00
init?(with: Contact, account: Account) {
2024-12-06 07:55:59 +00:00
contact = with
xmpp = MLXMPPManager.sharedInstance()
db = DataLayer.sharedInstance()
2024-12-06 12:34:31 +00:00
self.account = account
2024-12-02 15:50:23 +00:00
2024-12-06 07:55:59 +00:00
guard
let monalContact = db.contactList()
.first(where: {
$0.accountID.intValue == with.ownerId
})
else { return nil }
self.monalContact = monalContact
2024-12-02 15:50:23 +00:00
isOmemoEnabled = monalContact.isEncrypted
2024-12-06 11:56:09 +00:00
subscribe()
NotificationCenter.default.post(name: Notification.Name(kMonalNewMessageNotice), object: nil)
2024-12-06 07:55:59 +00:00
}
2024-12-02 15:50:23 +00:00
2024-12-06 12:34:31 +00:00
init?(with: Chat, account: Account) {
2024-12-06 11:56:09 +00:00
xmpp = MLXMPPManager.sharedInstance()
db = DataLayer.sharedInstance()
2024-12-06 12:34:31 +00:00
self.account = account
2024-12-06 11:56:09 +00:00
guard
let monalContact = db.contactList()
.first(where: {
$0.accountID.intValue == with.accountId
})
else { return nil }
self.monalContact = monalContact
isOmemoEnabled = monalContact.isEncrypted
guard let contact = Contact(monalContact) else { return nil }
self.contact = contact
subscribe()
NotificationCenter.default.post(name: Notification.Name(kMonalNewMessageNotice), object: nil)
2024-12-06 07:55:59 +00:00
// guard let account = accounts.first(where: { $0.id == with.accountId }) else { return nil }
//
// var contact = contacts.first(where: { $0.ownerId == with.accountId && $0.contactJid == with.participantJid })
// if contact == nil {
// let semaphore = DispatchSemaphore(value: 0)
// Task {
// await addContact(contactJid: with.participantJid, forAccountID: with.accountId)
// semaphore.signal()
// }
// semaphore.wait()
// contact = contacts.first(where: { $0.ownerId == with.accountId && $0.contactJid == with.participantJid })
// }
2024-12-02 15:50:23 +00:00
//
2024-12-06 07:55:59 +00:00
// guard let contact else { return nil }
// let chatModel = WrapperChat(account: account, contact: contact, db: db, xmpp: xmpp)
// return chatModel
2024-12-02 15:50:23 +00:00
}
deinit {
notificationObservers.forEach { NotificationCenter.default.removeObserver($0) }
}
var chatTitle: String {
contact.name
}
func sendText(_ text: String) {
let newMessageId = UUID().uuidString
_ = db.addMessageHistory(
to: contact.contactJid,
forAccount: monalContact.accountID,
withMessage: text,
2024-12-06 12:34:31 +00:00
actuallyFrom: account.jid,
2024-12-02 15:50:23 +00:00
withId: newMessageId,
encrypted: monalContact.isEncrypted,
messageType: kMessageTypeText,
mimeType: nil,
size: nil
)
print(newMessageId)
xmpp.sendMessage(text, to: monalContact, isEncrypted: monalContact.isEncrypted, isUpload: false, messageId: newMessageId)
}
func requestMAM() {
2024-12-06 11:56:09 +00:00
guard let acc = monalContact.account else { return }
2024-12-02 15:50:23 +00:00
if mamRequestInProgress { return }
mamRequestInProgress = true
let lastStanzaId = messages.last?.stanzaId // last here because list is reversed
2024-12-06 11:56:09 +00:00
?? db.lastStanzaId(forAccount: NSNumber(value: contact.ownerId))
2024-12-02 15:50:23 +00:00
acc.setMAMQueryMostRecentFor(monalContact, before: lastStanzaId) { [weak self] msgs, _ in
DispatchQueue.main.asyncAfter(deadline: .now() + 0.5) { [weak self] in
self?.mamRequestInProgress = false
if !(msgs ?? []).isEmpty {
self?.refreshMessages()
}
}
}
}
}
private extension WrapperChat {
func subscribe() {
let newMsg = NotificationCenter.default.addObserver(forName: Notification.Name(kMonalNewMessageNotice), object: nil, queue: .main) { [weak self] _ in
self?.refreshMessages()
}
notificationObservers.append(newMsg)
let sentMsg = NotificationCenter.default.addObserver(forName: Notification.Name(kMonalSentMessageNotice), object: nil, queue: .main) { [weak self] _ in
self?.refreshMessages()
}
notificationObservers.append(sentMsg)
}
func refreshMessages() {
let messages = db.messages(forContact: contact.contactJid, forAccount: NSNumber(value: contact.ownerId))
.compactMap { obj -> Message? in
guard let message = obj as? MLMessage else { return nil }
return Message(message)
}
.sorted { $0.timestamp > $1.timestamp }
self.messages = messages
}
func toggleOmemo(_ new: Bool) {
if monalContact.isEncrypted != new {
monalContact.toggleEncryption(new)
}
}
}