File indexing completed on 2025-04-20 09:31:06

 /*
     SPDX-FileCopyrightText: 2012 Jasem Mutlaq <mutlaqja@ikarustech.com>
 
     SPDX-License-Identifier: GPL-2.0-or-later
 */
 
 #pragma once
 
 #ifdef USE_QT5_INDI
 #include <baseclientqt.h>
 #else
 #include <baseclient.h>
 #endif
 
 #include "ui_manager.h"
 
 #include "ekos.h"
 #include "fitsviewer/summaryfitsview.h"
 #include "indi/indistd.h"
 #include "auxiliary/portselector.h"
 #include "ksnotification.h"
 #include "auxiliary/opslogs.h"
 #include "ekos/capture/rotatorsettings.h"
 
 #include <QDialog>
 #include <QHash>
 
 #include <memory>
 
 //! Generic record interfaces and implementations.
 namespace EkosLive
 {
 class Client;
 class Message;
 class Media;
 }
 
 class DriverInfo;
 class ProfileInfo;
 class KPageWidgetItem;
 class OpsEkos;
 
 /**
  * @class Manager
  * @short Primary class to handle all Ekos modules.
  * The Ekos Manager class manages startup and shutdown of INDI devices and registeration of devices within Ekos Modules. Ekos module consist of \ref Ekos::Mount, \ref Ekos::Capture, \ref Ekos::Focus, \ref Ekos::Guide, and \ref Ekos::Align modules.
  * \defgroup EkosDBusInterface "Ekos DBus Interface" provides high level functions to control devices and Ekos modules for a total robotic operation:
  * <ul>
  * <li>\ref CaptureDBusInterface "Capture Module DBus Interface"</li>
  * <li>\ref FocusDBusInterface "Focus Module DBus Interface"</li>
  * <li>\ref MountDBusInterface "Mount Module DBus Interface"</li>
  * <li>\ref GuideDBusInterface "Guide Module DBus Interface"</li>
  * <li>\ref AlignDBusInterface "Align Module DBus Interface"</li>
  * <li>\ref WeatherDBusInterface "Weather DBus Interface"</li>
  * <li>\ref DustCapDBusInterface "Dust Cap DBus Interface"</li>
  * </ul>
  *  For low level access to INDI devices, the \ref INDIDBusInterface "INDI Dbus Interface" provides complete access to INDI devices and properties.
  *  Ekos Manager provides a summary of operations progress in the <i>Summary</i> section of the <i>Setup</i> tab.
  *
  * @author Jasem Mutlaq
  * @version 1.8
  */
 namespace Ekos
 {
 
 class Analyze;
 class Capture;
 class Scheduler;
 class Focus;
 class Align;
 class Guide;
 class Mount;
 class Observatory;
 // class RotatorSettings;
 
 class Manager : public QDialog, public Ui::Manager
 {
         Q_OBJECT
         Q_CLASSINFO("D-Bus Interface", "org.kde.kstars.Ekos")
 
         Q_SCRIPTABLE Q_PROPERTY(Ekos::CommunicationStatus indiStatus READ indiStatus NOTIFY indiStatusChanged)
         Q_SCRIPTABLE Q_PROPERTY(Ekos::CommunicationStatus ekosStatus READ ekosStatus NOTIFY ekosStatusChanged)
         Q_SCRIPTABLE Q_PROPERTY(Ekos::CommunicationStatus settleStatus READ settleStatus NOTIFY settleStatusChanged)
         Q_SCRIPTABLE Q_PROPERTY(bool ekosLiveStatus READ ekosLiveStatus NOTIFY ekosLiveStatusChanged)
         Q_SCRIPTABLE Q_PROPERTY(QStringList logText READ logText NOTIFY newLog)
 
         enum class EkosModule
         {
             Setup,
             Scheduler,
             Analyze,
             Capture,
             Focus,
             Mount,
             Align,
             Guide,
             Observatory,
         };
     public:
         static Manager *Instance();
         static void release();
 
         // No OP
         void initialize() {}
 
         void appendLogText(const QString &);
         void setOptionsWidget(KPageWidgetItem *ops, OpsEkos *opsEkosPtr)
         {
             ekosOptionsWidget = ops;
             opsEkos = opsEkosPtr;
         }
         void addObjectToScheduler(SkyObject *object);
 
         Scheduler *schedulerModule()
         {
             return schedulerProcess.get();
         }
         Guide *guideModule()
         {
             return guideProcess.get();
         }
         Align *alignModule()
         {
             return alignProcess.get();
         }
         Mount *mountModule()
         {
             return mountProcess.get();
         }
         Focus *focusModule()
         {
             return focusProcess.get();
         }
         Capture *captureModule()
         {
             return captureProcess.get();
         }
         FITSView *getSummaryPreview()
         {
             return m_SummaryView.get();
         }
 
         // Filter Manager
         void createFilterManager(ISD::FilterWheel *device);
         bool getFilterManager(const QString &name, QSharedPointer<FilterManager> &fm);
         bool getFilterManager(QSharedPointer<FilterManager> &fm);
 
         // Rotator Control
         void createRotatorController(ISD::Rotator *device);
         bool getRotatorController(const QString &Name, QSharedPointer<RotatorSettings> &rs);
         bool existRotatorController();
 
         QString getCurrentJobName();
         void announceEvent(const QString &message, KSNotification::EventSource source, KSNotification::EventType event);
 
         /**
          * @brief activateModule Switch tab to specific module name (i.e. CCD) and raise Ekos screen to focus.
          * @param name module name CCD, Guide, Focus, Mount, Scheduler, or Observatory.
          * @param popup if True, show Ekos Manager window in the foreground.
          */
         void activateModule(const QString &name, bool popup = false);
 
         /**
          * @brief addProfile Add a new profile to the database.
          * @param profileInfo Collection of profile parameters to include the following:
          * 1. name: Profile name
          * 2. auto_connect: True of False for Autoconnect?
          * 3. Mode: "local" or "remote"
          * 4. remote_host: Optional. remote host (default localhost)
          * 5. remote_port: Optional. remote port (default 7624)
          * 6. guiding: 0 for "Internal", 1 for "PHD2", or 2 for "LinGuider"
          * 7. remote_guiding_host: Optional. remote host for guider application (default localhost)
          * 8. remote_guide_port: Optional. remote port for guider application.
          * 9. use_web_manager: True or False?
          * 10. web_manager_port. Optional. INDI Web Manager port (default 8624)
          * 12. primary_scope: ID of primary scope to use. This is the ID from OAL::Scope list in the database.
          * 13. guide_scope: ID of guide scope to use. This is the ID from OAL::Scope list in the database.
          * 14. mount: Mount driver label (default --).
          * 15. ccd: CCD driver label (default --).
          * 16. guider: Guider driver label (default --).
          * 17. focuser: Focuser driver label (default --).
          * 18. filter: Filter Wheel driver label (default --).
          * 19. ao: Adaptive Optics driver label (default --).
          * 20. dome: Dome driver label (default --).
          * 21. Weather: Weather station driver label (default --).
          * 22. aux1: aux1 driver label (default --).
          * 23. aux2: aux2 driver label (default --).
          * 24. aux3: aux3 driver label (default --).
          * 25. aux4: aux4 driver label (default --).
          */
         void addNamedProfile(const QJsonObject &profileInfo);
 
         /** Same as above, except it edits an existing named profile */
         void editNamedProfile(const QJsonObject &profileInfo);
 
         /**
          * @brief deleteProfile Delete existing equipment profile
          * @param name Name of profile
          * @warning Ekos must be stopped for this to work. It will fail if Ekos is online.
          */
         void deleteNamedProfile(const QString &name);
 
         /**
          * @brief getProfile Get a single profile information.
          * @param name Profile name
          * @return A JSon object with the detail profile info as described in addProfile function.
          */
         QJsonObject getNamedProfile(const QString &name);
 
         /**
          * DBus commands to manage equipment profiles.
          */
 
         /*@{*/
 
         /**
          * DBUS interface function.
          * set Current device profile.
          * @param profileName Profile name
          * @return True if profile is set, false if not found.
          */
         Q_SCRIPTABLE bool setProfile(const QString &profileName);
 
         /**
          * DBUS interface function
          * @brief getProfiles Return a list of all device profiles
          * @return List of device profiles
          */
         Q_SCRIPTABLE QStringList getProfiles();
 
         /** @}*/
 
 
         /**
          * Manager interface provides advanced scripting capabilities to establish and shutdown Ekos services.
          */
 
         /*@{*/
 
         /**
          * DBUS interface function.
          * @return INDI connection status (0 Idle, 1 Pending, 2 Connected, 3 Error)
          * @deprecated
          */
         Q_SCRIPTABLE unsigned int getINDIConnectionStatus()
         {
             return m_indiStatus;
         }
 
         Q_SCRIPTABLE Ekos::CommunicationStatus indiStatus()
         {
             return m_indiStatus;
         }
 
         /**
          * DBUS interface function.
          * @return Ekos starting status (0 Idle, 1 Pending, 2 Started, 3 Error)
          * @deprecated
          */
         Q_SCRIPTABLE unsigned int getEkosStartingStatus()
         {
             return m_ekosStatus;
         }
 
         Q_SCRIPTABLE Ekos::CommunicationStatus ekosStatus()
         {
             return m_ekosStatus;
         }
 
         /**
          * DBUS interface function.
          * @return Settle status (0 Idle, 1 Pending, 2 Started, 3 Error)
          */
         Q_SCRIPTABLE Ekos::CommunicationStatus settleStatus()
         {
             return m_settleStatus;
         }
 
         /**
          * DBUS interface function. Toggle Ekos logging.
          * @param name Name of logging to toggle. Available options are:
          * ** VERBOSE
          * ** INDI
          * ** FITS
          * ** CAPTURE
          * ** FOCUS
          * ** GUIDE
          * ** ALIGNMENT
          * ** MOUNT
          * ** SCHEDULER
          * ** OBSERVATORY
          * @param enabled True to enable, false otherwise.
          */
         Q_SCRIPTABLE Q_NOREPLY void setEkosLoggingEnabled(const QString &name, bool enabled);
 
         /**
          * DBUS interface function.
          * If connection mode is local, the function first establishes an INDI server with all the specified drivers in Ekos options or as set by the user. For remote connection,
          * it establishes connection to the remote INDI server.
          * @return Returns true if server started successful (local mode) or connection to remote server is successful (remote mode).
          */
         Q_SCRIPTABLE void start();
 
         /**
          * DBUS interface function.
          * If connection mode is local, the function terminates the local INDI server and drivers. For remote, it disconnects from the remote INDI server.
          */
         Q_SCRIPTABLE void stop();
 
         Q_SCRIPTABLE QStringList logText()
         {
             return m_LogText;
         }
 
         Q_SCRIPTABLE bool ekosLiveStatus();
 
         /**
          * DBUS interface function.
          * @param enabled Connect to EkosLive if true, otherwise disconnect.
         */
         Q_SCRIPTABLE void setEkosLiveConnected(bool enabled);
 
         /**
          * @brief setEkosLiveConfig Set EkosLive settings
          * @param rememberCredentials Remember username and password for next session.
          * @param autoConnect If true, it will automatically connect to EkosLive service.
          */
         Q_SCRIPTABLE void setEkosLiveConfig(bool rememberCredentials, bool autoConnect);
 
         /**
          * @brief setEkosLiveUser Save EkosLive username and password
          * @param username User name
          * @param password Password
          */
         Q_SCRIPTABLE void setEkosLiveUser(const QString &username, const QString &password);
 
         /**
          * @brief acceptPortSelection Accept current port selection settings in the Selector Dialog
          */
         Q_SCRIPTABLE void acceptPortSelection();
 
     signals:
         // Have to use full Ekos::CommunicationStatus for DBus signal to work
         void ekosStatusChanged(Ekos::CommunicationStatus status);
         void indiStatusChanged(Ekos::CommunicationStatus status);
         void settleStatusChanged(Ekos::CommunicationStatus status);
         void ekosLiveStatusChanged(bool status);
 
         void newLog(const QString &text);
         void newModule(const QString &name);
         void newDevice(const QString &name, int interface);
 
     protected:
         void closeEvent(QCloseEvent *event) override;
         void hideEvent(QHideEvent *) override;
         void showEvent(QShowEvent *) override;
         void resizeEvent(QResizeEvent *) override;
 
     public slots:
 
         /**
          * DBUS interface function.
          * Connects all the INDI devices started by Ekos.
          */
         Q_SCRIPTABLE Q_NOREPLY void connectDevices();
 
         /**
          * DBUS interface function.
          * Disconnects all the INDI devices started by Ekos.
          */
         Q_SCRIPTABLE Q_NOREPLY void disconnectDevices();
 
         /** @}*/
 
         void processINDI();
         void cleanDevices(bool stopDrivers = true);
 
         void processNewDevice(const QSharedPointer<ISD::GenericDevice> &device);
 
         void processNewProperty(INDI::Property);
         void processUpdateProperty(INDI::Property);
         void processDeleteProperty(INDI::Property);
         void processMessage(int id);
 
 
         void setDeviceReady();
 
         void restartDriver(const QString &deviceName);
 
     private slots:
 
         void changeAlwaysOnTop(Qt::ApplicationState state);
 
         void showEkosOptions();
 
         void updateLog();
         void clearLog();
 
         void processTabChange();
 
         void setServerStarted(const QString &host, int port);
         void setServerFailed(const QString &host, int port, const QString &message);
         //void setServerTerminated(const QString &host, int port, const QString &message);
 
         void setClientStarted(const QString &host, int port);
         void setClientFailed(const QString &host, int port, const QString &message);
         void setClientTerminated(const QString &host, int port, const QString &message);
 
         void removeDevice(const QSharedPointer<ISD::GenericDevice> &device);
 
         void deviceConnected();
         void deviceDisconnected();
 
         //void processINDIModeChange();
         void checkINDITimeout();
 
         // Logs
         void updateDebugInterfaces();
         void watchDebugProperty(INDI::Property prop);
 
         void addMount(ISD::Mount *device);
         void addCamera(ISD::Camera *device);
         void addFilterWheel(ISD::FilterWheel *device);
         void addFocuser(ISD::Focuser *device);
         void addRotator(ISD::Rotator *device);
         void addDome(ISD::Dome *device);
         void addWeather(ISD::Weather *device);
         void addDustCap(ISD::DustCap *device);
         void addLightBox(ISD::LightBox *device);
         void addGuider(ISD::Guider *device);
         void addGPS(ISD::GPS *device);
 
         /**
          * @brief syncGenericDevice Check if this device needs to be added to any Ekos module.
          * @param device pointer to generic device.
          */
         void syncGenericDevice(const QSharedPointer<ISD::GenericDevice> &device);
         void createModules(const QSharedPointer<ISD::GenericDevice> &device);
 
         // Profiles
         void addProfile();
         void editProfile();
         void deleteProfile();
         void wizardProfile();
 
         // Mount Summary
         void updateMountCoords(const SkyPoint position, ISD::Mount::PierSide pierSide, const dms &ha);
         void updateMountStatus(ISD::Mount::Status status);
         void setTarget(const QString &name);
 
         // Capture Summary
         void updateCaptureStatus(CaptureState status);
         void updateCaptureProgress(SequenceJob *job, const QSharedPointer<FITSData> &data);
         void updateExposureProgress(SequenceJob *job);
         void updateCaptureCountDown();
 
         // Focus summary
         void updateFocusStatus(FocusState status);
         void updateCurrentHFR(double newHFR, int position, bool inAutofocus);
 
         // Guide Summary
         void updateGuideStatus(GuideState status);
         void updateSigmas(double ra, double de);
 
     private:
         explicit Manager(QWidget *parent);
         ~Manager() override;
 
         void removeTabs();
         void reset();
         void initCapture();
         void initFocus();
         void initGuide();
         void initAlign();
         void initMount();
         void initObservatory();
 
         void loadDrivers();
         void loadProfiles();
         int addModuleTab(EkosModule module, QWidget *tab, const QIcon &icon);
 
         /**
          * @brief syncActiveDevices Syncs ACTIVE_DEVICES such as ACTIVE_TELESCOPE and ACTIVE_CCD
          * to the currently detected devices.
          */
         void syncActiveDevices();
 
         /**
          * @brief isINDIReady Check whether all INDI devices are connected and ready and emit signals accordingly.
          * @return True if all INDI devices are connected and ready.
          */
         bool isINDIReady();
 
         // Connect Signals/Slots of Ekos modules
         void connectModules();
 
         // Check if INDI server is already running
         bool isRunning(const QString &process);
 
         bool getCurrentProfile(QSharedPointer<ProfileInfo> &profile) const;
         void updateProfileLocation(const QSharedPointer<ProfileInfo> &profile);
         void setProfileMapping(const QJsonObject &payload)
         {
             m_ProfileMapping = payload;
         }
         // Port Selector Save profile when connect all is pressed
         void setPortSelectionComplete();
         // Check if the driver binary must be one only to avoid duplicate instances
         // Some driver binaries support multiple devices per binary
         // so we only need to start a single instance to handle them all.
         bool checkUniqueBinaryDriver(const QSharedPointer<DriverInfo> &primaryDriver,
                                      const QSharedPointer<DriverInfo> &secondaryDriver);
 
         // Containers
 
         // All Drivers
         QHash<QString, QSharedPointer<DriverInfo>> driversList;
 
         // All managed drivers
         QList<QSharedPointer<DriverInfo>> managedDrivers;
 
         // Smart pointers for the various Ekos Modules
         std::unique_ptr<Capture> captureProcess;
         std::unique_ptr<Focus> focusProcess;
         std::unique_ptr<Guide> guideProcess;
         std::unique_ptr<Align> alignProcess;
         std::unique_ptr<Mount> mountProcess;
         std::unique_ptr<Analyze> analyzeProcess;
         std::unique_ptr<Scheduler> schedulerProcess;
         std::unique_ptr<Observatory> observatoryProcess;
         std::unique_ptr<EkosLive::Client> ekosLiveClient;
 
         bool m_LocalMode { true };
         bool m_isStarted { false };
         bool m_RemoteManagerStart { false };
 
         int m_DriverDevicesCount { 0 };
 
         QStringList m_LogText;
         KPageWidgetItem *ekosOptionsWidget { nullptr };
         OpsEkos *opsEkos { nullptr };
 
         CommunicationStatus m_ekosStatus { Ekos::Idle };
         CommunicationStatus m_indiStatus { Ekos::Idle };
         // Settle is used to know once all properties from all devices have been defined
         // There is no way to know this for sure so we use a debounace mechanism.
         CommunicationStatus m_settleStatus { Ekos::Idle };
 
         std::unique_ptr<QStandardItemModel> profileModel;
         QList<QSharedPointer<ProfileInfo>> profiles;
         QJsonObject m_ProfileMapping;
 
         // Mount Summary
         QPointer<QProcess> indiHubAgent;
         KLed *mountMotionState { nullptr };
 
 
         // Capture Summary
         QTimer m_CountdownTimer;
         QTimer settleTimer;
         // Preview Frame
         QSharedPointer<SummaryFITSView> m_SummaryView;
 
         QSharedPointer<ProfileInfo> m_CurrentProfile;
         bool profileWizardLaunched { false };
         QString m_PrimaryCamera, m_GuideCamera;
 
         // Port Selector
         std::unique_ptr<Selector::Dialog> m_PortSelector;
         QTimer m_PortSelectorTimer;
 
         QMap<QString, QSharedPointer<FilterManager>> m_FilterManagers;
         QMap<QString, QSharedPointer<RotatorSettings>> m_RotatorControllers;
 
         // Logs
         QPointer<OpsLogs> opsLogs;
 
         // E.g. Setup, Scheduler, and Analyze.
         int numPermanentTabs { 0 };
 
         friend class EkosLive::Client;
         friend class EkosLive::Message;
         friend class EkosLive::Media;
 
         static Manager *_Manager;
 };
 
 }