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

constexpr char SERVER_PASSWORD[] = "123456";

using namespace std::placeholders;

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

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

void onMessage(QVsoaRegulator *regulator, QString url, QVsoaPayload payload)
{
    regulator->update(url, payload);
}

void ondelay(const QString &url, const QVsoaPayload &payload)
{
    qDebug() << "received event:" << url << "payload:" << payload.param();
}

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

    // Initilize client
    QVsoaClient client;
    if (client.isInvalid()) {
        qDebug() << "Can not create VSOA client!";
        return -1;
    }

    // Initilize regulator
    QVsoaRegulator regulator(3000);
    // Add slot with 1024 bytes buffer.
    regulator.addSlot("/axis", ondelay, 1024);

    QObject::connect(&client, &QVsoaClient::connected, onConnected);
    QObject::connect(&client, &QVsoaClient::disconnected, onDisconnected);
    QObject::connect(&client, &QVsoaClient::message, std::bind(onMessage, &regulator, _1, _2));

    // Connect to server with password
    client.connect2server("vsoa://axis_server", SERVER_PASSWORD, 1000);
    // Enable automatic connections
    client.autoConnect(1000, 500);
    // Subscribe /axis
    client.subscribe("/axis");
    // Enable data consistency on /axis
    client.autoConsistent({"/axis"}, 1000);

    return a.exec();
}