File indexing completed on 2025-02-16 04:23:12

 /*
     SPDX-FileCopyrightText: 2022 Volker Krause <vkrause@kde.org>
     SPDX-License-Identifier: LGPL-2.0-or-later
 */
 
 #ifndef KUNIFIEDPUSH_DISTRIBUTOR_H
 #define KUNIFIEDPUSH_DISTRIBUTOR_H
 
 #include "abstractpushprovider.h"
 #include "command.h"
 
 #include "../shared/clientinfo_p.h"
 #include "../shared/distributorstatus_p.h"
 
 #include <QDBusContext>
 #include <QObject>
 
 #include <deque>
 #include <memory>
 #include <vector>
 
 namespace KUnifiedPush {
 
 class Client;
 class Message;
 
 /** UnifiedPush distributor service. */
 class Distributor : public QObject, public QDBusContext
 {
     Q_OBJECT
 public:
     explicit Distributor(QObject *parent = nullptr);
     ~Distributor();
 
     // UnifiedPush D-Bus interface
     QString Register(const QString &serviceName, const QString &token, const QString &description, QString &registrationResultReason);
     void Unregister(const QString &token);
 
     // KCM D-Bus interface
     int status() const;
     QString pushProviderId() const;
     QVariantMap pushProviderConfiguration(const QString &pushProviderId) const;
     void setPushProvider(const QString &pushProviderId, const QVariantMap &config);
     QList<KUnifiedPush::ClientInfo> registeredClients() const;
     void forceUnregisterClient(const QString &token);
 
 Q_SIGNALS:
     void statusChanged();
     void pushProviderChanged();
     void registeredClientsChanged();
 
 private:
     void messageReceived(const Message &msg) const;
     void clientRegistered(const Client &client, AbstractPushProvider::Error error, const QString &errorMsg);
     void clientUnregistered(const Client &client, AbstractPushProvider::Error error);
     void providerConnected();
     void providerDisconnected(AbstractPushProvider::Error error, const QString &errorMsg);
 
     QStringList clientTokens() const;
 
     bool setupPushProvider();
     void purgeUnavailableClients();
 
     bool hasCurrentCommand() const;
     void processNextCommand();
 
     void setStatus(DistributorStatus::Status status);
 
     bool isNetworkAvailable() const;
 
     std::unique_ptr<AbstractPushProvider> m_pushProvider;
     std::vector<Client> m_clients;
     Command m_currentCommand;
     std::deque<Command> m_commandQueue;
     DistributorStatus::Status m_status = DistributorStatus::Unknown;
 };
 
 }
 
 #endif // KUNIFIEDPUSH_DISTRIBUTOR_H