akonadicontrol/agentmanager.h

/***************************************************************************
 *   SPDX-FileCopyrightText: 2006 Tobias Koenig <tokoe@kde.org>            *
 *   SPDX-FileCopyrightText: 2007 Volker Krause <vkrause@kde.org>          *
 *                                                                         *
 *   SPDX-License-Identifier: LGPL-2.0-or-later                            *
 ***************************************************************************/
 
#pragma once
 
#include <QHash>
#include <QStringList>
 
#include "agentinstance.h"
#include "agenttype.h"
 
class QDir;
 
namespace Akonadi
{
class ProcessControl;
}
 
/**
 * The agent manager has knowledge about all available agents (it scans
 * for .desktop files in the agent directory) and the available configured
 * instances.
 */
class AgentManager : public QObject, protected QDBusContext
{
    Q_OBJECT
    Q_CLASSINFO("D-Bus Interface", "org.freedesktop.Akonadi.AgentManager")
 
public:
    /**
     * Creates a new agent manager.
     *
     * @param parent The parent object.
     */
    explicit AgentManager(bool verbose, QObject *parent = nullptr);
 
    /**
     * Destroys the agent manager.
     */
    ~AgentManager() override;
 
    /**
     * Called by the crash handler and dtor to terminate
     * the child processes.
     */
    void cleanup();
 
    /**
     * Returns the list of identifiers of all available
     * agent types.
     */
    [[nodiscard]] QStringList agentTypes() const;
 
    /**
     * Returns the i18n'ed name of the agent type for
     * the given @p identifier.
     */
    [[nodiscard]] QString agentName(const QString &identifier) const;
 
    /**
     * Returns the i18n'ed comment of the agent type for
     * the given @p identifier..
     */
    [[nodiscard]] QString agentComment(const QString &identifier) const;
 
    /**
     * Returns the icon name of the agent type for the
     * given @p identifier.
     */
    [[nodiscard]] QString agentIcon(const QString &identifier) const;
 
    /**
     * Returns a list of supported mimetypes of the agent type
     * for the given @p identifier.
     */
    [[nodiscard]] QStringList agentMimeTypes(const QString &identifier) const;
 
    /**
     * Returns a list of supported capabilities of the agent type
     * for the given @p identifier.
     */
    [[nodiscard]] QStringList agentCapabilities(const QString &identifier) const;
 
    /**
     * Returns a list of Custom added properties of the agent type
     * for the given @p identifier
     * @since 1.11
     */
    [[nodiscard]] QVariantMap agentCustomProperties(const QString &identifier) const;
 
    /**
     * Creates a new agent of the given agent type @p identifier.
     *
     * @return The identifier of the new agent if created successfully,
     *         an empty string otherwise.
     *         The identifier consists of two parts, the type of the
     *         agent and an unique instance number, and looks like
     *         the following: 'file_1' or 'imap_267'.
     */
    [[nodiscard]] QString createAgentInstance(const QString &identifier);
 
    /**
     * Removes the agent with the given @p identifier.
     */
    void removeAgentInstance(const QString &identifier);
 
    /**
     * Returns the type of the agent instance with the given @p identifier.
     */
    [[nodiscard]] QString agentInstanceType(const QString &identifier);
 
    /**
     * Returns the list of identifiers of configured instances.
     */
    [[nodiscard]] QStringList agentInstances() const;
 
    /**
     * Returns the current status code of the agent with the given @p identifier.
     */
    int agentInstanceStatus(const QString &identifier) const;
 
    /**
     * Returns the i18n'ed description of the current status of the agent with
     * the given @p identifier.
     */
    [[nodiscard]] QString agentInstanceStatusMessage(const QString &identifier) const;
 
    /**
     * Returns the current progress of the agent with the given @p identifier
     * in percentage.
     */
    [[nodiscard]] uint agentInstanceProgress(const QString &identifier) const;
 
    /**
     * Returns the i18n'ed description of the current progress of the agent with
     * the given @p identifier.
     */
    QString agentInstanceProgressMessage(const QString &identifier) const;
 
    /**
     * Sets the @p name of the agent instance with the given @p identifier.
     */
    void setAgentInstanceName(const QString &identifier, const QString &name);
 
    /**
     * Returns the name of the agent instance with the given @p identifier.
     */
    [[nodiscard]] QString agentInstanceName(const QString &identifier) const;
 
    /**
     * Triggers the agent instance with the given @p identifier to show
     * its configuration dialog.
     * @param windowId Parent window id for the configuration dialog.
     */
    void agentInstanceConfigure(const QString &identifier, qlonglong windowId);
 
    /**
     * Triggers the agent instance with the given @p identifier to start
     * synchronization.
     */
    void agentInstanceSynchronize(const QString &identifier);
 
    /**
      Trigger a synchronization of the collection tree by the given resource agent.
      @param identifier The resource agent identifier.
    */
    void agentInstanceSynchronizeCollectionTree(const QString &identifier);
 
    /**
      Trigger a synchronization of the given collection by its owning resource agent.
    */
    void agentInstanceSynchronizeCollection(const QString &identifier, qint64 collection);
 
    /**
      Trigger a synchronization of the given collection by its owning resource agent.
      @param recursive set it true to have sub-collection synchronized as well
    */
    void agentInstanceSynchronizeCollection(const QString &identifier, qint64 collection, bool recursive);
 
    /**
     * Trigger a synchronization of tags by the given resource agent.
     * @param identifier The resource agent identifier.
     */
    void agentInstanceSynchronizeTags(const QString &identifier);
 
    /**
      Returns if the agent instance @p identifier is in online mode.
    */
    bool agentInstanceOnline(const QString &identifier);
 
