File indexing completed on 2024-05-26 05:14:07

 /*
     SPDX-FileCopyrightText: 2018 Daniel Vrátil <dvratil@kde.org>
 
     SPDX-License-Identifier: LGPL-2.0-or-later
 */
 
 #include "agentconfigurationmanager_p.h"
 #include "akonadicore_debug.h"
 #include "servermanager.h"
 
 #include <QCoreApplication>
 #include <QDBusConnectionInterface>
 #include <QDir>
 #include <QPluginLoader>
 
 #include <QDBusConnection>
 
 namespace Akonadi
 {
 class AgentConfigurationManagerPrivate
 {
 public:
     QString serviceName(const QString &instance) const
     {
         QString service = QStringLiteral("org.freedesktop.Akonadi.AgentConfig.%1").arg(instance);
         if (ServerManager::self()->hasInstanceIdentifier()) {
             service += QLatin1Char('.') + ServerManager::self()->instanceIdentifier();
         }
         return service;
     }
 };
 } // namespace Akonadi
 
 using namespace Akonadi;
 
 AgentConfigurationManager *AgentConfigurationManager::sInstance = nullptr;
 
 AgentConfigurationManager::AgentConfigurationManager(QObject *parent)
     : QObject(parent)
 {
 }
 
 AgentConfigurationManager *AgentConfigurationManager::self()
 {
     if (sInstance == nullptr) {
         sInstance = new AgentConfigurationManager();
     }
     return sInstance;
 }
 
 AgentConfigurationManager::~AgentConfigurationManager()
 {
 }
 
 bool AgentConfigurationManager::registerInstanceConfiguration(const QString &instance)
 {
     const auto serviceName = d->serviceName(instance);
     QDBusConnection conn = QDBusConnection::sessionBus();
     if (conn.interface()->isServiceRegistered(serviceName)) {
         qCDebug(AKONADICORE_LOG) << "Service " << serviceName << " is already registered";
         return false;
     }
 
     return conn.registerService(serviceName);
 }
 
 void AgentConfigurationManager::unregisterInstanceConfiguration(const QString &instance)
 {
     const auto serviceName = d->serviceName(instance);
     QDBusConnection::sessionBus().unregisterService(serviceName);
 }
 
 bool AgentConfigurationManager::isInstanceRegistered(const QString &instance) const
 {
     const auto serviceName = d->serviceName(instance);
     return QDBusConnection::sessionBus().interface()->isServiceRegistered(serviceName);
 }
 
 QString AgentConfigurationManager::findConfigPlugin(const QString &type) const
 {
     const auto libPaths = QCoreApplication::libraryPaths();
     const QString prefixPluginPath = QStringLiteral("pim6/akonadi/config");
     for (const auto &libPath : libPaths) {
         const QString pluginPath = QStringLiteral("%1/%2/").arg(libPath, prefixPluginPath);
         const auto libs = QDir(pluginPath).entryInfoList(QDir::Files | QDir::NoDotAndDotDot);
         for (const auto &lib : libs) {
             QPluginLoader loader(lib.absoluteFilePath());
             const auto metaData = loader.metaData().toVariantMap();
             if (metaData.value(QStringLiteral("IID")).toString() != QLatin1StringView("org.freedesktop.Akonadi.AgentConfig")) {
                 continue;
             }
             const auto md = metaData.value(QStringLiteral("MetaData")).toMap();
             if (md.value(QStringLiteral("X-Akonadi-PluginType")).toString() != QLatin1StringView("AgentConfig")) {
                 continue;
             }
             if (!type.startsWith(md.value(QStringLiteral("X-Akonadi-AgentConfig-Type")).toString())) {
                 continue;
             }
             return loader.fileName();
         }
     }
 
     return {};
 }
 
 #include "moc_agentconfigurationmanager_p.cpp"