#include "VoipMsSMSClient.h"
#include <QTextStream>
#include <QDebug>
#include <QJsonDocument>
#include <QJsonObject>
#include <QDateTime>
#include <QStringList>

CVoipMsSMSClient::CVoipMsSMSClient()
{
    mVOIPMSSocket = new QNetworkAccessManager();
    connect(mVOIPMSSocket,SIGNAL(finished(QNetworkReply*)),this,SLOT(VoipServerReplyFinished(QNetworkReply*)));

    mVOIPMsNotificationServer = new QTcpServer;
    connect(mVOIPMsNotificationServer,SIGNAL(newConnection()),this,SLOT(VoipNotificationServerConnected()));
    mVOIPMsNotificationServer->listen(QHostAddress::Any,80);

}

CVoipMsSMSClient::~CVoipMsSMSClient()
{
    delete mVOIPMSSocket;
    mSMSMessagesList.clear();
    mVOIPMsNotificationServer->close();
    delete mVOIPMsNotificationServer;
}

unsigned int CVoipMsSMSClient::SetVOIPMsSettings(CVoipMSSMSSettings *SettingsData)
{
    mVOIPMsSettings = SettingsData;

    return RET_OK;
}

int CVoipMsSMSClient::DownloadSMSFromServer()
{

    mCurStartDate = QDate::currentDate().addDays(-VOIP_MS_SMS_DATESPAN);
    SendSMSDownloadRequest(mCurStartDate,QDate::currentDate());
    mSMSMessagesList.clear();

    return RET_OK;
}

int CVoipMsSMSClient::SendSMSDownloadRequest(QDate StartDate, QDate EndDate)
{
    QString Url;
    Url.clear();
    QTextStream UrlStream(&Url);

    qDebug() << "Sending request for dates from: " << StartDate.toString("yyyy-MM-dd") << " to: " << EndDate.toString("yyyy-MM-dd");

    //   Url = "https://www.voip.ms/api/v1/rest.php?api_username=jean-francois.martel@polymtl.ca&api_password=Pentium2&method=getSMS&from=2015-11-01&to=2015-11-11&did=5143606463&limit=50";

    UrlStream << VOIP_MS_API_URL
              << "api_username=" << mVOIPMsSettings.mUsername << "&"
              << "api_password=" << mVOIPMsSettings.mPassword << "&"
              << "method=" << "getSMS" << "&"
              << "from=" << StartDate.toString("yyyy-MM-dd") << "&"
              << "to=" << EndDate.toString("yyyy-MM-dd") << "&"
              << "did=" << mVOIPMsSettings.mDefaultDID << "&"
              << "limit=" << VOIP_MS_SMS_MAX_COUNT;

    qDebug() << "Cmd: " << Url;
    mVOIPMSSocket->get(QNetworkRequest(Url));
    mCurStartDate = EndDate;


    return RET_OK;
}

int CVoipMsSMSClient::DownloadNewSMS()
{
    SendSMSDownloadRequest(QDate::currentDate(),QDate::currentDate());
}

unsigned int CVoipMsSMSClient::GetDidFromUserAccount(const QString username, const QString Password)
{
    QString Method = "getDIDsInfo";
    QString Url;
    Url.clear();
    QTextStream UrlStream(&Url);

    UrlStream << VOIP_MS_API_URL
              << "api_username=" << username << "&"
              << "api_password=" << Password << "&"
              << "method=" << Method << "&";

     mVOIPMSSocket->get(QNetworkRequest(Url));

    return RET_OK;
}

void CVoipMsSMSClient::VoipServerReplyFinished(QNetworkReply *NetworkReply)
{
    QByteArray Reply = NetworkReply->readAll();

    QJsonDocument JsonReply = QJsonDocument::fromJson(Reply);
    QJsonObject JsonObject = JsonReply.object();
    QStringList Keys = JsonObject.keys();
    if(JsonObject["status"].toString() == "success")
    {
        if(Keys.contains("sms"))
        {
            QJsonArray SMSArray = JsonObject["sms"].toArray();
            SMSReceived(&SMSArray);
        }
        else if(Keys.contains("dids"))
        {
            QJsonArray DIDsInfoArray = JsonObject["dids"].toArray();
            DIDsInfoReceived(&DIDsInfoArray);
        }
    }
    else
    {
        qDebug() << "VOIP.MS reply: " << JsonObject["status"].toString();
        if(JsonObject["status"].toString() == "no_sms")
        {
            SMSReceived(0);
        }
    }
}

