autoqtcpdistribution.h

#ifndef AUTOQTCPDISTRIBUTION_H
#define AUTOQTCPDISTRIBUTION_H
 
 
#include <QObject>
#include <QList>
#include <subscription.h>
#include <QHash>
#include <QString>
#include <QStringList>
#include <QVariant>
#include <QVariantList>
#include <QList>
#include <QPair>
#include <QSet>
#include <QUuid>
#include <autoqtcpserver.h>
#include <autoqtcpheader.h>
#include <platform_global.h>
 
namespace ADI {
 
class AutoQTcpSubDaemon;
class AutoQTcpSubClient;
 
class PLATFORMSHARED_EXPORT  AutoQTcpDistribution : public QObject
{
     Q_OBJECT
 
private :
 
 
     AutoQTcpServer *Layer1Server;
 
     QHash <QString, Subscription *> AllAutoSubscriptions;
 
     QSet<QString> GlobalSubscription;
     QSet<QString> LocalCloudSubscriptions;
 
     QHash <QString, AutoQTcpSubDaemon *> AllSubDaemons;
     QHash <QString, AutoQTcpSubClient *> AllSubClients;
 
     QVariant ourUniqueId;
 
     bool allowServer;
 
 
private slots :
 
     void SlotNewServerGlobalPub(QString newPub, bool yes);
 
     void SlotNewPublication(QString name);
     void SlotLostPublication(QString name);
 
 
 
public:
 
 
    typedef enum { Originals, OnLooker  } SUBORIGIN;
 
    explicit AutoQTcpDistribution(QString interface, QString netmask = "255.255.255.205"
                , int servicePort = 4892, SUBORIGIN author =  Originals,  QObject *parent = nullptr);
 
    virtual ~AutoQTcpDistribution();
 
    virtual Subscription *GetSubscription(QString name );
 
    bool GetAllowServer(void )
    {
         return allowServer ;
     }
 
     bool IsThisGlobal(QString name) {
         return GlobalSubscription.contains(name);
     }
 
     QStringList GetAllGlobalNames(void);
 
     QStringList GetAllLocalNames(void);
 
     bool HaveLocal(QString name)
     {
         return LocalCloudSubscriptions.contains(name);
     }
 
     void WriteAsDaemon( QString Key, QVariantList &vl );
 
     void WriteAsClient( QString Key, QVariantList &vl );
 
     void RemoteNameFound(int, QString name);
 
     void RemoteNameLost( int, QString name);
 
     QVariant getOurUniqueId(void)
     {
         return ourUniqueId;
     }
 
 public slots :
 
     void ClientConnected(QString);
 
     void ClientDisconnected(QString);
 
     void DaemonConnected(QString);
 
     void DaemonDisconnected(QString);
 
     void DataReadyDaemon( QString key, QVariantList message );
 
     void DataReadyClient( QString key, QVariantList message );
 
signals:
 
     void NewGlobalName(QString);
 
     void LostGlobalName(QString);
 
     void NewLocalName(QString);
 
     void LostLocalName(QString);
 
     void SignalNewRemotePublication(int,QString);
 
     void SignalLostRemotePublication(int,QString);
 
};
 
}
 
#endif // AUTOQTCPDISTRIBUTION_H