#include <QCoreApplication>
#include <QDebug>
#include <QVsoa>

using namespace std::placeholders;

class StreamClient : public QObject
{
    Q_OBJECT
public:
    StreamClient()
    {
        QObject::connect(&m_client, &QVsoaClient::connected, this, &StreamClient::onConnected);
        QObject::connect(&m_client, &QVsoaClient::disconnected, this, &StreamClient::onDisconnected);
    }

    void onConnected(bool ok, QString info)
    {
        if (!ok) {
            qDebug() << "Connected with server failed!";
            return;
        }
        qDebug() << "Connected with server:" << info;
        readCall();
    }

    void onDisconnected() { qDebug() << "Connection break"; }

    void readCall()
    {
        auto invoker = new QVsoaClientRPCInvoker(&m_client, "/read", RPCMethod::GET);
        QObject::connect(invoker, &QVsoaClientRPCInvoker::serverReply, this, &StreamClient::onReadReplay);
        invoker->call(QVsoaPayload{});
    }

    void onReadReplay(const QVsoaHeader header)
    {
        auto stream = QVsoaStream::createStream(&m_client, header.tunid(), 1000, 5000);
        connect(stream, &QVsoaStream::connectionStatusChange, this, &StreamClient::onStreamConStatusChanged);
        connect(stream, &QVsoaStream::readyRead, this, &StreamClient::onStreamReadyRead);
        sender()->deleteLater();
    }

    void onStreamConStatusChanged(bool ok)
    {
        auto stream = qobject_cast<QVsoaStream*>(sender());
        if (!ok) {
            qDebug() << "Unable to connect to the server stream.";
            stream->deleteLater();
            return;
        }
        qDebug() << "Connected to VSOA stream server.";
    }

    void onStreamReadyRead()
    {
        auto stream = qobject_cast<QVsoaStream*>(sender());
        auto data = stream->readAll();
        qDebug() << "Received" << data.length() << "bytes from VSOA stream:" << data.toHex(':');
        stream->deleteLater();
    }

    void start()
    {
        if (m_client.isInvalid()) {
            qDebug() << "Can not create VSOA client!";
            return;
        }
        m_client.connect2server("vsoa://vsoa_stream_server", {});
    }

private:
    QVsoaClient m_client;
};

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    StreamClient client;
    client.start();

    return a.exec();
}