session_coordinator.h

Go to the documentation of this file.

#ifndef WAVELENGTH_SESSION_COORDINATOR_H
#define WAVELENGTH_SESSION_COORDINATOR_H
 
#include <QObject>
#include <QDebug>
 
struct WavelengthInfo;

class SessionCoordinator final : public QObject {
    Q_OBJECT
 
public:
    static SessionCoordinator *GetInstance() {
        static SessionCoordinator instance;
        return &instance;
    }

    SessionCoordinator(const SessionCoordinator &) = delete;

    SessionCoordinator &operator=(const SessionCoordinator &) = delete;

    void Initialize();

    static bool CreateWavelength(const QString &frequency,
                                 bool is_password_protected, const QString &password);

    static bool JoinWavelength(const QString &frequency, const QString &password = QString());

    static void LeaveWavelength();

    static void CloseWavelength(const QString &frequency);

    static bool SendMessage(const QString &message);

    static bool SendFile(const QString &file_path);

    static WavelengthInfo GetWavelengthInfo(const QString &frequency, bool *is_host = nullptr);

    static QString GetActiveWavelength();

    static void SetActiveWavelength(const QString &frequency);

    static bool IsActiveWavelengthHost();

    static QList<QString> GetJoinedWavelengths();

    static int GetJoinedWavelengthCount();

    static bool IsWavelengthPasswordProtected(const QString &frequency);

    static bool IsWavelengthHost(const QString &frequency);

    static bool IsWavelengthJoined(const QString &frequency);

    static bool IsWavelengthConnected(const QString &frequency);

    static QString GetRelayServerAddress();

    static void SetRelayServerAddress(const QString &address);

    static QString GetRelayServerUrl();
 
signals:
    void wavelengthCreated(QString frequency);

    void wavelengthJoined(QString frequency);

    void wavelengthLeft(QString frequency);

    void wavelengthClosed(QString frequency);

    void messageReceived(QString frequency, const QString &message);

    void messageSent(QString frequency, const QString &message);

    void connectionError(const QString &error_message);

    void authenticationFailed(QString frequency);

    void userKicked(QString frequency, const QString &reason);

    void activeWavelengthChanged(QString frequency);

    void pttGranted(QString frequency);

    void pttDenied(QString frequency, QString reason);

    void pttStartReceiving(QString frequency, QString sender_id);

    void pttStopReceiving(QString frequency);

    void audioDataReceived(QString frequency, const QByteArray &audio_data);

    void remoteAudioAmplitudeUpdate(QString frequency, qreal amplitude);
 
private slots:
    void onWavelengthCreated(const QString &frequency);

    void onWavelengthJoined(const QString &frequency);

    void onWavelengthLeft(const QString &frequency);

    void onWavelengthClosed(const QString &frequency);

    void onMessageReceived(const QString &frequency, const QString &message);

    void onMessageSent(const QString &frequency, const QString &message);

    void onConnectionError(const QString &errorMessage);

    void onAuthenticationFailed(const QString &frequency);

    void onActiveWavelengthChanged(const QString &frequency);

    static void onConfigChanged(const QString &key) {
        qDebug() << "Configuration changed:" << key;
    }

    void onPttGranted(const QString &frequency) {
        emit pttGranted(frequency);
    }

    void onPttDenied(const QString &frequency, const QString &reason) {
        emit pttDenied(frequency, reason);
    }

    void onPttStartReceiving(const QString &frequency, const QString &sender_id) {
        emit pttStartReceiving(frequency, sender_id);
    }

    void onPttStopReceiving(const QString &frequency) {
        emit pttStopReceiving(frequency);
    }

    void onAudioDataReceived(const QString &frequency, const QByteArray &audio_data) {
        emit audioDataReceived(frequency, audio_data);
    }

    void onRemoteAudioAmplitudeUpdate(const QString &frequency, const qreal amplitude) {
        emit remoteAudioAmplitudeUpdate(frequency, amplitude);
    }
 
private:
    explicit SessionCoordinator(QObject *parent = nullptr) : QObject(parent) {
    }

    ~SessionCoordinator() override = default;

    void ConnectSignals();

    static void LoadConfig();
};
 
#endif // WAVELENGTH_SESSION_COORDINATOR_H