File indexing completed on 2024-04-21 14:46:12

 /*
     SPDX-FileCopyrightText: 2012 Jasem Mutlaq <mutlaqja@ikarustech.com>
 
     SPDX-License-Identifier: GPL-2.0-or-later
 */
 
 #pragma once
 
 #include "indicommon.h"
 
 #include <QFile>
 #include <QObject>
 #include <QProcess>
 #include <QTcpSocket>
 #include <QTemporaryFile>
 #include <QFuture>
 
 #include <memory>
 
 class DriverInfo;
 
 /**
  * @class ServerManager
  * ServerManager is responsible for starting and shutting local INDI servers.
  *
  * @author Jasem Mutlaq
  */
 class ServerManager : public QObject
 {
         Q_OBJECT
 
     public:
         ServerManager(const QString &inHost, int inPort);
         ~ServerManager() override;
 
         bool start();
         void stop();
 
         QString getLogBuffer();
         const QString &getHost() const
         {
             return host;
         }
         int getPort() const
         {
             return port;
         }
 
         void setPendingDrivers(QList<QSharedPointer<DriverInfo>> drivers)
         {
             m_PendingDrivers = drivers;
         }
         const QList<QSharedPointer<DriverInfo>> &pendingDrivers() const
         {
             return m_PendingDrivers;
         }
 
         void startDriver(const QSharedPointer<DriverInfo> &driver);
         void stopDriver(const QSharedPointer<DriverInfo> &driver);
         bool restartDriver(const QSharedPointer<DriverInfo> &driver);
 
         const QList<QSharedPointer<DriverInfo>> &managedDrivers() const
         {
             return m_ManagedDrivers;
         }
         bool contains(const QSharedPointer<DriverInfo> &driver)
         {
             return m_ManagedDrivers.contains(driver);
         }
 
         void setMode(ServerMode inMode)
         {
             mode = inMode;
         }
         ServerMode getMode()
         {
             return mode;
         }
 
         QString errorString();
 
         int size()
         {
             return m_ManagedDrivers.size();
         }
 
     public slots:
         void processServerError(QProcess::ProcessError);
         void processStandardError();
 
     private:
         QTcpSocket serverSocket;
         QString host;
         int port;
         QTemporaryFile serverBuffer;
         std::unique_ptr<QProcess> serverProcess;
 
         void insertEnvironmentPath(QProcessEnvironment *env, const QString &variable, const QString &relativePath);
 
         ServerMode mode { SERVER_CLIENT };
 
         QList<QSharedPointer<DriverInfo>> m_ManagedDrivers;
 
         QList<QSharedPointer<DriverInfo>> m_PendingDrivers;
 
         QFile indiFIFO;
 
     signals:
         void started();
         void stopped();
         void failed(const QString &message);
         void terminated(const QString &message);
 
 
         void newServerLog();
 
         // Driver Signals
         void driverStarted(const QSharedPointer<DriverInfo> &driver);
         void driverStopped(const QSharedPointer<DriverInfo> &driver);
         void driverRestarted(const QSharedPointer<DriverInfo> &driver);
         void driverFailed(const QSharedPointer<DriverInfo> &driver, const QString &message);
 };