message_processor.h

Go to the documentation of this file.

#ifndef WAVELENGTH_MESSAGE_PROCESSOR_H
#define WAVELENGTH_MESSAGE_PROCESSOR_H
 
#include <QObject>
 
class QWebSocket;
class MessageService;

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

    MessageProcessor(const MessageProcessor &) = delete;

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

    static bool AreFrequenciesEqual(const QString &frequency1, const QString &frequency2) {
        return frequency1 == frequency2;
    }

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

    void ProcessIncomingBinaryMessage(const QByteArray &message, const QString &frequency);

    void SetSocketMessageHandlers(QWebSocket *socket, QString frequency);
 
private:
    void ProcessMessageContent(const QJsonObject &message_object, const QString &frequency, const QString &message_id);

    void ProcessSystemCommand(const QJsonObject &message_object, const QString &frequency);

    void ProcessUserJoined(const QJsonObject &message_object, const QString &frequency);

    void ProcessUserLeft(const QJsonObject &message_object, const QString &frequency);

    void ProcessWavelengthClosed(const QString &frequency);
 
signals:
    void messageReceived(QString frequency, const QString &formatted_message);

    void systemMessage(QString frequency, const QString &formatted_message);

    void wavelengthClosed(QString frequency);

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

    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:
    explicit MessageProcessor(QObject *parent = nullptr);

    ~MessageProcessor() override = default;
};
 
#endif // WAVELENGTH_MESSAGE_PROCESSOR_H