serversenteventsstream.h

/*
    SPDX-FileCopyrightText: 2022 Volker Krause <vkrause@kde.org>
    SPDX-License-Identifier: LGPL-2.0-or-later
*/
 
#ifndef KUNIFIEDPUSH_SERVERSENTEVENTSSTREAM_H
#define KUNIFIEDPUSH_SERVERSENTEVENTSSTREAM_H
 
#include <QHash>
#include <QObject>
 
class QIODevice;
 
namespace KUnifiedPush {
 
class SSEMessage
{
public:
    QByteArray event;
    QByteArray data;
    QHash<QByteArray, QByteArray> metaData;
};
 
/** Sever-sent Events (SSE) stream
 *  @see https://en.wikipedia.org/wiki/Server-sent_events
 */
class ServerSentEventsStream : public QObject
{
    Q_OBJECT
public:
    explicit ServerSentEventsStream(QObject *parent = nullptr);
    ~ServerSentEventsStream();
 
    void read(QIODevice *device);
    [[nodiscard]] QByteArray buffer() const;
 
Q_SIGNALS:
    void messageReceived(const KUnifiedPush::SSEMessage &msg);
 
private:
    void processBuffer();
 
    QByteArray m_buffer;
};
 
}
 
Q_DECLARE_METATYPE(KUnifiedPush::SSEMessage)
 
#endif // KUNIFIEDPUSH_SERVERSENTEVENTSSTREAM_H