File indexing completed on 2023-09-24 06:01:07

 /***************************************************************************
  *   Copyright (C) 2008-2011 by Daniel Nicoletti                           *
  *   dantti12@gmail.com                                                    *
  *                                                                         *
  *   This program is free software; you can redistribute it and/or modify  *
  *   it under the terms of the GNU General Public License as published by  *
  *   the Free Software Foundation; either version 2 of the License, or     *
  *   (at your option) any later version.                                   *
  *                                                                         *
  *   This program is distributed in the hope that it will be useful,       *
  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  *   GNU General Public License for more details.                          *
  *                                                                         *
  *   You should have received a copy of the GNU General Public License     *
  *   along with this program; see the file COPYING. If not, write to       *
  *   the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,  *
  *   Boston, MA 02110-1301, USA.                                           *
  ***************************************************************************/
 
 #include "TransactionJob.h"
 
 #include <PkStrings.h>
 #include <PkIcons.h>
 
 #include <KLocalizedString>
 //#include <KGlobal>
 #include <KNotification>
 
 #include <QLoggingCategory>
 
 Q_DECLARE_LOGGING_CATEGORY(APPER_DAEMON)
 
 TransactionJob::TransactionJob(Transaction *transaction, QObject *parent) :
     KJob(parent),
     m_transaction(transaction),
     m_status(transaction->status()),
     m_role(transaction->role()),
     m_flags(transaction->transactionFlags()),
     m_percentage(0),
     m_speed(0),
     m_downloadSizeRemainingTotal(0),
     m_finished(false)
 {
     setCapabilities(Killable);
 
     connect(transaction, &Transaction::roleChanged, this, &TransactionJob::updateJob);
     connect(transaction, &Transaction::statusChanged, this, &TransactionJob::updateJob);
     connect(transaction, &Transaction::downloadSizeRemainingChanged, this, &TransactionJob::updateJob);
     connect(transaction, &Transaction::transactionFlagsChanged, this, &TransactionJob::updateJob);
     connect(transaction, &Transaction::percentageChanged, this, &TransactionJob::updateJob);
     connect(transaction, &Transaction::speedChanged, this, &TransactionJob::updateJob);
     connect(transaction, &Transaction::finished, this, &TransactionJob::finished);
     connect(transaction, &Transaction::package, this, &TransactionJob::package);
     connect(transaction, &Transaction::repoDetail, this, &TransactionJob::repoDetail);
 }
 
 TransactionJob::~TransactionJob()
 {
 }
 
 void TransactionJob::finished(PackageKit::Transaction::Exit exit)
 {
     if (m_finished) {
         return;
     }
 
     // emit the description so the Speed: xxx KiB/s
     // don't get confused to a destination URL
     emit description(this, PkStrings::action(m_role, m_flags));
     if (exit == Transaction::ExitCancelled || exit == Transaction::ExitFailed) {
         setError(KilledJobError);
     }
     m_finished = true;
     emitResult();
 }
 
 void TransactionJob::package(Transaction::Info info, const QString &packageID, const QString &summary)
 {
     Q_UNUSED(summary)
     if (!packageID.isEmpty()) {
         bool changed = false;
         if (info == Transaction::InfoFinished) {
             changed = m_packages.removeOne(Transaction::packageName(packageID));
         } else if (!m_packages.contains(Transaction::packageName(packageID))) {
             m_packages << Transaction::packageName(packageID);
             changed = true;
         }
 
         if (changed) {
             m_details = m_packages.join(QLatin1String(", "));
             emitDescription();
         }
     }
 }
 
 void TransactionJob::repoDetail(const QString &repoId, const QString &repoDescription)
 {
     Q_UNUSED(repoId)
     QString first = PkStrings::status(m_status);
     emit description(this, PkStrings::action(m_role, m_flags), qMakePair(first, repoDescription));
 }
 
 void TransactionJob::emitDescription()
 {
     QString details = m_details;
     if (details.isEmpty()) {
         details = QLatin1String("...");
     }
 
     QString first = PkStrings::status(m_status);
     emit description(this, PkStrings::action(m_role, m_flags), qMakePair(first, details));
 }
 
 void TransactionJob::updateJob()
 {
     Transaction::Role role = m_transaction->role();
     Transaction::TransactionFlags flags = m_transaction->transactionFlags();
     if (m_role != role || m_flags != flags) {
         m_role = role;
         m_flags = flags;
         emitDescription();
     }
 
     // Status & Speed
     Transaction::Status status = m_transaction->status();
     if (m_status != status) {
         m_status = status;
         emitDescription();
     }
 
     uint percentage = m_transaction->percentage();
     if (percentage <= 100) {
         emitPercent(percentage, 100);
     } else if (m_percentage != 0) {
         percentage = 0;
         emitPercent(0, 0);
     }
     m_percentage = percentage;
 
     uint speed = m_transaction->speed();
     if (m_speed != speed) {
         m_speed = speed;
         emitSpeed(m_speed);
     }
 
     if (m_downloadSizeRemainingTotal == 0) {
         m_downloadSizeRemainingTotal = m_transaction->downloadSizeRemaining();
     }
 
     if (m_downloadSizeRemainingTotal) {
         qulonglong processed;
         processed = m_downloadSizeRemainingTotal - m_transaction->downloadSizeRemaining();
         emitPercent(processed, m_downloadSizeRemainingTotal);
     }
 }
 
 void TransactionJob::start()
 {
     m_role = Transaction::RoleUnknown;
     m_speed = 0;
     m_downloadSizeRemainingTotal = 0;
     m_details = Transaction::packageName(m_transaction->lastPackage());
     updateJob();
 }
 
 bool TransactionJob::isFinished() const
 {
     return m_finished;
 }
 
 Transaction *TransactionJob::transaction() const
 {
     return m_transaction;
 }
 
 bool TransactionJob::doKill()
 {
     // emit the description so the Speed: xxx KiB/s
     // don't get confused to a destination URL
     emit description(this, PkStrings::action(m_role, m_flags));
     QDBusPendingReply<> reply = m_transaction->cancel();
     reply.waitForFinished();
     qCDebug(APPER_DAEMON) << "Transaction cancel operation result" << m_transaction->tid().path() << reply.error();
     emit canceled();
 
     return !reply.isError() && m_transaction->role() == Transaction::RoleCancel;
 }
 
 #include "moc_TransactionJob.cpp"