From 63f4e2043a1ef99638078ea316124d56bea9fe4a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Adrien=20B=C3=A9raud?= <adrien.beraud@savoirfairelinux.com>
Date: Sun, 6 Apr 2025 21:29:35 -0400
Subject: [PATCH] message channel: route messages through onTextMessage
Change-Id: I4f39abfb8cba90b428554b1972cf6ed72b7682e5
---
src/jamidht/message_channel_handler.cpp | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/jamidht/message_channel_handler.cpp b/src/jamidht/message_channel_handler.cpp
index 4dca17765c..97046eaae7 100644
--- a/src/jamidht/message_channel_handler.cpp
+++ b/src/jamidht/message_channel_handler.cpp
@@ -145,6 +145,7 @@ MessageChannelHandler::onReady(const std::shared_ptr<dht::crypto::Certificate>&
socket->setOnRecv([acc = pimpl_->account_.lock(),
peerId,
+ deviceId = device.toString(),
ctx = std::make_shared<DecodingContext>()](const uint8_t* buf, size_t len) {
if (!buf || !acc)
return len;
@@ -158,12 +159,11 @@ MessageChannelHandler::onReady(const std::shared_ptr<dht::crypto::Certificate>&
while (ctx->pac.next(oh)) {
Message msg;
oh.get().convert(msg);
- acc->handleMessage(peerId, {msg.t, msg.c});
+ acc->onTextMessage("", peerId, deviceId, {{msg.t, msg.c}});
}
} catch (const std::exception& e) {
- JAMI_WARNING("[convInfo] error on sync: {:s}", e.what());
+ JAMI_WARNING("[convInfo] Error parsing message: {:s}", e.what());
}
-
return len;
});
}
--
GitLab