#include <QMutexLocker>
#include <QFile>

#include "filecopier.h"

FileCopier::FileCopier(QObject *parent) : QThread(parent), mCancel(false){}

void FileCopier::addJob(const QString &source, const QString &dest){
    QMutexLocker l(&mAddJobMutex);
    if(!mJobs.contains(source)){
        mJobs[source] = dest;
    }
}

QHash<QString, QString> FileCopier::jobs(){
    QMutexLocker l(&mAddJobMutex);
    return mJobs;
}

void FileCopier::run(){
    int bufsize = 16 * 1024 * 1024;
    char *buf = new char[bufsize];
    mCancel = false;
    while(!mJobs.isEmpty()){
        mAddJobMutex.lock();
        auto first = mJobs.constBegin();
        auto source = first.key();
        auto dest = first.value();
        mJobs.remove(source);
        mAddJobMutex.unlock();
        QFile sFile(source);
        QFile dFile(dest);
        bool openSource = sFile.open(QIODevice::ReadOnly);
        bool openDest = dFile.open(QIODevice::WriteOnly);
        if(!openSource || !openDest){
            emit success(false, source);
            goto cleanup;
        }
        emit newFile(source, sFile.size());
        int read = 0;
        qint64 total = 0;
        while(!sFile.atEnd()){
            mCancelMutex.lock();
            bool cancel = mCancel;
            mCancelMutex.unlock();
            if(cancel){
                QFile::remove(dest);
                emit success(false, source);
                goto cleanup;
            }
            read = sFile.read(buf, bufsize);
            dFile.write(buf, read);
            total += read;
            emit bytesRead(total);
        }
        emit success(true, source);
    }

    cleanup:
    delete buf;
}

void FileCopier::cancel(){
    QMutexLocker l(&mCancelMutex);
    mCancel = true;
}