app_instance_manager.h

Go to the documentation of this file.

#ifndef APP_INSTANCE_MANAGER_H
#define APP_INSTANCE_MANAGER_H
 
#include <QObject>
#include <QPointF>
#include <QSizeF>
#include <QString>
#include <QLocalSocket>
#include <QLocalServer>
#include <QMutex>
#include <QPropertyAnimation>
#include <QTimer>
#include <thread>
 
class BlobAnimation;
class QMainWindow;

struct InstanceInfo {
    QString instance_id; 
    QPointF blob_center; 
    QPoint window_position; 
    QSize window_size; 
    bool is_creator; 
};

class AppInstanceManager final : public QObject {
    Q_OBJECT
 
public:
    explicit AppInstanceManager(QMainWindow *window, BlobAnimation *blob, QObject *parent = nullptr);

    ~AppInstanceManager() override;

    bool Start();

    [[nodiscard]] QString GetInstanceId() const { return instance_id_; }

    [[nodiscard]] bool IsCreator() const { return is_creator_; }

    static bool IsAnotherInstanceRunning();
 
signals:
    void instanceConnected(QString instance_id);

    void instanceDisconnected(QString instance_id);

    void otherInstancePositionHasChanged(QString instance_id, const QPointF &blob_center,
                                         const QPoint &window_position);
 
private slots:
    void onNewConnection();

    void clientDisconnected();

    void readData();

    void sendPositionUpdate();
 
private:
    enum MessageType : quint8 {
        kPositionUpdate = 1, 
        kIdentify = 5, 
        kIdentifyResponse = 6, 
    };

    void SetupServer();

    void ConnectToServer();

    bool ProcessMessage(const QByteArray &message, QLocalSocket *sender = nullptr);

    void SendToAllClients(const QByteArray &message);

    [[nodiscard]] QByteArray CreatePositionMessage() const;

    void InitAttractionThread();

    void ApplyAttractionForce(const QPointF &target_position);

    void StartAbsorptionAnimation();

    void FinalizeAbsorption();
 
    QMainWindow *main_window_; 
    BlobAnimation *blob_; 
    QLocalServer *server_ = nullptr; 
    QLocalSocket *socket_ = nullptr; 
    QTimer position_timer_; 
    QTimer absorption_check_timer_; 
    QMutex instances_mutex_; 
 
    std::atomic<bool> is_creator_{false}; 
    QString instance_id_; 
 
    QVector<InstanceInfo> connected_instances_;
    QHash<QLocalSocket *, QString> client_ids_;
    std::unique_ptr<std::thread> attraction_thread_; 
    std::atomic<bool> is_thread_running{false}; 
 
    static constexpr int kUpdateIntervalMs = 50; 
    static const QString kServerName; 
 
    static constexpr double kAttractionForce = 0.5;
    static constexpr double kAbsorptionDistance = 50.0; 
 
    std::atomic<bool> is_being_absorbed_ = false;
};
 
#endif // APP_INSTANCE_MANAGER_H