Implement push notification support

CMakeLists.txt

@@ -68,6 +68,8 @@ set_package_properties(KF6Kirigami2 PROPERTIES
         )
 find_package(KF6KirigamiAddons 0.7.2 REQUIRED)
 
+find_package(KUnifiedPush)
+
 if(ANDROID)
     find_package(OpenSSL)
     set_package_properties(OpenSSL PROPERTIES

src/CMakeLists.txt

@@ -333,6 +333,11 @@ endif()
 target_include_directories(neochat PRIVATE ${CMAKE_BINARY_DIR} ${CMAKE_CURRENT_SOURCE_DIR}/models ${CMAKE_CURRENT_SOURCE_DIR}/enums)
 target_link_libraries(neochat PUBLIC Qt::Core Qt::Quick Qt::Qml Qt::Gui Qt::Multimedia Qt::Network Qt::QuickControls2 KF6::I18n KF6::Kirigami2 KF6::Notifications KF6::ConfigCore KF6::ConfigGui KF6::CoreAddons KF6::SonnetCore  KF6::ItemModels QuotientQt6 cmark::cmark QCoro::Core)
 
+if(TARGET KUnifiedPush)
+    target_link_libraries(neochat PUBLIC KUnifiedPush)
+    target_compile_definitions(neochat PUBLIC -DHAVE_KUNIFIEDPUSH)
+endif()
+
 kconfig_add_kcfg_files(neochat GENERATE_MOC neochatconfig.kcfgc)
 
 if(NEOCHAT_FLATPAK)
@@ -438,6 +443,9 @@ endif()
 
 install(TARGETS neochat-app ${KDE_INSTALL_TARGETS_DEFAULT_ARGS})
 
+configure_file(org.kde.neochat.notifier.service.in ${CMAKE_CURRENT_BINARY_DIR}/org.kde.neochat.notifier.service)
+install(FILES ${CMAKE_CURRENT_BINARY_DIR}/org.kde.neochat.notifier.service DESTINATION ${KDE_INSTALL_DBUSSERVICEDIR})
+
 if (NOT ANDROID AND NOT WIN32 AND NOT APPLE)
     install(FILES plasma-runner-neochat.desktop DESTINATION ${KDE_INSTALL_DATAROOTDIR}/krunner/dbusplugins)
 endif()

src/controller.cpp

@@ -14,6 +14,13 @@
 #include <KWindowEffects>
 #endif
 
+#ifdef HAVE_KUNIFIEDPUSH
+#include <KUnifiedPush/Connector>
+#include <QCoroNetworkReply>
+#include <QDBusConnection>
+#include <qcoro/qcorosignal.h>
+#endif
+
 #include <QFile>
 #include <QFileInfo>
 #include <QGuiApplication>
@@ -41,6 +48,11 @@
 #include "roommanager.h"
 #include "windowcontroller.h"
 
+#ifdef HAVE_KUNIFIEDPUSH
+#include <Quotient/csapi/pusher.h>
+#include <Quotient/networkaccessmanager.h>
+#endif
+
 #if defined(Q_OS_WIN) || defined(Q_OS_MAC)
 #include "trayicon.h"
 #elif !defined(Q_OS_ANDROID)
@@ -49,9 +61,54 @@
 
 using namespace Quotient;
 
+#ifdef HAVE_KUNIFIEDPUSH
+QCoro::Task<void> Controller::setupPush(const QString &endpoint)
+{
+    while (!activeConnection()) {
+        co_await qCoro(this, &Controller::activeConnectionChanged);
+    }
+    QUrl gatewayEndpoint(endpoint);
+    gatewayEndpoint.setPath("/_matrix/push/v1/notify");
+    QNetworkRequest checkGateway(gatewayEndpoint);
+    auto reply = co_await NetworkAccessManager::instance()->get(checkGateway);
+    const QJsonObject replyJson = QJsonDocument::fromJson(reply->readAll()).object();
+    if (replyJson["unifiedpush"]["gateway"].toString() == QStringLiteral("matrix")) {
+        Controller::instance().activeConnection()->callApi<PostPusherJob>(endpoint,
+                                                                          "http",
+                                                                          "neochat-foo1",
+                                                                          "NeoChat",
+                                                                          "Device 1",
+                                                                          "en",
+                                                                          PostPusherJob::PusherData{{gatewayEndpoint.toString()}, " "});
+    } else {
+        qWarning() << "There's no gateway";
+    }
+}
+#endif
+
 Controller::Controller(QObject *parent)
     : QObject(parent)
 {
+#ifdef HAVE_KUNIFIEDPUSH
+    const auto serviceName = QStringLiteral("org.kde.neochat.notifier");
+    if (!QDBusConnection::sessionBus().registerService(serviceName)) {
+        qCritical() << "Service name already in use";
+        return;
+    }
+    auto connector = new KUnifiedPush::Connector(serviceName);
+    connect(connector, &KUnifiedPush::Connector::stateChanged, [](auto state) {
+        // TODO ?
+    });
+    connect(connector, &KUnifiedPush::Connector::messageReceived, [](const auto &msg) {
+        NotificationsManager::instance().postPushNotification(msg);
+    });
+    connect(connector, &KUnifiedPush::Connector::endpointChanged, [this](const auto &endpoint) {
+        setupPush(endpoint);
+    });
+
+    connector->registerClient(i18n("Receiving Matrix messages"));
+#endif
+
     Connection::setRoomType<NeoChatRoom>();
 
     setApplicationProxy();

src/controller.h

@@ -15,6 +15,10 @@
 #include <Quotient/jobs/basejob.h>
 #include <Quotient/settings.h>
 
+#ifdef HAVE_KUNIFIEDPUSH
+#include <qcoro/task.h>
+#endif
+
 class NeoChatRoom;
 class TrayIcon;
 class QQuickTextDocument;
@@ -177,6 +181,11 @@ private:
     explicit Controller(QObject *parent = nullptr);
 
     QPointer<NeoChatConnection> m_connection;
+
+#ifdef HAVE_KUNIFIEDPUSH
+    QCoro::Task<void> setupPush(const QString &endpoint);
+#endif
+
     TrayIcon *m_trayIcon = nullptr;
 
     QKeychain::ReadPasswordJob *loadAccessTokenFromKeyChain(const Quotient::AccountSettings &account);

src/notificationsmanager.cpp

@@ -6,6 +6,8 @@
 #include <memory>
 
 #include <QGuiApplication>
+#include <QJsonArray>
+#include <QJsonDocument>
 
 #include <KLocalizedString>
 #include <KNotification>
@@ -326,4 +328,33 @@ QPixmap NotificationsManager::createNotificationImage(const QImage &icon, NeoCha
     return QPixmap::fromImage(roundedImage);
 }
 
+void NotificationsManager::postPushNotification(const QByteArray &message)
+{
+    KNotification *notification = new KNotification("message"_ls);
+
+    const auto json = QJsonDocument::fromJson(message).object();
+
+    auto sender = json["notification"_ls]["sender_display_name"_ls].toString();
+    auto roomName = json["notification"_ls]["room_name"_ls].toString();
+    auto roomId = json["notification"_ls]["room_id"_ls].toString();
+    auto text = json["notification"_ls]["content"_ls]["body"_ls].toString();
+
+    if (sender == roomName) {
+        notification->setTitle(sender);
+    } else {
+        notification->setTitle(i18n("%1 (%2)", sender, roomName));
+    }
+
+    notification->setText(text.toHtmlEscaped());
+
+    notification->setDefaultAction(i18n("Open NeoChat in this room"));
+    connect(notification, &KNotification::defaultActivated, this, [=]() {
+        WindowController::instance().showAndRaiseWindow(notification->xdgActivationToken());
+    });
+
+    notification->sendEvent();
+
+    m_notifications.insert(roomId, notification);
+}
+
 #include "moc_notificationsmanager.cpp"

src/notificationsmanager.h

@@ -81,6 +81,7 @@ public:
      * Nothing happens if the given room doesn't have an invite notification.
      */
     void clearInvitationNotification(const QString &roomId);
+    void postPushNotification(const QByteArray &message);
 
     /**
      * @brief Handle the notifications for the given connection.

src/org.kde.neochat.notifier.service.in

@@ -0,0 +1,5 @@
+# SPDX-FileCopyrightText: none
+# SPDX-License-Identifier: CC0-1.0
+[D-BUS Service]
+Name=org.kde.neochat.notifier
+Exec=@CMAKE_INSTALL_PREFIX@/bin/neochat