File indexing completed on 2024-06-23 05:06:51

 /*
     SPDX-FileCopyrightText: 2006-2007 Volker Krause <vkrause@kde.org>
 
     SPDX-License-Identifier: LGPL-2.0-or-later
 */
 
 #include "monitor.h"
 #include "monitor_p.h"
 
 #include "changemediator_p.h"
 #include "collectionfetchscope.h"
 #include "session.h"
 
 #include "shared/akranges.h"
 
 #include <QMetaMethod>
 
 using namespace Akonadi;
 using namespace AkRanges;
 
 Monitor::Monitor(QObject *parent)
     : QObject(parent)
     , d_ptr(new MonitorPrivate(nullptr, this))
 {
     d_ptr->init();
     d_ptr->connectToNotificationManager();
 
     ChangeMediator::registerMonitor(this);
 }
 
 /// @cond PRIVATE
 Monitor::Monitor(MonitorPrivate *d, QObject *parent)
     : QObject(parent)
     , d_ptr(d)
 {
     d_ptr->init();
     d_ptr->connectToNotificationManager();
 
     ChangeMediator::registerMonitor(this);
 }
 /// @endcond
 
 Monitor::~Monitor()
 {
     ChangeMediator::unregisterMonitor(this);
 }
 
 void Monitor::setCollectionMonitored(const Collection &collection, bool monitored)
 {
     Q_D(Monitor);
     if (!d->collections.contains(collection) && monitored) {
         d->collections << collection;
         d->pendingModification.startMonitoringCollection(collection.id());
         d->scheduleSubscriptionUpdate();
     } else if (!monitored) {
         if (d->collections.removeAll(collection)) {
             d->pendingModification.stopMonitoringCollection(collection.id());
             d->scheduleSubscriptionUpdate();
         }
     }
 
     Q_EMIT collectionMonitored(collection, monitored); // NOLINT(readability-misleading-indentation): false positive
 }
 
 void Monitor::setItemMonitored(const Item &item, bool monitored)
 {
     Q_D(Monitor);
     if (!d->items.contains(item.id()) && monitored) {
         d->items.insert(item.id());
         d->pendingModification.startMonitoringItem(item.id());
         d->scheduleSubscriptionUpdate();
     } else if (!monitored) {
         if (d->items.remove(item.id())) {
             d->pendingModification.stopMonitoringItem(item.id());
             d->scheduleSubscriptionUpdate();
         }
     }
 
     Q_EMIT itemMonitored(item, monitored); // NOLINT(readability-misleading-indentation): false positive
 }
 
 void Monitor::setResourceMonitored(const QByteArray &resource, bool monitored)
 {
     Q_D(Monitor);
     if (!d->resources.contains(resource) && monitored) {
         d->resources.insert(resource);
         d->pendingModification.startMonitoringResource(resource);
         d->scheduleSubscriptionUpdate();
     } else if (!monitored) {
         if (d->resources.remove(resource)) {
             d->pendingModification.stopMonitoringResource(resource);
             d->scheduleSubscriptionUpdate();
         }
     }
 
     Q_EMIT resourceMonitored(resource, monitored); // NOLINT(readability-misleading-indentation): false positive
 }
 
 void Monitor::setMimeTypeMonitored(const QString &mimetype, bool monitored)
 {
     Q_D(Monitor);
     if (!d->mimetypes.contains(mimetype) && monitored) {
         d->mimetypes.insert(mimetype);
         d->pendingModification.startMonitoringMimeType(mimetype);
         d->scheduleSubscriptionUpdate();
     } else if (!monitored) {
         if (d->mimetypes.remove(mimetype)) {
             d->pendingModification.stopMonitoringMimeType(mimetype);
             d->scheduleSubscriptionUpdate();
         }
     }
 
     Q_EMIT mimeTypeMonitored(mimetype, monitored); // NOLINT(readability-misleading-indentation): false positive
 }
 
 void Monitor::setTagMonitored(const Akonadi::Tag &tag, bool monitored)
 {
     Q_D(Monitor);
     if (!d->tags.contains(tag.id()) && monitored) {
         d->tags.insert(tag.id());
         d->pendingModification.startMonitoringTag(tag.id());
         d->scheduleSubscriptionUpdate();
     } else if (!monitored) {
         if (d->tags.remove(tag.id())) {
             d->pendingModification.stopMonitoringTag(tag.id());
             d->scheduleSubscriptionUpdate();
         }
     }
 
     Q_EMIT tagMonitored(tag, monitored); // NOLINT(readability-misleading-indentation): false positive
 }
 
 void Monitor::setTypeMonitored(Monitor::Type type, bool monitored)
 {
     Q_D(Monitor);
     if (!d->types.contains(type) && monitored) {
         d->types.insert(type);
         d->pendingModification.startMonitoringType(MonitorPrivate::monitorTypeToProtocol(type));
         d->scheduleSubscriptionUpdate();
     } else if (!monitored) {
         if (d->types.remove(type)) {
             d->pendingModification.stopMonitoringType(MonitorPrivate::monitorTypeToProtocol(type));
             d->scheduleSubscriptionUpdate();
         }
     }
 
     Q_EMIT typeMonitored(type, monitored); // NOLINT(readability-misleading-indentation): false positive
 }
 
 void Akonadi::Monitor::setAllMonitored(bool monitored)
 {
     Q_D(Monitor);
     if (d->monitorAll == monitored) {
         return;
     }
 
     d->monitorAll = monitored;
 
     d->pendingModification.setAllMonitored(monitored);
     d->scheduleSubscriptionUpdate();
 
     Q_EMIT allMonitored(monitored);
 }
 
 void Monitor::setExclusive(bool exclusive)
 {
     Q_D(Monitor);
     d->exclusive = exclusive;
     d->pendingModification.setIsExclusive(exclusive);
     d->scheduleSubscriptionUpdate();
 }
 
 bool Monitor::exclusive() const
 {
     Q_D(const Monitor);
     return d->exclusive;
 }
 
 void Monitor::ignoreSession(Session *session)
 {
     Q_D(Monitor);
 
     if (!d->sessions.contains(session->sessionId())) {
         d->sessions << session->sessionId();
         connect(session, &Session::destroyed, this, [d](QObject *o) {
             d->slotSessionDestroyed(o);
         });
         d->pendingModification.startIgnoringSession(session->sessionId());
         d->scheduleSubscriptionUpdate();
     }
 }
 
 void Monitor::fetchCollection(bool enable)
 {
     Q_D(Monitor);
     d->fetchCollection = enable;
 }
 
 void Monitor::fetchCollectionStatistics(bool enable)
 {
     Q_D(Monitor);
     d->fetchCollectionStatistics = enable;
 }
 
 void Monitor::setItemFetchScope(const ItemFetchScope &fetchScope)
 {
     Q_D(Monitor);
     d->mItemFetchScope = fetchScope;
     d->pendingModificationChanges |= Protocol::ModifySubscriptionCommand::ItemFetchScope;
     d->scheduleSubscriptionUpdate();
 }
 
 ItemFetchScope &Monitor::itemFetchScope()
 {
     Q_D(Monitor);
     d->pendingModificationChanges |= Protocol::ModifySubscriptionCommand::ItemFetchScope;
     d->scheduleSubscriptionUpdate();
     return d->mItemFetchScope;
 }
 
 void Monitor::fetchChangedOnly(bool enable)
 {
     Q_D(Monitor);
     d->mFetchChangedOnly = enable;
 }
 
 void Monitor::setCollectionFetchScope(const CollectionFetchScope &fetchScope)
 {
     Q_D(Monitor);
     d->mCollectionFetchScope = fetchScope;
     d->pendingModificationChanges |= Protocol::ModifySubscriptionCommand::CollectionFetchScope;
     d->scheduleSubscriptionUpdate();
 }
 
 CollectionFetchScope &Monitor::collectionFetchScope()
 {
     Q_D(Monitor);
     d->pendingModificationChanges |= Protocol::ModifySubscriptionCommand::CollectionFetchScope;
     d->scheduleSubscriptionUpdate();
     return d->mCollectionFetchScope;
 }
 
 void Monitor::setTagFetchScope(const TagFetchScope &fetchScope)
 {
     Q_D(Monitor);
     d->mTagFetchScope = fetchScope;
     d->pendingModificationChanges |= Protocol::ModifySubscriptionCommand::TagFetchScope;
     d->scheduleSubscriptionUpdate();
 }
 
 TagFetchScope &Monitor::tagFetchScope()
 {
     Q_D(Monitor);
     d->pendingModificationChanges |= Protocol::ModifySubscriptionCommand::TagFetchScope;
     d->scheduleSubscriptionUpdate();
     return d->mTagFetchScope;
 }
 
 Akonadi::Collection::List Monitor::collectionsMonitored() const
 {
     Q_D(const Monitor);
     return d->collections;
 }
 
 QList<Item::Id> Monitor::itemsMonitoredEx() const
 {
     Q_D(const Monitor);
     QList<Item::Id> result;
     result.reserve(d->items.size());
     std::copy(d->items.begin(), d->items.end(), std::back_inserter(result));
     return result;
 }
 
 int Monitor::numItemsMonitored() const
 {
     Q_D(const Monitor);
     return d->items.size();
 }
 
 QList<Tag::Id> Monitor::tagsMonitored() const
 {
     Q_D(const Monitor);
     QList<Tag::Id> result;
     result.reserve(d->tags.size());
     std::copy(d->tags.begin(), d->tags.end(), std::back_inserter(result));
     return result;
 }
 
 QList<Monitor::Type> Monitor::typesMonitored() const
 {
     Q_D(const Monitor);
     QList<Monitor::Type> result;
     result.reserve(d->types.size());
     std::copy(d->types.begin(), d->types.end(), std::back_inserter(result));
     return result;
 }
 
 QStringList Monitor::mimeTypesMonitored() const
 {
     Q_D(const Monitor);
     return d->mimetypes | Actions::toQList;
 }
 
 int Monitor::numMimeTypesMonitored() const
 {
     Q_D(const Monitor);
     return d->mimetypes.count();
 }
 
 QList<QByteArray> Monitor::resourcesMonitored() const
 {
     Q_D(const Monitor);
     return d->resources | Actions::toQList;
 }
 
 int Monitor::numResourcesMonitored() const
 {
     Q_D(const Monitor);
     return d->resources.count();
 }
 
 bool Monitor::isAllMonitored() const
 {
     Q_D(const Monitor);
     return d->monitorAll;
 }
 
 void Monitor::setSession(Akonadi::Session *session)
 {
     Q_D(Monitor);
     if (session == d->session) {
         return;
     }
 
     if (!session) {
         d->session = Session::defaultSession();
     } else {
         d->session = session;
     }
 
     d->itemCache->setSession(d->session);
     d->collectionCache->setSession(d->session);
     d->tagCache->setSession(d->session);
 
     // Reconnect with a new session
     d->connectToNotificationManager();
 }
 
 Session *Monitor::session() const
 {
     Q_D(const Monitor);
     return d->session;
 }
 
 void Monitor::setCollectionMoveTranslationEnabled(bool enabled)
 {
     Q_D(Monitor);
     d->collectionMoveTranslationEnabled = enabled;
 }
 
 void Monitor::connectNotify(const QMetaMethod &signal)
 {
     Q_D(Monitor);
     d->updateListeners(signal, MonitorPrivate::AddListener);
 }
 
 void Monitor::disconnectNotify(const QMetaMethod &signal)
 {
     Q_D(Monitor);
     d->updateListeners(signal, MonitorPrivate::RemoveListener);
 }
 
 #include "moc_monitor.cpp"