File indexing completed on 2024-04-21 14:45:02

 /*
     SPDX-FileCopyrightText: 2018 Jasem Mutlaq <mutlaqja@ikarustech.com>
 
     Media Channel
 
     SPDX-License-Identifier: GPL-2.0-or-later
 */
 
 #pragma once
 
 #include <QtWebSockets/QWebSocket>
 #include <memory>
 
 #include "ekos/manager.h"
 #include "nodemanager.h"
 
 class FITSView;
 
 namespace EkosLive
 {
 class Media : public QObject
 {
         Q_OBJECT
 
     public:
         explicit Media(Ekos::Manager * manager, QVector<QSharedPointer<NodeManager>> &nodeManagers);
         virtual ~Media() = default;
 
         bool isConnected() const;
         void sendResponse(const QString &command, const QJsonObject &payload);
         void sendResponse(const QString &command, const QJsonArray &payload);
 
         void registerCameras();
 
         // Ekos Media Message to User
         void sendFile(const QString &filename, const QString &uuid);
         void sendData(const QSharedPointer<FITSData> &data, const QString &uuid);        
         void sendView(const QSharedPointer<FITSView> &view, const QString &uuid);
         void sendUpdatedFrame(const QSharedPointer<FITSView> &view);
         void sendModuleFrame(const QSharedPointer<FITSView> &view);
 
         // Convenience functions
         void sendDarkLibraryData(const QSharedPointer<FITSData> &data);
 
     signals:
         void connected();
         void disconnected();
 
         void newBoundingRect(QRect rect, QSize view, double currentZoom);
         void newMetadata(const QByteArray &metadata);
         void newImage(const QByteArray &image);
 
     public slots:
         // Capture
         void sendVideoFrame(const QSharedPointer<QImage> &frame);
 
         // Correction Vector
         void setCorrectionVector(QLineF correctionVector)
         {
             this->correctionVector = correctionVector;
         }
 
         // Polar View
         void resetPolarView();
 
         void processNewBLOB(IBLOB *bp);
 
     private slots:
         // Connection
         void onConnected();
         void onDisconnected();        
 
         // Communication
         void onTextReceived(const QString &message);
         void onBinaryReceived(const QByteArray &message);
 
         // Metadata and Image upload
         void uploadMetadata(const QByteArray &metadata);
         void uploadImage(const QByteArray &image);
 
     private:
         void upload(const QSharedPointer<FITSView> &view);
 
         Ekos::Manager * m_Manager { nullptr };
         QVector<QSharedPointer<NodeManager>> m_NodeManagers;
         QString m_UUID;
         QString extension;
         QStringList temporaryFiles;
         QLineF correctionVector;
         QSharedPointer<FITSView> m_TemporaryView;
 
         bool m_sendBlobs { true};
 
         // Image width for high-bandwidth setting
         static const uint16_t HB_IMAGE_WIDTH = 1920;
         // Video width for high-bandwidth setting
         static const uint16_t HB_VIDEO_WIDTH = 1280;
         // Image high bandwidth image quality (jpg)
         static const uint8_t HB_IMAGE_QUALITY = 90;
         // Video high bandwidth video quality (jpg)
         static const uint8_t HB_VIDEO_QUALITY = 64;
         // Image high bandwidth image quality (jpg) for PAH
         static const uint8_t HB_PAH_IMAGE_QUALITY = 50;
         // Video high bandwidth video quality (jpg) for PAH
         static const uint8_t HB_PAH_VIDEO_QUALITY = 24;
 
         // Retry every 5 seconds in case remote server is down
         static const uint16_t RECONNECT_INTERVAL = 5000;
         // Retry for 1 hour before giving up
         static const uint16_t RECONNECT_MAX_TRIES = 720;
 
         // Binary Metadata Size
         static const uint16_t METADATA_PACKET = 512;
 
         // HIPS Tile Width and Height
         static const uint16_t HIPS_TILE_WIDTH = 512;
         static const uint16_t HIPS_TILE_HEIGHT = 512;
 };
 }