unsigned int CVoipMsSMSClient::SMSReceived(QJsonArray *SMSArray)
{

    QList<CSMSMessage> NewMessages;
    int NBMsgReceived;

    if(SMSArray != 0)
    {
        foreach (const QJsonValue & value, *SMSArray)
        {
            CSMSMessage NewMessage;
            QJsonObject obj = value.toObject();
            NewMessage.mContact = obj["contact"].toString();
            NewMessage.mDateTime = QDateTime::fromString(obj["date"].toString(),"yyyy-MM-dd HH:mm:ss");
            NewMessage.mDID = obj["did"].toString();
            NewMessage.mMessageText = obj["message"].toString();
            NewMessage.mType = (SmsType_t)obj["type"].toString().toInt();
            NewMessage.mVOIPMSDatabaseID = obj["id"].toString();//.toLongLong();
            NewMessages.append(NewMessage);
            //qDebug() << obj["date"].toString() << " : " << obj["id"].toString();
        }

        NBMsgReceived = NewMessages.size();
        qDebug() << "Received " << NBMsgReceived << "messages";


        if(mSMSMessagesList.size() >0 && NewMessages.size() > 0)
        {
            //remove existing messages...
            bool finished = false;

            QDateTime NewDate = NewMessages.at(0).mDateTime;
            QDateTime OldDate = mSMSMessagesList.at(0).mDateTime;

            if(NewDate > OldDate)
            {
                while(!finished)
                {
                    //compare starting from the end for efficiency...
                    NewDate = NewMessages.last().mDateTime;
                    OldDate = mSMSMessagesList.at(0).mDateTime;

                    if(NewDate <= OldDate)
                    {
                        NewMessages.removeLast();
                        if(NewMessages.size() == 0)
                        {
                            finished = true;
                        }
                    }
                    else
                    {
                        finished = true;
                    }
                }

                NewMessages.append(mSMSMessagesList);
                mSMSMessagesList = NewMessages;
            }
            else
            {

                while(!finished)
                {
                    //compare starting from the end for efficiency...
                    NewDate = NewMessages.at(0).mDateTime;
                    OldDate = mSMSMessagesList.last().mDateTime;

                    if(NewDate >= OldDate)
                    {
                        NewMessages.removeAt(0);
                        if(NewMessages.size() == 0)
                        {
                            finished = true;
                        }
                    }
                    else
                    {
                        finished = true;
                    }
                }
                 mSMSMessagesList.append(NewMessages);
            }
        }
        else
        {
            mSMSMessagesList.append(NewMessages);
        }




        if(NBMsgReceived == VOIP_MS_SMS_MAX_COUNT)
        {
            //Restart at the last day received...
            mCurStartDate = mSMSMessagesList.last().mDateTime.date();
            QDate EarlierDate = mCurStartDate.addDays(-VOIP_MS_SMS_DATESPAN);
            SendSMSDownloadRequest(EarlierDate,mCurStartDate);
        }
        else
        {
            qDebug() << "Finished download of " << mSMSMessagesList.size() << " SMS messages";
            qDebug("-----------------------------------------------------------------------");
            qDebug(" ");
            for(int i = 0; i < mSMSMessagesList.size(); i++)
            {
                qDebug() << mSMSMessagesList.at(i).mDateTime.toString("yyyy-MM-dd hh:mm:ss") << " : " << mSMSMessagesList.at(i).mContact  << " : " << mSMSMessagesList.at(i).mMessageText.toUtf8().data();
            }
            qDebug("-----------------------------------------------------------------------");
            qDebug(" ");

        }
    }
    else
    {
        qDebug("No SMS to download in this period.");
    }

    return RET_OK;
}

unsigned int CVoipMsSMSClient::NewSMSNotification(QString DID)
{
    if(DID != mVOIPMsSettings.mDefaultDID)
    {
        return RET_ERROR;
    }

    DownloadNewSMS();
    return RET_OK;
}

unsigned int CVoipMsSMSClient::DIDsInfoReceived(QJsonArray *DIDsInfoPtr)
{
    QStringList DIDs;
    QJsonArray DIDsInfo = *DIDsInfoPtr;

    foreach (const QJsonValue & value, DIDsInfo)
    {
        QJsonObject DIDInfo = value.toObject();
        QString CurDID = DIDInfo["did"].toString();
        int SMSEnabled = DIDInfo["sms_enabled"].toString().toInt();
        if(SMSEnabled == 1)
        {
            DIDs.append(CurDID);
        }
        qDebug("DID: %s - SMSEnabled %d",CurDID.toUtf8().data(),SMSEnabled);

        emit DIDSFetched(DIDs);
    }

    return RET_OK;
}

void CVoipMsSMSClient::VoipNotificationServerConnected()
{
    qDebug("Client Connected");

    mClientConnection = mVOIPMsNotificationServer->nextPendingConnection();
    connect(mClientConnection,SIGNAL(readyRead()),this,SLOT(VoipNotificationServerDataAvail()));
   // ClientConnection->waitForReadyRead();

}

void CVoipMsSMSClient::VoipNotificationServerDataAvail()
{
    QString Notification(mClientConnection->readAll());
    QStringList Parts = Notification.split(" ");
    QString Data;
    QString Did;

    for(int i = 0; i < Parts.size(); i++)
    {
        if(Parts.at(i).contains("/?"))
        {
            Data = Parts.at(i);
            break;
        }
    }

    if(Data.isEmpty() == false)
    {
        Parts = Data.remove("/?").split("&");

        for(int i = 0; i < Parts.size(); i++)
        {
            if(Parts.at(i).contains("did="))
            {
                Data = Parts.at(i);
                Did = Data.remove("did=");
            }
        }
    }

    qDebug() << "New SMS from did: " << Did;

//    qDebug() << Notification;
    mClientConnection->close();

    NewSMSNotification(Did);
}

//https://www.voip.ms/api/v1/rest.php?api_username=jean-francois.martel@polymtl.ca&api_password=Pentium2&method=getBalance&advanced=True


//https://www.voip.ms/api/v1/rest.php?api_username=jean-francois.martel@polymtl.ca&api_password=Pentium2&method=getSMS&from=2014-01-01&to=2015-11-11&did=5143606463&limit=50