aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/CMakeLists.txt2
-rw-r--r--src/client/QXmppCarbonManagerV2.cpp165
-rw-r--r--src/client/QXmppCarbonManagerV2.h26
3 files changed, 193 insertions, 0 deletions
diff --git a/src/CMakeLists.txt b/src/CMakeLists.txt
index c02c4015..c7ffdb53 100644
--- a/src/CMakeLists.txt
+++ b/src/CMakeLists.txt
@@ -96,6 +96,7 @@ set(INSTALL_HEADER_FILES
client/QXmppAttentionManager.h
client/QXmppBookmarkManager.h
client/QXmppCarbonManager.h
+ client/QXmppCarbonManagerV2.h
client/QXmppClient.h
client/QXmppClientExtension.h
client/QXmppConfiguration.h
@@ -210,6 +211,7 @@ set(SOURCE_FILES
client/QXmppAttentionManager.cpp
client/QXmppBookmarkManager.cpp
client/QXmppCarbonManager.cpp
+ client/QXmppCarbonManagerV2.cpp
client/QXmppClient.cpp
client/QXmppClientExtension.cpp
client/QXmppConfiguration.cpp
diff --git a/src/client/QXmppCarbonManagerV2.cpp b/src/client/QXmppCarbonManagerV2.cpp
new file mode 100644
index 00000000..25b76ec7
--- /dev/null
+++ b/src/client/QXmppCarbonManagerV2.cpp
@@ -0,0 +1,165 @@
+// SPDX-FileCopyrightText: 2022 Linus Jahn <lnj@kaidan.im>
+//
+// SPDX-License-Identifier: LGPL-2.1-or-later
+
+#include "QXmppCarbonManagerV2.h"
+
+#include "QXmppClient.h"
+#include "QXmppConstants_p.h"
+#include "QXmppFutureUtils_p.h"
+#include "QXmppMessage.h"
+
+#include <QDomElement>
+#include <QStringBuilder>
+
+using namespace QXmpp;
+using namespace QXmpp::Private;
+using Manager = QXmppCarbonManagerV2;
+
+class CarbonEnableIq : public QXmppIq
+{
+public:
+ CarbonEnableIq()
+ : QXmppIq()
+ {
+ setType(QXmppIq::Set);
+ }
+
+ // parsing not implemented
+ void parseElementFromChild(const QDomElement &) override
+ {
+ }
+ void toXmlElementFromChild(QXmlStreamWriter *writer) const override
+ {
+ writer->writeStartElement(ns_carbons, "enable");
+ writer->writeEndElement();
+ }
+};
+
+auto firstXmlnsElement(const QDomElement &el, const char *xmlns)
+{
+ for (auto child = el.firstChildElement();
+ !child.isNull();
+ child = child.nextSiblingElement()) {
+ if (child.namespaceURI() == xmlns) {
+ return child;
+ }
+ }
+ return QDomElement();
+}
+
+auto firstChildElement(const QDomElement &el, const char *tagName, const char *xmlns)
+{
+ for (auto child = el.firstChild();
+ !child.isNull();
+ child = child.nextSibling()) {
+ if (child.isElement() && child.namespaceURI() == xmlns) {
+ auto childEl = child.toElement();
+ if (childEl.tagName() == tagName) {
+ return childEl;
+ }
+ }
+ }
+ return QDomElement();
+}
+
+auto parseIq(std::variant<QDomElement, SendError> &&sendResult) -> std::optional<QXmppStanza::Error>
+{
+ if (auto el = std::get_if<QDomElement>(&sendResult)) {
+ auto iqType = el->attribute(QStringLiteral("type"));
+ if (iqType == "result") {
+ return {};
+ }
+ QXmppIq iq;
+ iq.parse(*el);
+ return iq.error();
+ } else if (auto err = std::get_if<SendError>(&sendResult)) {
+ using Error = QXmppStanza::Error;
+ return Error(Error::Wait, Error::UndefinedCondition,
+ QStringLiteral("Couldn't send request: ") + err->text);
+ }
+ return {};
+}
+
+///
+/// \class QXmppCarbonManagerV2
+///
+/// \brief The QXmppCarbonManagerV2 class handles message carbons as described in \xep{0280,
+/// Message Carbons}.
+///
+/// The manager automatically enables carbons when a connection is established. If the connection
+/// could be resumed, no new request is done. Carbon copied messages from other devices of the same
+/// account and carbon copied messages from other accounts are injected into the QXmppClient. This
+/// way you can handle them like any other incoming message by implementing QXmppMessageHandler.
+///
+/// Checks are done to ensure that the entity sending the carbon copy is allowed to send the
+/// forwarded message.
+///
+/// You don't need to do anything other than adding the extension to the client to use it.
+/// \code
+/// QXmppClient client;
+/// client.addNewExtension<QXmppCarbonManagerV2>();
+/// \endcode
+///
+/// \ingroup Managers
+///
+/// \since QXmpp 1.5
+///
+
+bool Manager::handleStanza(const QDomElement &element, const std::optional<QXmppE2eeMetadata> &)
+{
+ if (element.tagName() != "message") {
+ return false;
+ }
+
+ auto carbon = firstXmlnsElement(element, ns_carbons);
+ if (carbon.isNull() || (carbon.tagName() != "sent" && carbon.tagName() != "received")) {
+ return false;
+ }
+
+ // carbon copies must always come from our bare JID
+ auto from = element.attribute(QStringLiteral("from"));
+ if (from != client()->configuration().jidBare()) {
+ info("Received carbon copy from attacker or buggy client '" % from %
+ "' trying to use CVE-2017-5603.");
+ return false;
+ }
+
+ auto forwarded = firstChildElement(carbon, "forwarded", ns_forwarding);
+ auto messageElement = firstChildElement(forwarded, "message", ns_client);
+ if (messageElement.isNull()) {
+ return false;
+ }
+
+ QXmppMessage message;
+ message.parse(messageElement);
+
+ injectMessage(std::move(message));
+ return true;
+}
+
+void Manager::setClient(QXmppClient *newClient)
+{
+ if (client()) {
+ disconnect(client(), &QXmppClient::connected, this, &Manager::enableCarbons);
+ }
+
+ QXmppClientExtension::setClient(newClient);
+ connect(newClient, &QXmppClient::connected, this, &Manager::enableCarbons);
+}
+
+void Manager::enableCarbons()
+{
+ if (client()->streamManagementState() == QXmppClient::ResumedStream) {
+ // skip re-enabling for resumed streams
+ return;
+ }
+
+ await(client()->sendIq(CarbonEnableIq()), this, [this](QXmppClient::IqResult domResult) {
+ if (auto err = parseIq(std::move(domResult))) {
+ warning("Could not enable message carbons: " % err->text());
+ } else {
+ info("Message Carbons enabled.");
+ }
+ });
+}
diff --git a/src/client/QXmppCarbonManagerV2.h b/src/client/QXmppCarbonManagerV2.h
new file mode 100644
index 00000000..405792d0
--- /dev/null
+++ b/src/client/QXmppCarbonManagerV2.h
@@ -0,0 +1,26 @@
+// SPDX-FileCopyrightText: 2022 Linus Jahn <lnj@kaidan.im>
+//
+// SPDX-License-Identifier: LGPL-2.1-or-later
+
+#ifndef QXMPPCARBONMANAGERV2_H
+#define QXMPPCARBONMANAGERV2_H
+
+#include "QXmppClientExtension.h"
+
+class QXMPP_EXPORT QXmppCarbonManagerV2 : public QXmppClientExtension
+{
+ Q_OBJECT
+public:
+ bool handleStanza(const QDomElement &, const std::optional<QXmppE2eeMetadata> &) override;
+
+protected:
+ void setClient(QXmppClient *client) override;
+
+private:
+ void enableCarbons();
+
+ // placeholder (we may need a d-ptr in the future)
+ void *d;
+};
+
+#endif // QXMPPCARBONMANAGERV2_H
generated by cgit v1.2.3 (git 2.39.1) at 2026-06-09 14:40:27 +0000