#include "MQTTClientWrapper.h"
#include "OtarcikCan.h"

CMQTTClientWrapper::CMQTTClientWrapper()
{
    connect(&mMQTTClient,&QMqttClient::stateChanged,this,&CMQTTClientWrapper::StateChanged);
    mMQTTRefreshTimer = new QTimer;
    mMQTTRefreshTimer->setSingleShot(true);
    mProgramPtr = 0;
}

CMQTTClientWrapper::~CMQTTClientWrapper()
{
    delete mMQTTRefreshTimer;
}

int CMQTTClientWrapper::SetMQTTParams(CCloudParams *Params)
{
    mMQTTParams = *Params;
    mMQTTClientID = "Otarcik_Station_Ville_Emard";

    return RET_OK;
}

int CMQTTClientWrapper::ConnectToBroker()
{
    //Setup the client before connecting.
    mMQTTClient.setAutoKeepAlive(true);
    mMQTTClient.setClientId(mMQTTClientID);
    mMQTTClient.setHostname(mMQTTParams.mMQTTBrokerHostName);
    mMQTTClient.setPort(mMQTTParams.mMQTTBrokerPort);
    mMQTTClient.setPassword(mMQTTParams.mMQTTBrokerPassword);
    mMQTTClient.setUsername(mMQTTParams.mMQTTBrokerUserName);

    mMQTTClient.connectToHost();

    return RET_OK;
}

int CMQTTClientWrapper::DisconnectFromBroker()
{
    mMQTTClient.disconnectFromHost();
    return RET_OK;
}

int CMQTTClientWrapper::NewMQTTMessages(QList<CMQTTMessage> MessagesList)
{
    if(mMQTTClient.state() != QMqttClient::Connected)
    {
        return RET_GENERAL_ERROR;
    }
    if(mMQTTRefreshTimer->remainingTime() > 0)
    {
   //     qDebug("MQTT timer value: %d",mMQTTRefreshTimer->remainingTime());
        return RET_OK;
    }
    if(MessagesList.isEmpty())
    {
        return RET_GENERAL_ERROR;
    }


    for(int i = 0; i < MessagesList.size(); i++)
    {
        qint32 res = mMQTTClient.publish(MessagesList.at(i).mMessageTopic,MessagesList.at(i).mMessagePayload.toLocal8Bit(),0,true);
        qDebug("%s : %s",qPrintable(MessagesList.at(i).mMessageTopic), qPrintable(MessagesList.at(i).mMessagePayload));

    }
    mMQTTRefreshTimer->start(mMQTTParams.mMQTTTransmitTimeout);
    qDebug("Sent %d MQTT messages",MessagesList.size());


    return RET_OK;
}

void CMQTTClientWrapper::StateChanged()
{
    switch(mMQTTClient.state())
    {
        case QMqttClient::Disconnected:
        {
            qDebug("MQTT client Disconnected");
            mProgramPtr->SetMQTTConnectionSatusRequest(false);
            break;
        }
        case QMqttClient::Connected:
        {
            mProgramPtr->SetMQTTConnectionSatusRequest(true);
            qDebug("MQTT client Connected");
            break;
        }
        case QMqttClient::Connecting:
        {
            qDebug("MQTT client Connecting...");
            break;
        }
    }
}

int CMQTTClientWrapper::SendMQTTTestMessage()
{
    mMQTTClient.publish(QString("Otarcik/Test"),QString("Test Payload").toLocal8Bit(),0,true);
    qDebug("Sending MQTT test message");
}