File indexing completed on 2024-06-16 04:55:59

 /* -*- mode: c++; c-basic-offset:4 -*-
     crypto/task.cpp
 
     This file is part of Kleopatra, the KDE keymanager
     SPDX-FileCopyrightText: 2007 Klarälvdalens Datakonsult AB
 
     SPDX-License-Identifier: GPL-2.0-or-later
 */
 
 #include <config-kleopatra.h>
 
 #include "task.h"
 #include "task_p.h"
 
 #include <Libkleo/KleoException>
 
 #include <Libkleo/AuditLogEntry>
 #include <Libkleo/GnuPG>
 
 #include <gpgme++/exception.h>
 
 #include <gpg-error.h>
 
 #include <KIconLoader>
 #include <KLocalizedString>
 
 using namespace Kleo;
 using namespace Kleo::Crypto;
 using namespace GpgME;
 
 namespace
 {
 
 class ErrorResult : public Task::Result
 {
 public:
     ErrorResult(const GpgME::Error &error, const QString &details)
         : Task::Result()
         , m_error(error)
         , m_details(details)
     {
     }
 
     QString overview() const override
     {
         return makeOverview(m_details);
     }
     QString details() const override
     {
         return QString();
     }
     GpgME::Error error() const override
     {
         return m_error;
     }
     QString errorString() const override
     {
         return m_details;
     }
     VisualCode code() const override
     {
         return NeutralError;
     }
     AuditLogEntry auditLog() const override
     {
         return AuditLogEntry();
     }
 
 private:
     const GpgME::Error m_error;
     const QString m_details;
 };
 }
 
 class Task::Private
 {
     friend class ::Kleo::Crypto::Task;
     Task *const q;
 
 public:
     explicit Private(Task *qq);
 
 private:
     int m_progress;
     int m_totalProgress;
     bool m_asciiArmor;
     int m_id;
 };
 
 namespace
 {
 static int nextTaskId = 0;
 }
 
 Task::Private::Private(Task *qq)
     : q(qq)
     , m_progress(0)
     , m_totalProgress(0)
     , m_asciiArmor(false)
     , m_id(nextTaskId++)
 {
 }
 
 Task::Task(QObject *p)
     : QObject(p)
     , d(new Private(this))
 {
 }
 
 Task::~Task()
 {
 }
 
 void Task::setAsciiArmor(bool armor)
 {
     d->m_asciiArmor = armor;
 }
 
 bool Task::asciiArmor() const
 {
     return d->m_asciiArmor;
 }
 
 std::shared_ptr<Task> Task::makeErrorTask(const GpgME::Error &error, const QString &details, const QString &label)
 {
     const std::shared_ptr<SimpleTask> t(new SimpleTask(label));
     t->setResult(t->makeErrorResult(error, details));
     return t;
 }
 
 int Task::id() const
 {
     return d->m_id;
 }
 
 int Task::currentProgress() const
 {
     return d->m_progress;
 }
 
 int Task::totalProgress() const
 {
     return d->m_totalProgress;
 }
 
 QString Task::tag() const
 {
     return QString();
 }
 
 void Task::setProgress(int processed, int total)
 {
     d->m_progress = processed;
     d->m_totalProgress = total;
     Q_EMIT progress(processed, total, QPrivateSignal());
 }
 
 void Task::start()
 {
     try {
         doStart();
     } catch (const Kleo::Exception &e) {
         QMetaObject::invokeMethod(this, "emitError", Qt::QueuedConnection, Q_ARG(GpgME::Error, e.error()), Q_ARG(QString, e.message()));
     } catch (const GpgME::Exception &e) {
         QMetaObject::invokeMethod(this, "emitError", Qt::QueuedConnection, Q_ARG(GpgME::Error, e.error()), Q_ARG(QString, QString::fromLocal8Bit(e.what())));
     } catch (const std::exception &e) {
         QMetaObject::invokeMethod(this,
                                   "emitError",
                                   Qt::QueuedConnection,
                                   Q_ARG(GpgME::Error, Error::fromCode(GPG_ERR_UNEXPECTED)),
                                   Q_ARG(QString, QString::fromLocal8Bit(e.what())));
     } catch (...) {
         QMetaObject::invokeMethod(this,
                                   "emitError",
                                   Qt::QueuedConnection,
                                   Q_ARG(GpgME::Error, Error::fromCode(GPG_ERR_UNEXPECTED)),
                                   Q_ARG(QString, i18n("Unknown exception in Task::start()")));
     }
     Q_EMIT started(QPrivateSignal());
 }
 
 void Task::emitError(const GpgME::Error &error, const QString &details)
 {
     emitResult(makeErrorResult(error, details));
 }
 
 void Task::emitResult(const std::shared_ptr<const Task::Result> &r)
 {
     d->m_progress = d->m_totalProgress;
     Q_EMIT progress(currentProgress(), totalProgress(), QPrivateSignal());
     Q_EMIT result(r, QPrivateSignal());
 }
 
 std::shared_ptr<Task::Result> Task::makeErrorResult(const GpgME::Error &error, const QString &details)
 {
     return std::shared_ptr<Task::Result>(new ErrorResult(error, details));
 }
 
 class Task::Result::Private
 {
 public:
     Private()
     {
     }
 };
 
 Task::Result::Result()
     : d(new Private())
 {
 }
 Task::Result::~Result()
 {
 }
 
 bool Task::Result::hasError() const
 {
     return error().code() != 0;
 }
 
 Task::Result::ContentType Task::Result::viewableContentType() const
 {
     return Task::Result::ContentType::None;
 }
 
 static QString image(const char *img)
 {
     // ### escape?
     return KIconLoader::global()->iconPath(QLatin1StringView(img), KIconLoader::Small);
 }
 
 QString Task::Result::makeOverview(const QString &msg)
 {
     return QLatin1StringView("<b>") + msg + QLatin1String("</b>");
 }
 
 QString Task::Result::iconPath(VisualCode code)
 {
     switch (code) {
     case Danger:
         return image("dialog-error");
     case AllGood:
         return image("dialog-ok");
     case Warning:
         return image("dialog-warning");
     case NeutralError:
     case NeutralSuccess:
     default:
         return QString();
     }
 }
 
 QString Task::Result::icon() const
 {
     return iconPath(code());
 }
 
 #include "moc_task_p.cpp"
 
 #include "moc_task.cpp"