File indexing completed on 2024-04-21 03:55:30

 /*
     This file is part of the KDE libraries
     SPDX-FileCopyrightText: 2017 Elvis Angelaccio <elvis.angelaccio@kde.org>
 
     SPDX-License-Identifier: LGPL-2.0-only OR LGPL-3.0-only OR LicenseRef-KDE-Accepted-LGPL
 */
 
 #include "kioexecd.h"
 #include "kioexecdadaptor.h"
 #include "kioexecdebug.h"
 
 #include <KDirWatch>
 #include <KIO/CopyJob>
 #include <KLocalizedString>
 #include <KMessageBox>
 #include <KPluginFactory>
 
 #include <QDir>
 #include <QFileInfo>
 #include <QStandardPaths>
 
 static const int predefinedTimeout = 30000; // 30s
 
 K_PLUGIN_CLASS_WITH_JSON(KIOExecd, "kioexecd.json")
 
 KIOExecd::KIOExecd(QObject *parent, const QList<QVariant> &)
     : KDEDModule(parent)
 {
     qCDebug(KIOEXEC) << "kioexecd started";
 
     new KIOExecdAdaptor(this);
     m_watcher = new KDirWatch(this);
 
     connect(m_watcher, &KDirWatch::dirty, this, &KIOExecd::slotDirty);
     connect(m_watcher, &KDirWatch::created, this, &KIOExecd::slotCreated);
     connect(m_watcher, &KDirWatch::deleted, this, &KIOExecd::slotDeleted);
     m_timer.setSingleShot(true);
     m_timer.setInterval(predefinedTimeout);
     connect(&m_timer, &QTimer::timeout, this, &KIOExecd::slotCheckDeletedFiles);
 }
 
 KIOExecd::~KIOExecd()
 {
     // Remove the remaining temporary files and if possible their parent directories
     for (auto it = m_watched.constBegin(); it != m_watched.constEnd(); ++it) {
         QFileInfo info(it.key());
         const auto parentDir = info.path();
         qCDebug(KIOEXEC) << "About to delete" << parentDir << "containing" << info.fileName();
         QFile::remove(it.key());
         QDir().rmdir(parentDir);
     }
 }
 
 void KIOExecd::watch(const QString &path, const QString &destUrl)
 {
     if (m_watched.contains(path)) {
         qCDebug(KIOEXEC) << "Already watching" << path;
         return;
     }
 
     qCDebug(KIOEXEC) << "Going to watch" << path << "for changes, remote destination is" << destUrl;
 
     // Watch the temporary file for modifications, creations or deletions
     m_watcher->addFile(path);
     m_watched.insert(path, QUrl(destUrl));
 }
 
 void KIOExecd::slotCreated(const QString &path)
 {
     m_deleted.remove(path);
 
     // When the file is recreated, it is not signaled as dirty.
     slotDirty(path);
 }
 
 void KIOExecd::slotDirty(const QString &path)
 {
     if (!m_watched.contains(path)) {
         return;
     }
 
     const auto dest = m_watched.value(path);
 
     const auto result = KMessageBox::questionTwoActions(nullptr,
                                                         i18n("The file %1\nhas been modified. Do you want to upload the changes?", dest.toDisplayString()),
                                                         i18n("File Changed"),
                                                         KGuiItem(i18n("Upload")),
                                                         KGuiItem(i18n("Do Not Upload")));
     if (result != KMessageBox::PrimaryAction) {
         return;
     }
 
     qCDebug(KIOEXEC) << "Uploading" << path << "to" << dest;
     auto job = KIO::copy(QUrl::fromLocalFile(path), dest);
     connect(job, &KJob::result, this, [](KJob *job) {
         if (job->error()) {
             KMessageBox::error(nullptr, job->errorString());
         }
     });
 }
 
 void KIOExecd::slotDeleted(const QString &path)
 {
     if (!m_watched.contains(path)) {
         return;
     }
 
     m_deleted.insert(path, QDateTime::currentDateTimeUtc());
     m_timer.start();
 }
 
 void KIOExecd::slotCheckDeletedFiles()
 {
     const QDateTime currentDateTime = QDateTime::currentDateTimeUtc();
     // check if the deleted (and not recreated) files where deleted 30s ago or more
     for (auto it = m_deleted.begin(); it != m_deleted.end();) {
         if (it.value().msecsTo(currentDateTime) >= predefinedTimeout) {
             qCDebug(KIOEXEC) << "Going to forget" << it.key();
             m_watcher->removeFile(it.key());
             m_watched.remove(it.key());
             QFileInfo info(it.key());
             const auto parentDir = info.path();
             qCDebug(KIOEXEC) << "About to delete" << parentDir;
             QDir().rmdir(parentDir);
             it = m_deleted.erase(it);
         } else {
             ++it;
         }
     }
     if (!m_deleted.isEmpty()) {
         m_timer.start();
     }
 }
 
 #include "kioexecd.moc"
 #include "moc_kioexecd.cpp"