Implement presence

Quotient/connection.cpp

@@ -33,6 +33,7 @@
 #include "events/encryptionevent.h"
 #include "jobs/downloadfilejob.h"
 #include "jobs/mediathumbnailjob.h"
+#include "events/presenceevent.h"
 
 // moc needs fully defined deps, see https://www.qt.io/blog/whats-new-in-qmetatype-qvariant
 #include "moc_connection.cpp" // NOLINT(bugprone-suspicious-include)
@@ -637,7 +638,26 @@ void Connection::Private::consumeAccountData(Events&& accountDataEvents)
 
 void Connection::Private::consumePresenceData(Events&& presenceData)
 {
-    // To be implemented
+    for (const auto &event : presenceData) {
+        auto presenceEvent = eventCast<const PresenceEvent>(event);
+        auto sender = presenceEvent->fullJson()[u"sender"_s].toString(); // TODO ?
+        if (presenceEvent->currentlyActive()) {
+            forcePresentUsers += sender;
+        } else {
+            forcePresentUsers.removeAll(sender);
+        }
+        if (presenceEvent->presence() == u"online") {
+            presentUsers += sender;
+        } else {
+            presentUsers.removeAll(sender);
+        }
+    }
+    Q_EMIT q->presenceChanged();
+}
+
+bool Connection::isUserPresent(const QString &userId) const
+{
+    return d->forcePresentUsers.contains(userId) || d->presentUsers.contains(userId);
 }
 
 void Connection::Private::consumeToDeviceEvents(Events&& toDeviceEvents)

Quotient/connection.h

@@ -807,6 +807,8 @@ public Q_SLOTS:
     static Connection* makeMockConnection(const QString& mxId,
                                           bool enableEncryption = true);
 
+    Q_INVOKABLE bool isUserPresent(const QString &userId) const;
+
 Q_SIGNALS:
     //! \brief Initial server resolution has failed
     //!
@@ -983,6 +985,8 @@ public Q_SLOTS:
     //! This does not mean that the server was reached, a sync was performed, or the state cache was loaded.
     void ready();
 
+    void presenceChanged();
+
     friend class ::TestCrossSigning;
 protected:
     //! Access the underlying ConnectionData class

Quotient/connection_p.h

@@ -52,6 +52,8 @@ class Q_DECL_HIDDEN Quotient::Connection::Private {
     std::unordered_map<QString, EventPtr> accountData;
     QMetaObject::Connection syncLoopConnection {};
     int syncTimeout = -1;
+    QStringList forcePresentUsers;
+    QStringList presentUsers;
 
     GetCapabilitiesJob::Capabilities capabilities{};
 

Quotient/events/presenceevent.h

@@ -0,0 +1,25 @@
+// SPDX-License-Identifier: LGPL-2.0-or-later
+// SPDX-FileCopyrightText: 2025 Tobias Fella <[email protected]>
+
+#pragma once
+
+#include "event.h"
+
+namespace Quotient
+{
+
+class QUOTIENT_API PresenceEvent : public Quotient::Event {
+public:
+    QUO_EVENT(PresenceEvent, "m.presence")
+
+    using Event::Event;
+
+    QUO_CONTENT_GETTER(QString, avatarUrl)
+    QUO_CONTENT_GETTER(bool, currentlyActive)
+    QUO_CONTENT_GETTER(QString, displayName)
+    QUO_CONTENT_GETTER(qint64, lastActiveTime)
+    QUO_CONTENT_GETTER(QString, presence)
+    QUO_CONTENT_GETTER(QString, statusMsg)
+};
+
+}