Masterctrl/Sources/VoipSMS/VoipMsSMSClient.cpp

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

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);

    mCheckNewSMSTimer = new QTimer();
    connect(mCheckNewSMSTimer,SIGNAL(timeout()),this,SLOT(CheckNewSMSTimerExpired()));
    mCheckNewSMSTimer->setSingleShot(false);

    mFirstDownloadDone = false;

    mProgramHandle = 0;

}

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

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";

    StopSMSCheckTimer();

    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;

    mLastRequestCmd = "getSMS";


    return RET_OK;
}

int CVoipMsSMSClient::SendSMS(QList<CSMSMessage> *SMSList)
{

    if(SMSList->size() == 0)
    {
        return RET_ERROR;
    }

    SendSMS(SMSList->at(0));

    if(SMSList->size() > 1)
    {
        for(int i = 1; i < SMSList->size(); i++)
        {
            mPendingSMSSendList.append(SMSList->at(i));
        }
    }

    return RET_OK;
}

int CVoipMsSMSClient::SendSMS(CSMSMessage Message)
{
    QString Url;
    Url.clear();
    QTextStream UrlStream(&Url);

    StopSMSCheckTimer();
    UrlStream << VOIP_MS_API_URL
              << "api_username=" << mVOIPMsSettings.mUsername << "&"
              << "api_password=" << mVOIPMsSettings.mPassword << "&"
              << "method=" << "sendSMS" << "&"
              << "did=" << Message.mDID << "&"
              << "dst=" << Message.mContact << "&"
              << "message=" << Message.mMessageText;

    qDebug() << "Sending SMS Msg : " << Url;
    mVOIPMSSocket->get(QNetworkRequest(Url));
    mLastRequestCmd = "sendSMS";

    return RET_OK;
}

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

int CVoipMsSMSClient::CheckForNewSMS()
{
    if(mSMSMessagesList.isEmpty() == true)
    {
        return RET_ERROR;
    }


    QDate Today = QDate::currentDate();
    QDate StartDate = mSMSMessagesList.at(0).mDateTime.date();
    SendSMSDownloadRequest(StartDate,Today);
    return RET_OK;
}

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

    StopSMSCheckTimer();

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

     mVOIPMSSocket->get(QNetworkRequest(Url));
     mLastRequestCmd = Method;

    return RET_OK;
}

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

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

int CVoipMsSMSClient::SendSMSAckReceived(bool Success)
{
    if(Success)
    {
        qDebug("SMS sent successfuly");
        if(mPendingSMSSendList.size() != 0)
        {
            CSMSMessage Msg = mPendingSMSSendList.takeFirst();
            SendSMS(Msg);
        }
        else
        {
            CheckForNewSMS();
//            StartSMSCheckTimer();
        }
    }
    else
    {
        qDebug("SMS send failed");
        mPendingSMSSendList.clear();
        StartSMSCheckTimer();
    }



    return RET_OK;
}

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;
                    }
                }
                if(mFirstDownloadDone == true && NewMessages.size() > 0)
                {
                    mProgramHandle->NewSMSMessagesArrived(NewMessages);

                    qDebug() << "Added " << NewMessages.size() << " new SMS messages";
                    qDebug("-----------------------------------------------------------------------");
                    qDebug(" ");
                    for(int i = 0; i < NewMessages.size(); i++)
                    {
                        qDebug() << NewMessages.at(i).mDateTime.toString("yyyy-MM-dd hh:mm:ss") << " : " << NewMessages.at(i).mContact  << " : " << NewMessages.at(i).mMessageText.toUtf8().data();
                    }
                    qDebug("-----------------------------------------------------------------------");
                    qDebug(" ");
                }

                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);
                 if(mFirstDownloadDone == true && NewMessages.size() > 0)
                 {
                     mProgramHandle->NewSMSMessagesArrived(NewMessages);

                     qDebug() << "Added " << NewMessages.size() << " new SMS messages";
                     qDebug("-----------------------------------------------------------------------");
                     qDebug(" ");
                     for(int i = 0; i < NewMessages.size(); i++)
                     {
                         qDebug() << NewMessages.at(i).mDateTime.toString("yyyy-MM-dd hh:mm:ss") << " : " << NewMessages.at(i).mContact  << " : " << NewMessages.at(i).mMessageText.toUtf8().data();
                     }
                     qDebug("-----------------------------------------------------------------------");
                     qDebug(" ");
                 }
            }
        }
        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
        {
            if(mFirstDownloadDone == false)
            {
//                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(" ");


                mFirstDownloadDone = true;
//                mCheckNewSMSTimer->start(VOIP_MS_SMS_CHECK_TIMEOUT);
                StartSMSCheckTimer();
                qDebug("Timer started");
            }

        }
    }
    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);
    }

    StartSMSCheckTimer();

    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);
}

void CVoipMsSMSClient::CheckNewSMSTimerExpired()
{
    CheckForNewSMS();
}

QList<CSMSMessage> *CVoipMsSMSClient::GetSMSList()
{
    return &mSMSMessagesList;
}

int CVoipMsSMSClient::GetSMSCount()
{
    return mSMSMessagesList.size();
}

QString CVoipMsSMSClient::GetDefaultDID()
{
    return mVOIPMsSettings.mDefaultDID;
}

void CVoipMsSMSClient::StartSMSCheckTimer()
{
    if(mFirstDownloadDone == true)
    {
        mCheckNewSMSTimer->start(VOIP_MS_SMS_CHECK_TIMEOUT);
    }
}

void CVoipMsSMSClient::StopSMSCheckTimer()
{
    mCheckNewSMSTimer->stop();
}

//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