devicemanager.h

/*
    SPDX-FileCopyrightText: 2003 Jasem Mutlaq <mutlaqja@ikarustech.com>
 
    SPDX-License-Identifier: GPL-2.0-or-later
*/
 
#pragma once
 
#include <QTcpSocket>
 
class INDIMenu;
class INDI_P;
class INDI_D;
 
class KProcess;
class QTcpSocket;
 
// INDI device manager
class DeviceManager : public QObject
{
    Q_OBJECT
  public:
    enum ManagerMode
    {
        M_LOCAL,
        M_SERVER,
        M_CLIENT
    };
    enum
    {
        INDI_DEVICE_NOT_FOUND    = -1,
        INDI_PROPERTY_INVALID    = -2,
        INDI_PROPERTY_DUPLICATED = -3,
        INDI_DISPATCH_ERROR      = -4
    };
 
    DeviceManager(INDIMenu *INDIparent, QString inHost, uint inPort, ManagerMode inMode);
    ~DeviceManager();
 
    INDIMenu *parent;
    QList<INDI_D *> indi_dev;
    QList<IDevice *> managed_devices;
 
    QTcpSocket serverSocket;
    LilXML *XMLParser;
    QString host;
    uint port;
    QString serverBuffer;
    ManagerMode mode;
    KProcess *serverProcess;
 
    int dispatchCommand(XMLEle *root, QString &errmsg);
 
    INDI_D *addDevice(XMLEle *dep, QString &errmsg);
    INDI_D *findDev(XMLEle *root, int create, QString &errmsg);
 
    /*****************************************************************
        * Send to server
        ******************************************************************/
    void sendNewText(INDI_P *pp);
    void sendNewNumber(INDI_P *pp);
    void sendNewSwitch(INDI_P *pp, INDI_E *lp);
    void startBlob(const QString &devName, const QString &propName, const QString &timestamp);
    void sendOneBlob(const QString &blobName, unsigned int blobSize, const QString &blobFormat,
                     unsigned char *blobBuffer);
    void finishBlob();
 
    /*****************************************************************
        * Misc.
        ******************************************************************/
    int delPropertyCmd(XMLEle *root, QString &errmsg);
    int removeDevice(const QString &devName, QString &errmsg);
    INDI_D *findDev(const QString &devName, QString &errmsg);
 
    int messageCmd(XMLEle *root, QString &errmsg);
    void checkMsg(XMLEle *root, INDI_D *dp);
    void doMsg(XMLEle *msg, INDI_D *dp);
 
    void appendManagedDevices(QList<IDevice *> &processed_devices);
    void startServer();
    void stopServer();
    void connectToServer();
    void enableBLOB(bool enable, QString device = QString(), QString property = QString());
 
    QString getServerBuffer() { return serverBuffer; }
 
  public slots:
    void dataReceived();
    void connectionSuccess();
    void connectionError();
    void processStandardError();
 
  signals:
    void newDevice(INDI_D *);
    void deviceManagerError(DeviceManager *);
    void newServerInput();
};