qsyncdownloaddata.cpp

Go to the documentation of this file.

#include "qsyncdownloaddata.h"
#include "qsyncdatainterface_p.h"

#include <QFile>
#include <QDateTime>

class QSyncDownloadDataPrivate : public QSyncDataInterfacePrivate
{
public:
    QSyncDownloadDataPrivate()
        : QSyncDataInterfacePrivate()
    {
    }

    QString m_downloadTime;
    QString m_downloadPath;
};



QSyncDownloadData::QSyncDownloadData(QNetworkAccessManager *networkManager, QObject *parent)
    : QSyncDataInterface(TTK_CREATE_PRIVATE(QSyncDownloadData), networkManager, parent)
{
    TTK_D(QSyncDownloadData);
    d->m_manager = networkManager;
}

void QSyncDownloadData::downloadDataOperator(const QString &time, const QString &bucket, const QString &fileName, const QString &filePath)
{
    TTK_D(QSyncDownloadData);
    d->m_downloadTime = time;
    d->m_downloadPath = filePath;

    const QString &method = "GET";
    const QString &url = TTK_SEPARATOR + fileName;
    const QString &resource = TTK_SEPARATOR + bucket + url;
    const QString &host = bucket + TTK_DOT + QSyncConfig::HOST;

    TTKStringMap headers;
    headers.insert("Date", QSyncUtils::GMT());
    headers.insert("Host", host);
    headers.insert("Content-Type", "charset=utf-8");

    d->insertAuthorization(method, headers, resource);

    QNetworkRequest request;
    request.setUrl("http://" + host + url);

    for(auto it = headers.constBegin(); it != headers.constEnd(); ++it)
    {
        request.setRawHeader(it.key().toUtf8(), it.value().toUtf8());
    }

    QNetworkReply *reply = d->m_manager->get(request);
    connect(reply, SIGNAL(finished()), SLOT(receiveDataFromServer()));
    QtNetworkErrorConnect(reply, this, replyError, TTK_SLOT);

    if(parent()->metaObject()->indexOfSlot("downloadProgress(QString,qint64,qint64)") != -1)
    {
        connect(reply, SIGNAL(downloadProgress(qint64,qint64)), SLOT(downloadProgress(qint64,qint64)));
        connect(this, SIGNAL(downloadProgressChanged(QString,qint64,qint64)), parent(), SLOT(downloadProgress(QString,qint64,qint64)));
    }
}

QString QSyncDownloadData::downloadUrl(const QString &bucket, const QString &fileName)
{
    return downloadUrl(bucket, fileName, "application/x-www-form-urlencoded");
}

QString QSyncDownloadData::downloadUrl(const QString &bucket, const QString &fileName, const QString &contentType)
{
    const qint64 deadline = QDateTime::currentDateTimeUtc().addSecs(60 * 30).toMSecsSinceEpoch() / 1000;

    const QString &encodeKey = pathEncode(fileName);
    const QString &method = "GET";
    const QString &resource = TTK_SEPARATOR + bucket + TTK_SEPARATOR + fileName;
    const QString &host = bucket + TTK_DOT + QSyncConfig::HOST;

    TTKStringMap headers;
    headers.insert("Date", QString::number(deadline));
    headers.insert("Content-Type", contentType);
    headers.insert("Host", host);

    const QString &signature = QSyncUtils::authorizationCode(QSyncConfig::KEY, method, headers, resource);
    return QString("http://%1/%2?OSSAccessKeyId=%3&Expires=%4&Signature=%5").arg(host, encodeKey, QSyncConfig::NAME).arg(deadline).arg(signature);
}

void QSyncDownloadData::receiveDataFromServer()
{
    TTK_D(QSyncDownloadData);
    QNetworkReply *reply = TTKObjectCast(QNetworkReply*, sender());
    if(reply)
    {
        if(reply->error() == QNetworkReply::NoError)
        {
            QFile file(d->m_downloadPath);
            if(file.open(QIODevice::WriteOnly))
            {
                file.write(reply->readAll());
                file.close();
            }
            Q_EMIT downloadFileFinished(d->m_downloadTime);
        }
        else
        {
            Q_EMIT downloadFileFinished(TTK_NAN_STR);
        }
        reply->deleteLater();
    }
    else
    {
        Q_EMIT downloadFileFinished(TTK_NAN_STR);
    }
}

void QSyncDownloadData::downloadProgress(qint64 bytesSent, qint64 bytesTotal)
{
    TTK_D(QSyncDownloadData);
    Q_EMIT downloadProgressChanged(d->m_downloadTime, bytesSent, bytesTotal);
}