File indexing completed on 2023-05-30 09:17:24

 /**
  * SPDX-FileCopyrightText: 2013 Albert Vaca <albertvaka@gmail.com>
  *
  * SPDX-License-Identifier: GPL-2.0-only OR GPL-3.0-only OR LicenseRef-KDE-Accepted-GPL
  */
 
 #include "notificationsmodel.h"
 
 #include <QDebug>
 #include <QIcon>
 
 #include <dbushelper.h>
 
 // In older Qt released, qAsConst isnt available
 #include "core/qtcompat_p.h"
 #include "interfaces_debug.h"
 
 NotificationsModel::NotificationsModel(QObject *parent)
     : QAbstractListModel(parent)
     , m_dbusInterface(nullptr)
 {
     connect(this, &QAbstractItemModel::rowsInserted, this, &NotificationsModel::rowsChanged);
     connect(this, &QAbstractItemModel::rowsRemoved, this, &NotificationsModel::rowsChanged);
 
     connect(this, &QAbstractItemModel::dataChanged, this, &NotificationsModel::anyDismissableChanged);
     connect(this, &QAbstractItemModel::rowsInserted, this, &NotificationsModel::anyDismissableChanged);
 
     QDBusServiceWatcher *watcher =
         new QDBusServiceWatcher(DaemonDbusInterface::activatedService(), QDBusConnection::sessionBus(), QDBusServiceWatcher::WatchForOwnerChange, this);
     connect(watcher, &QDBusServiceWatcher::serviceRegistered, this, &NotificationsModel::refreshNotificationList);
     connect(watcher, &QDBusServiceWatcher::serviceUnregistered, this, &NotificationsModel::clearNotifications);
 }
 
 QHash<int, QByteArray> NotificationsModel::roleNames() const
 {
     // Role names for QML
     QHash<int, QByteArray> names = QAbstractItemModel::roleNames();
     names.insert(DbusInterfaceRole, "dbusInterface");
     names.insert(AppNameModelRole, "appName");
     names.insert(IdModelRole, "notificationId");
     names.insert(DismissableModelRole, "dismissable");
     names.insert(RepliableModelRole, "repliable");
     names.insert(IconPathModelRole, "appIcon");
     names.insert(TitleModelRole, "title");
     names.insert(TextModelRole, "notitext");
     return names;
 }
 
 NotificationsModel::~NotificationsModel()
 {
 }
 
 QString NotificationsModel::deviceId() const
 {
     return m_deviceId;
 }
 
 void NotificationsModel::setDeviceId(const QString &deviceId)
 {
     m_deviceId = deviceId;
 
     if (m_dbusInterface) {
         delete m_dbusInterface;
     }
 
     m_dbusInterface = new DeviceNotificationsDbusInterface(deviceId, this);
 
     connect(m_dbusInterface, &OrgKdeKdeconnectDeviceNotificationsInterface::notificationPosted, this, &NotificationsModel::notificationAdded);
     connect(m_dbusInterface, &OrgKdeKdeconnectDeviceNotificationsInterface::notificationRemoved, this, &NotificationsModel::notificationRemoved);
     connect(m_dbusInterface, &OrgKdeKdeconnectDeviceNotificationsInterface::allNotificationsRemoved, this, &NotificationsModel::clearNotifications);
 
     refreshNotificationList();
 
     Q_EMIT deviceIdChanged(deviceId);
 }
 
 void NotificationsModel::notificationAdded(const QString &id)
 {
     beginInsertRows(QModelIndex(), 0, 0);
     NotificationDbusInterface *dbusInterface = new NotificationDbusInterface(m_deviceId, id, this);
     connect(dbusInterface, &NotificationDbusInterface::ready, this, &NotificationsModel::notificationUpdated);
     m_notificationList.prepend(dbusInterface);
     endInsertRows();
 }
 
 void NotificationsModel::notificationRemoved(const QString &id)
 {
     for (int i = 0; i < m_notificationList.size(); ++i) {
         if (m_notificationList[i]->notificationId() == id) {
             beginRemoveRows(QModelIndex(), i, i);
             m_notificationList.removeAt(i);
             endRemoveRows();
             return;
         }
     }
     qCWarning(KDECONNECT_INTERFACES) << "Attempted to remove unknown notification: " << id;
 }
 
 void NotificationsModel::refreshNotificationList()
 {
     if (!m_dbusInterface) {
         return;
     }
 
     clearNotifications();
 
     if (!m_dbusInterface->isValid()) {
         qCWarning(KDECONNECT_INTERFACES) << "dbus interface not valid";
         return;
     }
 
     QDBusPendingReply<QStringList> pendingNotificationIds = m_dbusInterface->activeNotifications();
     QDBusPendingCallWatcher *watcher = new QDBusPendingCallWatcher(pendingNotificationIds, this);
 
     QObject::connect(watcher, &QDBusPendingCallWatcher::finished, this, &NotificationsModel::receivedNotifications);
 }
 
 void NotificationsModel::receivedNotifications(QDBusPendingCallWatcher *watcher)
 {
     watcher->deleteLater();
     clearNotifications();
     QDBusPendingReply<QStringList> pendingNotificationIds = *watcher;
 
     if (pendingNotificationIds.isError()) {
         qCWarning(KDECONNECT_INTERFACES) << pendingNotificationIds.error();
         return;
     }
 
     const QStringList notificationIds = pendingNotificationIds.value();
     if (notificationIds.isEmpty()) {
         return;
     }
 
     beginInsertRows(QModelIndex(), 0, notificationIds.size() - 1);
     for (const QString &notificationId : notificationIds) {
         NotificationDbusInterface *dbusInterface = new NotificationDbusInterface(m_deviceId, notificationId, this);
         m_notificationList.append(dbusInterface);
     }
     endInsertRows();
 }
 
 QVariant NotificationsModel::data(const QModelIndex &index, int role) const
 {
     if (!index.isValid() || index.row() < 0 || index.row() >= m_notificationList.count() || !m_notificationList[index.row()]->isValid()) {
         return QVariant();
     }
 
     if (!m_dbusInterface || !m_dbusInterface->isValid()) {
         return QVariant();
     }
 
     NotificationDbusInterface *notification = m_notificationList[index.row()];
 
     // FIXME: This function gets called lots of times, producing lots of dbus calls. Add a cache?
     switch (role) {
     case IconModelRole:
         return QIcon::fromTheme(QStringLiteral("device-notifier"));
     case IdModelRole:
         return notification->internalId();
     case NameModelRole:
         return notification->ticker();
     case ContentModelRole:
         return QString(); // To implement in the Android side
     case AppNameModelRole:
         return notification->appName();
     case DbusInterfaceRole:
         return QVariant::fromValue<QObject *>(notification);
     case DismissableModelRole:
         return notification->dismissable();
     case RepliableModelRole:
         return !notification->replyId().isEmpty();
     case IconPathModelRole:
         return notification->iconPath();
     case TitleModelRole:
         return notification->title();
     case TextModelRole:
         return notification->text();
     default:
         return QVariant();
     }
 }
 
 NotificationDbusInterface *NotificationsModel::getNotification(const QModelIndex &index) const
 {
     if (!index.isValid()) {
         return nullptr;
     }
 
     int row = index.row();
     if (row < 0 || row >= m_notificationList.size()) {
         return nullptr;
     }
 
     return m_notificationList[row];
 }
 
 int NotificationsModel::rowCount(const QModelIndex &parent) const
 {
     if (parent.isValid()) {
         // Return size 0 if we are a child because this is not a tree
         return 0;
     }
 
     return m_notificationList.count();
 }
 
 bool NotificationsModel::isAnyDimissable() const
 {
     for (NotificationDbusInterface *notification : qAsConst(m_notificationList)) {
         if (notification->dismissable()) {
             return true;
         }
     }
     return false;
 }
 
 void NotificationsModel::dismissAll()
 {
     for (NotificationDbusInterface *notification : qAsConst(m_notificationList)) {
         if (notification->dismissable()) {
             notification->dismiss();
         }
     }
 }
 
 void NotificationsModel::clearNotifications()
 {
     if (!m_notificationList.isEmpty()) {
         beginRemoveRows(QModelIndex(), 0, m_notificationList.size() - 1);
         qDeleteAll(m_notificationList);
         m_notificationList.clear();
         endRemoveRows();
     }
 }
 
 void NotificationsModel::notificationUpdated()
 {
     Q_EMIT dataChanged(index(0, 0), index(m_notificationList.size() - 1, 0));
 }