installmoduleprocess.cpp

// Copyright (c) 2019-2023 hors<horsicq@gmail.com>
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:

// The above copyright notice and this permission notice shall be included in all
// copies or substantial portions of the Software.

// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
// SOFTWARE.
//
#include "installmoduleprocess.h"

InstallModuleProcess::InstallModuleProcess(QObject *pParent) : QObject(pParent)
{
    currentStats = {};
    g_pPdStruct = nullptr;
}

void InstallModuleProcess::setData(QString sDataPath, QString sRootPath, QList<QString> listModuleFileNames, XBinary::PDSTRUCT *pPdStruct)
{
    this->sDataPath = XBinary::convertPathName(sDataPath);
    this->sRootPath = XBinary::convertPathName(sRootPath);
    this->listModuleFileNames = listModuleFileNames;
    this->g_pPdStruct = pPdStruct;
}

void InstallModuleProcess::stop()
{
    g_pPdStruct->bIsStop = true;
}

Utils::STATS InstallModuleProcess::getCurrentStats()
{
    return currentStats;
}

void InstallModuleProcess::process()
{
    QElapsedTimer elapsedTimer;
    elapsedTimer.start();

    currentStats.nTotalModule = listModuleFileNames.count();

    for (qint32 i = 0; (i < currentStats.nTotalModule) && (!(g_pPdStruct->bIsStop)); i++) {
        currentStats.sModule = QString("%1: %2").arg(tr("Install module")).arg(QFileInfo(listModuleFileNames.at(i)).baseName());
        emit infoMessage(currentStats.sModule);

        QFile file;
        file.setFileName(listModuleFileNames.at(i));

        if (file.open(QIODevice::ReadOnly)) {
            Utils::MDATA mdata = Utils::getMDataFromZip(&file, XBinary::convertPathName(sRootPath), g_pPdStruct);

            XZip zip(&file);

            QList<XArchive::RECORD> listZipRecords = zip.getRecords(-1, g_pPdStruct);

            currentStats.nTotalFile = mdata.listInstallRecords.count();

            for (qint32 j = 0; (j < currentStats.nTotalFile) && (!(g_pPdStruct->bIsStop)); j++) {
                Utils::HANDLE_RECORD record = mdata.listInstallRecords.at(j);

                currentStats.sFile = QString("%1: %2").arg(tr("Install file")).arg(sRootPath + QDir::separator() + record.sPath);
                emit infoMessage(currentStats.sFile);

                if (record.action == Utils::ACTION_COPYFILE) {
                    if (XBinary::isFileExists(sRootPath + QDir::separator() + record.sPath)) {
                        if (!XBinary::removeFile(sRootPath + QDir::separator() + record.sPath)) {
                            emit errorMessage(QString("%1: %2").arg(tr("Cannot remove file")).arg(sRootPath + QDir::separator() + record.sPath));
                            g_pPdStruct->bIsStop = true;
                        }
                    }

                    XArchive::RECORD archiveRecord = XArchive::getArchiveRecord("files/" + record.sPath, &listZipRecords);
                    zip.decompressToFile(&archiveRecord, sRootPath + QDir::separator() + record.sPath);

                    if (!XBinary::isFileHashValid(XBinary::HASH_SHA1, sRootPath + QDir::separator() + record.sPath, record.sSHA1)) {
                        emit errorMessage(QString("%1: %2").arg(tr("Invalid file HASH")).arg(sRootPath + QDir::separator() + record.sPath));
                        g_pPdStruct->bIsStop = true;
                    }
                } else if (record.action == Utils::ACTION_MAKEDIRECTORY) {
                    XBinary::createDirectory(sRootPath + QDir::separator() + record.sPath);
                }

                currentStats.nCurrentFile = j + 1;
            }

            QString sInfoFileName = Utils::getInstalledJsonFileName(sDataPath, mdata.sName);

            if (XBinary::isFileExists(sInfoFileName)) {
                if (!XBinary::removeFile(sInfoFileName)) {
                    emit errorMessage(QString("%1: %2").arg(tr("Cannot remove file")).arg(sInfoFileName));
                    g_pPdStruct->bIsStop = true;
                }
            }

            XArchive::RECORD archiveRecord = XArchive::getArchiveRecord("plugin_info.json", &listZipRecords);
            zip.decompressToFile(&archiveRecord, sInfoFileName);

            file.close();
        }

        currentStats.nCurrentModule = i + 1;
    }

    emit completed(elapsedTimer.elapsed());
}