    /**
      Sets agent instance @p identifier to online or offline mode.
    */
    void setAgentInstanceOnline(const QString &identifier, bool state);
 
    /**
      Restarts the agent instance @p identifier. This is supposed to be used as a
      development aid and not something to use during normal operations.
    */
    void restartAgentInstance(const QString &identifier);
 
    /**
     * Add a persistent search to remote search agents.
     */
    void addSearch(const QString &query, const QString &queryLanguage, qint64 resultCollectionId);
 
    /**
     * Removes a persistent search for the given result collection.
     */
    void removeSearch(quint64 resultCollectionId);
 
    void setAgentInstanceActivities(const QString &identifier, const QStringList &activities);
    [[nodiscard]] QStringList agentInstanceActivities(const QString &identifier);
 
    void setAgentInstanceActivitiesEnabled(const QString &identifier, bool enabled);
    [[nodiscard]] bool agentInstanceActivitiesEnabled(const QString &identifier);
 
Q_SIGNALS:
    /**
     * This signal is emitted whenever a new agent type was installed on the system.
     *
     * @param agentType The identifier of the new agent type.
     */
    void agentTypeAdded(const QString &agentType);
 
    /**
     * This signal is emitted whenever an agent type was removed from the system.
     *
     * @param agentType The identifier of the removed agent type.
     */
    void agentTypeRemoved(const QString &agentType);
 
    /**
     * This signal is emitted whenever a new agent instance was created.
     *
     * @param agentIdentifier The identifier of the new agent instance.
     */
    void agentInstanceAdded(const QString &agentIdentifier);
 
    /**
     * This signal is emitted whenever an agent instance was removed.
     *
     * @param agentIdentifier The identifier of the removed agent instance.
     */
    void agentInstanceRemoved(const QString &agentIdentifier);
 
    /**
     * This signal is emitted whenever the status of an agent instance has
     * changed.
     *
     * @param agentIdentifier The identifier of the agent that has changed.
     * @param status The new status code.
     * @param message The i18n'ed description of the new status.
     */
    void agentInstanceStatusChanged(const QString &agentIdentifier, int status, const QString &message);
 
    /**
     * This signal is emitted whenever the status of an agent instance has
     * changed.
     *
     * @param agentIdentifier The identifier of the agent that has changed.
     * @param status The object that describes the status change.
     */
    void agentInstanceAdvancedStatusChanged(const QString &agentIdentifier, const QVariantMap &status);
 
    /**
     * This signal is emitted whenever the progress of an agent instance has
     * changed.
     *
     * @param agentIdentifier The identifier of the agent that has changed.
     * @param progress The new progress in percentage.
     * @param message The i18n'ed description of the new progress.
     */
    void agentInstanceProgressChanged(const QString &agentIdentifier, uint progress, const QString &message);
 
    /**
     * This signal is emitted whenever an agent instance raised a warning.
     *
     * @param agentIdentifier The identifier of the agent instance.
     * @param message The i18n'ed warning message.
     */
    void agentInstanceWarning(const QString &agentIdentifier, const QString &message);
 
    /**
     * This signal is emitted whenever an agent instance raised an error.
     *
     * @param agentIdentifier The identifier of the agent instance.
     * @param message The i18n'ed error message.
     */
    void agentInstanceError(const QString &agentIdentifier, const QString &message);
 
    /**
     * This signal is emitted whenever the name of the agent instance has changed.
     *
     * @param agentIdentifier The identifier of the agent that has changed.
     * @param name The new name of the agent instance.
     */
    void agentInstanceNameChanged(const QString &agentIdentifier, const QString &name);
 
    /**
     * Emitted when the online state of an agent changed.
     */
    void agentInstanceOnlineChanged(const QString &agentIdentifier, bool state);
 
private Q_SLOTS:
    void updatePluginInfos();
    void serviceOwnerChanged(const QString &name, const QString &oldOwner, const QString &newOwner);
    void agentExeChanged(const QString &fileName);
 
private:
    /**
     * Returns the list of directory paths where the .desktop files
     * for the plugins are located.
     */
    static QStringList pluginInfoPathList();
 
    /**
     * Loads the internal state from config file.
     */
    void load();
 
    /**
     * Saves internal state to the config file.
     */
    void save();
 
    /**
     * Reads the plugin information from directory.
     */
    void readPluginInfos();
 
    /**
     * Reads the plugin information from directory.
     *
     * @param directory the directory to get plugin information from
     */
    void readPluginInfos(const QDir &directory);
 
    AgentInstance::Ptr createAgentInstance(const AgentType &type);
    bool checkAgentInterfaces(const QString &identifier, const QString &method) const;
    bool checkInstance(const QString &identifier) const;
    bool checkResourceInterface(const QString &identifier, const QString &method) const;
    bool checkAgentExists(const QString &identifier) const;
    void ensureAutoStart(const AgentType &info);
    void continueStartup();
    void registerAgentAtServer(const QString &agentIdentifier, const AgentType &type);
 
private:
    /**
     * The map which stores the .desktop file
     * entries for every agent type.
     *
     * Key is the agent type (e.g. 'file' or 'imap').
     */
    QHash<QString, AgentType> mAgents;
 
    /**
     * The map which stores the active instances.
     *
     * Key is the instance identifier.
     */
    QHash<QString, AgentInstance::Ptr> mAgentInstances;
 
    std::unique_ptr<Akonadi::ProcessControl> mAgentServer;
    std::unique_ptr<Akonadi::ProcessControl> mStorageController;
    bool mAgentServerEnabled = false;
    bool mVerbose = false;
 
    friend class AgentInstance;
};