File indexing completed on 2024-05-12 16:21:31

 /**
  * SPDX-FileCopyrightText: 2021 Bart De Vries <bart@mogwai.be>
  *
  * SPDX-License-Identifier: GPL-2.0-only OR GPL-3.0-only OR LicenseRef-KDE-Accepted-GPL
  */
 
 #include "storagemovejob.h"
 #include "storagemovejoblogging.h"
 
 #include <QDir>
 #include <QFile>
 #include <QTimer>
 
 #include <KLocalizedString>
 
 
 StorageMoveJob::StorageMoveJob(const QString &from, const QString &to, QStringList &list, QObject *parent)
     : KJob(parent)
     , m_from(from)
     , m_to(to)
     , m_list(list)
 {
 }
 
 void StorageMoveJob::start()
 {
     QTimer::singleShot(0, this, &StorageMoveJob::moveFiles);
 }
 
 void StorageMoveJob::moveFiles()
 {
     qCDebug(kastsStorageMoveJob) << "Begin moving" << m_list << "from" << m_from << "to" << m_to;
 
     bool success = true;
 
     QStringList fileList; // this list will contain all files that need to be moved
 
     for (QString item : m_list) {
         // make a list of files to be moved; path is relative to m_from
         if (QFileInfo(m_from + QStringLiteral("/") + item).isDir()) {
             // this item is a dir; now add all files in that subdir
             QStringList tempList = QDir(m_from + QStringLiteral("/") + item + QStringLiteral("/")).entryList(QDir::Files);
             for (QString file : tempList) {
                 fileList += item + QStringLiteral("/") + file;
             }
 
             // if the item is a subdir, let's try to create it in the new location
             // if this fails, then the destination is not writeable, and the move
             // should be aborted
             success = QFileInfo().absoluteDir().mkpath(m_to + QStringLiteral("/") + item) && success;
         } else if (QFileInfo(m_from + QStringLiteral("/") + item).isFile()) {
             // this item is a file; simply add it to the list
             fileList += item;
         }
     }
 
     if (!success) {
         setError(2);
         setErrorText(i18n("Destination path not writable"));
         emitResult();
         return;
     }
 
     setTotalAmount(Files, fileList.size());
     setProcessedAmount(Files, 0);
 
     for (int i = 0; i < fileList.size(); i++) {
         // First check if we need to abort this job
         if (m_abort) {
             // Remove files that were already copied
             for (int j = 0; j < i; j++) {
                 qCDebug(kastsStorageMoveJob) << "Removing file" << QDir(m_to).absoluteFilePath(fileList[j]);
                 QFile(QDir(m_to).absoluteFilePath(fileList[j])).remove();
             }
             setError(1);
             setErrorText(i18n("Operation aborted by user"));
             emitResult();
             return;
         }
 
         // Now we can start copying
         QString fromPath = QDir(m_from).absoluteFilePath(fileList[i]);
         QString toPath = QDir(m_to).absoluteFilePath(fileList[i]);
         if (QFileInfo::exists(toPath) && (QFileInfo(fromPath).size() == QFileInfo(toPath).size())) {
             qCDebug(kastsStorageMoveJob) << "Identical file already exists in destination; skipping" << toPath;
         } else {
             qCDebug(kastsStorageMoveJob) << "Copy" << fromPath << "to" << toPath;
             success = QFile(fromPath).copy(toPath) && success;
         }
         if (!success)
             break;
         setProcessedAmount(Files, i + 1);
     }
 
     if (m_abort) {
         setError(1);
         setErrorText(i18n("Operation aborted by user"));
     } else if (success) {
         // now it's safe to delete all the files from the original location
         for (QString file : fileList) {
             QFile(QDir(m_from).absoluteFilePath(file)).remove();
             qCDebug(kastsStorageMoveJob) << "Removing file" << QDir(m_from).absoluteFilePath(file);
         }
 
         // delete the directories as well
         for (const QString &item : m_list) {
             if (!item.isEmpty() && QFileInfo(m_from + QStringLiteral("/") + item).isDir()) {
                 QDir(m_from).rmdir(item);
             }
         }
     } else {
         setError(2);
         setErrorText(i18n("An error occurred while copying data"));
     }
 
     emitResult();
 }
 
 bool StorageMoveJob::doKill()
 {
     m_abort = true;
     return true;
 }