1 files changed, 147 insertions, 0 deletions
diff --git a/lang/qt/src/qgpgmewkdrefreshjob.cpp b/lang/qt/src/qgpgmewkdrefreshjob.cpp
new file mode 100644
index 00000000..8bad1ef1
--- /dev/null
+++ b/lang/qt/src/qgpgmewkdrefreshjob.cpp
@@ -0,0 +1,147 @@
+/*
+    qgpgmewkdrefreshjob.cpp
+
+    This file is part of qgpgme, the Qt API binding for gpgme
+    Copyright (c) 2023 g10 Code GmbH
+    Software engineering by Ingo Klöcker <[email protected]>
+
+    QGpgME 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.
+
+    QGpgME 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; if not, write to the Free Software
+    Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
+
+    In addition, as a special exception, the copyright holders give
+    permission to link the code of this program with any edition of
+    the Qt library by Trolltech AS, Norway (or with modified versions
+    of Qt that use the same license as Qt), and distribute linked
+    combinations including the two.  You must obey the GNU General
+    Public License in all respects for all of the code used other than
+    Qt.  If you modify this file, you may extend this exception to
+    your version of the file, but you are not obligated to do so.  If
+    you do not wish to do so, delete this exception statement from
+    your version.
+*/
+
+#ifdef HAVE_CONFIG_H
+ #include "config.h"
+#endif
+
+#include "qgpgmewkdrefreshjob.h"
+
+#include "debug.h"
+#include "qgpgme_debug.h"
+#include "qgpgmekeylistjob.h"
+#include "wkdrefreshjob_p.h"
+
+#include <context.h>
+
+#include <memory>
+
+using namespace QGpgME;
+using namespace GpgME;
+
+namespace
+{
+
+class QGpgMEWKDRefreshJobPrivate : public WKDRefreshJobPrivate
+{
+    QGpgMEWKDRefreshJob *q = nullptr;
+
+public:
+    QGpgMEWKDRefreshJobPrivate(QGpgMEWKDRefreshJob *qq)
+        : q{qq}
+    {
+    }
+
+    ~QGpgMEWKDRefreshJobPrivate() override = default;
+
+private:
+    GpgME::Error startIt() override;
+
+    void startNow() override
+    {
+        q->run();
+    }
+};
+
+static QStringList toEmailAddressesOriginatingFromWKD(const std::vector<GpgME::Key> &keys)
+{
+    const QStringList emails = std::accumulate(keys.begin(), keys.end(), QStringList{}, [](QStringList &emails, const Key &key) {
+        const auto userIDs = key.userIDs();
+        emails = std::accumulate(std::begin(userIDs), std::end(userIDs), emails, [](QStringList &emails, const UserID &userID) {
+            if (!userID.isRevoked() && !userID.addrSpec().empty() && userID.origin() == Key::OriginWKD) {
+                emails.push_back(QString::fromStdString(userID.addrSpec()));
+            }
+            return emails;
+        });
+        return emails;
+    });
+    return emails;
+}
+
+}
+
+QGpgMEWKDRefreshJob::QGpgMEWKDRefreshJob(Context *context)
+    : mixin_type{context}
+{
+    setJobPrivate(this, std::unique_ptr<QGpgMEWKDRefreshJobPrivate>{new QGpgMEWKDRefreshJobPrivate{this}});
+    lateInitialization();
+}
+
+QGpgMEWKDRefreshJob::~QGpgMEWKDRefreshJob() = default;
+
+static ImportResult locate_external_keys(Context *ctx, const std::vector<Key> &keys)
+{
+    const auto emails = toEmailAddressesOriginatingFromWKD(keys);
+    qCDebug(QGPGME_LOG) << __func__ << "locating external keys for" << emails;
+    if (emails.empty()) {
+        return ImportResult{};
+    }
+
+    Context::KeyListModeSaver saver{ctx};
+    ctx->setKeyListMode(GpgME::LocateExternal);
+    ctx->setFlag("auto-key-locate", "clear,wkd");
+    std::vector<Key> dummy;
+    auto job = std::unique_ptr<KeyListJob>{new QGpgMEKeyListJob{ctx}};
+    (void) job->exec(emails, false, dummy);
+    qCDebug(QGPGME_LOG) << __func__ << "number of keys:" << dummy.size();
+    std::for_each(dummy.cbegin(), dummy.cend(), [](const Key &k) {
+        qCDebug(QGPGME_LOG) << __func__ << toLogString(k).c_str();
+    });
+    const auto result = ctx->importResult();
+    qCDebug(QGPGME_LOG) << __func__ << "result:" << toLogString(result).c_str();
+    job.release();
+
+    return result;
+}
+
+static QGpgMEWKDRefreshJob::result_type refresh_keys(Context *ctx, const std::vector<Key> &keys)
+{
+    const auto result = locate_external_keys(ctx, keys);
+
+    return std::make_tuple(result, QString{}, Error{});
+}
+
+GpgME::Error QGpgMEWKDRefreshJobPrivate::startIt()
+{
+    if (m_keys.empty()) {
+        return Error::fromCode(GPG_ERR_INV_VALUE);
+    }
+
+    q->run([=](Context *ctx) {
+        return refresh_keys(ctx, m_keys);
+    });
+
+    return {};
+}
+
+#include "qgpgmewkdrefreshjob.moc"