wip
This commit is contained in:
parent
0e2c135bea
commit
af7664d2d3
|
@ -8,9 +8,10 @@ final class ClientMartinCarbonsManager {
|
|||
|
||||
init(_ xmppConnection: XMPPClient) {
|
||||
// subscribe to carbons
|
||||
let ctx = xmppConnection.module(MessageCarbonsModule.self).context
|
||||
xmppConnection.module(MessageCarbonsModule.self).carbonsPublisher
|
||||
.sink { [weak self] carbon in
|
||||
self?.handleMessage(carbon)
|
||||
self?.handleMessage(carbon, ctx)
|
||||
}
|
||||
.store(in: &cancellables)
|
||||
|
||||
|
@ -22,7 +23,7 @@ final class ClientMartinCarbonsManager {
|
|||
.store(in: &cancellables)
|
||||
}
|
||||
|
||||
private func handleMessage(_ received: Martin.MessageCarbonsModule.CarbonReceived) {
|
||||
private func handleMessage(_ received: Martin.MessageCarbonsModule.CarbonReceived, _ context: Context?) {
|
||||
let message = received.message
|
||||
let action = received.action
|
||||
let onJid = received.jid
|
||||
|
@ -34,7 +35,7 @@ final class ClientMartinCarbonsManager {
|
|||
print("---")
|
||||
#endif
|
||||
|
||||
if let msg = Message.map(message, context: nil) {
|
||||
if let msg = Message.map(message, context: context) {
|
||||
Task {
|
||||
do {
|
||||
try await msg.save()
|
||||
|
|
Loading…
Reference in a new issue