Page MenuHome GnuPG
Files F34024238

task.cpp
No OneTemporary
Actions

task.cpp
View Options

/* -*- 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"

File Metadata

Mime Type
text/x-c++
Expires
Sat, Nov 29, 7:12 AM (48 m, 24 s)
Storage Engine
local-disk
Storage Format
Raw Data
Storage Handle
ca/40/822c43da2d59d80df5f2df1504e2

Event Timeline