/*

  context.cpp - wraps a gpgme key context

  Copyright (C) 2003, 2007 Klarälvdalens Datakonsult AB

  This file is part of GPGME++.

  GPGME++ is free software; you can redistribute it and/or

  modify it under the terms of the GNU Library General Public

  License as published by the Free Software Foundation; either

  version 2 of the License, or (at your option) any later version.

  GPGME++ 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 Library General Public License for more details.

  You should have received a copy of the GNU Library General Public License

  along with GPGME++; see the file COPYING.LIB.  If not, write to the

  Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,

  Boston, MA 02110-1301, USA.

*/

#ifdef HAVE_CONFIG_H

 #include "config.h"

#endif

#include <context.h>

#include <eventloopinteractor.h>

#include <trustitem.h>

#include <keylistresult.h>

#include <keygenerationresult.h>

#include <importresult.h>

#include <decryptionresult.h>

#include <verificationresult.h>

#include <signingresult.h>

#include <encryptionresult.h>

#include <engineinfo.h>

#include <editinteractor.h>

#include <vfsmountresult.h>

#include <interfaces/assuantransaction.h>

#include <defaultassuantransaction.h>

#include "callbacks.h"

#include "data_p.h"

#include "context_p.h"

#include "util.h"

#include "tofuinfo.h"

#include <gpgme.h>

#include <istream>

#ifndef NDEBUG

#include <iostream>

using std::cerr;

using std::endl;

#endif

#include <cassert>

namespace GpgME

{

static inline unsigned int xtoi_1(const char *str)

{

    const unsigned int ch = *str;

    const unsigned int result =

        ch <= '9' ? ch - '0' :

        ch <= 'F' ? ch - 'A' + 10 :

        /* else */  ch - 'a' + 10 ;

    return result < 16 ? result : 0 ;

}

static inline int xtoi_2(const char *str)

{

    return xtoi_1(str) * 16U + xtoi_1(str + 1);

}

static void percent_unescape(std::string &s, bool plus2space)

{

    std::string::iterator src = s.begin(), dest = s.begin(), end = s.end();

    while (src != end) {

        if (*src == '%' && end - src > 2) {

            *dest++ = xtoi_2(&*++src);

            src += 2;

        } else if (*src == '+' && plus2space) {

            *dest++ = ' ';

            ++src;

        } else {

            *dest++ = *src++;

        }

    }

    s.erase(dest, end);

}

void initializeLibrary()

{

    gpgme_check_version(0);

}

Error initializeLibrary(int)

{

    if (gpgme_check_version(GPGME_VERSION)) {

        return Error();

    } else {

        return Error::fromCode(GPG_ERR_USER_1);

    }

}

static void format_error(gpgme_error_t err, std::string &str)

{

    char buffer[ 1024 ];

    gpgme_strerror_r(err, buffer, sizeof buffer);

    buffer[ sizeof buffer - 1 ] = '\0';

    str = buffer;

}

const char *Error::source() const

{

    return gpgme_strsource((gpgme_error_t)mErr);

}

const char *Error::asString() const

{

    if (mMessage.empty()) {

        format_error(static_cast<gpgme_error_t>(mErr), mMessage);

    }

    return mMessage.c_str();

}

int Error::code() const

{

    return gpgme_err_code(mErr);

}

int Error::sourceID() const

{

    return gpgme_err_source(mErr);

}

bool Error::isCanceled() const

{

    return code() == GPG_ERR_CANCELED;

}

int Error::toErrno() const

{

//#ifdef HAVE_GPGME_GPG_ERROR_WRAPPERS

    return gpgme_err_code_to_errno(static_cast<gpgme_err_code_t>(code()));

//#else

//    return gpg_err_code_to_errno( static_cast<gpg_err_code_t>( code() ) );

//#endif

}

// static

bool Error::hasSystemError()

{

    return gpgme_err_code_from_syserror() == GPG_ERR_MISSING_ERRNO ;

}

// static

void Error::setSystemError(gpg_err_code_t err)

{

    setErrno(gpgme_err_code_to_errno(err));

}

// static

void Error::setErrno(int err)

{

    gpgme_err_set_errno(err);

}

// static

Error Error::fromSystemError(unsigned int src)

{

    return Error(gpgme_err_make(static_cast<gpgme_err_source_t>(src), gpgme_err_code_from_syserror()));

}

// static

Error Error::fromErrno(int err, unsigned int src)

{

    return Error(gpgme_err_make(static_cast<gpgme_err_source_t>(src), gpgme_err_code_from_errno(err)));

}

// static

Error Error::fromCode(unsigned int err, unsigned int src)

{

    return Error(gpgme_err_make(static_cast<gpgme_err_source_t>(src), static_cast<gpgme_err_code_t>(err)));

}

std::ostream &operator<<(std::ostream &os, const Error &err)

{

    return os << "GpgME::Error(" << err.encodedError() << " (" << err.asString() << "))";

}

Context::Context(gpgme_ctx_t ctx) : d(new Private(ctx))

{

}

Context::~Context()

{

    delete d;

}

Context *Context::createForProtocol(Protocol proto)

{

    gpgme_ctx_t ctx = 0;

    if (gpgme_new(&ctx) != 0) {

        return 0;

    }

    switch (proto) {

    case OpenPGP:

        if (gpgme_set_protocol(ctx, GPGME_PROTOCOL_OpenPGP) != 0) {

            gpgme_release(ctx);

            return 0;

        }

        break;

    case CMS:

        if (gpgme_set_protocol(ctx, GPGME_PROTOCOL_CMS) != 0) {

            gpgme_release(ctx);

            return 0;

        }

        break;

    default:

        gpgme_release(ctx);

        return 0;

    }

    return new Context(ctx);

}

std::unique_ptr<Context> Context::createForEngine(Engine eng, Error *error)

{

    gpgme_ctx_t ctx = 0;

    if (const gpgme_error_t err = gpgme_new(&ctx)) {

        if (error) {

            *error = Error(err);

        }

        return std::unique_ptr<Context>();

    }

    switch (eng) {

    case AssuanEngine:

        if (const gpgme_error_t err = gpgme_set_protocol(ctx, GPGME_PROTOCOL_ASSUAN)) {

            gpgme_release(ctx);

            if (error) {

                *error = Error(err);

            }

            return std::unique_ptr<Context>();

        }

        break;

    case G13Engine:

        if (const gpgme_error_t err = gpgme_set_protocol(ctx, GPGME_PROTOCOL_G13)) {

            gpgme_release(ctx);

            if (error) {

                *error = Error(err);

            }

            return std::unique_ptr<Context>();

        }

        break;

    case SpawnEngine:

        if (const gpgme_error_t err = gpgme_set_protocol(ctx, GPGME_PROTOCOL_SPAWN)) {

            gpgme_release(ctx);

            if (error) {

                *error = Error(err);

            }

            return std::unique_ptr<Context>();

        }

        break;

    default:

        gpgme_release(ctx);

        if (error) {

            *error = Error::fromCode(GPG_ERR_INV_ARG);

        }

        return std::unique_ptr<Context>();

    }

    if (error) {

        *error = Error();

    }

    return std::unique_ptr<Context>(new Context(ctx));

}

void Context::setDecryptionFlags(DecryptionFlags flags)

{

    d->decryptFlags = flags;

}

//

//

// Context::Private

//

//

Context::Private::Private(gpgme_ctx_t c)

    : ctx(c),

      iocbs(0),

      lastop(None),

      lasterr(GPG_ERR_NO_ERROR),

      lastAssuanInquireData(Data::null),

      lastAssuanTransaction(),

      lastEditInteractor(),

      lastCardEditInteractor(),

      decryptFlags(DecryptNone)

{

}

Context::Private::~Private()

{

    if (ctx) {

        gpgme_release(ctx);

    }

    ctx = 0;

    delete iocbs;

}

//

//

// Context attributes:

//

//

Protocol Context::protocol() const

{

    gpgme_protocol_t p = gpgme_get_protocol(d->ctx);

    switch (p) {

    case GPGME_PROTOCOL_OpenPGP: return OpenPGP;

    case GPGME_PROTOCOL_CMS:     return CMS;

    default:                     return UnknownProtocol;

    }

}

void Context::setArmor(bool useArmor)

{

    gpgme_set_armor(d->ctx, int(useArmor));

}

bool Context::armor() const

{

    return gpgme_get_armor(d->ctx);

}

void Context::setTextMode(bool useTextMode)

{

    gpgme_set_textmode(d->ctx, int(useTextMode));

}

bool Context::textMode() const

{

    return gpgme_get_textmode(d->ctx);

}

void Context::setOffline(bool useOfflineMode)

{

    gpgme_set_offline(d->ctx, int(useOfflineMode));

}

bool Context::offline() const

{

    return gpgme_get_offline(d->ctx);

}

void Context::setIncludeCertificates(int which)

{

    if (which == DefaultCertificates) {

        which = GPGME_INCLUDE_CERTS_DEFAULT;

    }

    gpgme_set_include_certs(d->ctx, which);

}

int Context::includeCertificates() const

{

    return gpgme_get_include_certs(d->ctx);

}

void Context::setKeyListMode(unsigned int mode)

{

    gpgme_set_keylist_mode(d->ctx, add_to_gpgme_keylist_mode_t(0, mode));

}

void Context::addKeyListMode(unsigned int mode)

{

    const unsigned int cur = gpgme_get_keylist_mode(d->ctx);

    gpgme_set_keylist_mode(d->ctx, add_to_gpgme_keylist_mode_t(cur, mode));

}

unsigned int Context::keyListMode() const

{

    return convert_from_gpgme_keylist_mode_t(gpgme_get_keylist_mode(d->ctx));

}

void Context::setProgressProvider(ProgressProvider *provider)

{

    gpgme_set_progress_cb(d->ctx, provider ? &progress_callback : 0, provider);

}

ProgressProvider *Context::progressProvider() const

{

    void *pp = 0;

    gpgme_progress_cb_t pcb = &progress_callback;

    gpgme_get_progress_cb(d->ctx, &pcb, &pp;;

    return static_cast<ProgressProvider *>(pp);

}

void Context::setPassphraseProvider(PassphraseProvider *provider)

{

    gpgme_set_passphrase_cb(d->ctx, provider ? &passphrase_callback : 0, provider);

}

PassphraseProvider *Context::passphraseProvider() const

{

    void *pp = 0;

    gpgme_passphrase_cb_t pcb = &passphrase_callback;

    gpgme_get_passphrase_cb(d->ctx, &pcb, &pp;;

    return static_cast<PassphraseProvider *>(pp);

}

void Context::setManagedByEventLoopInteractor(bool manage)

{

    if (!EventLoopInteractor::instance()) {

#ifndef NDEBUG

        cerr << "Context::setManagedByEventLoopInteractor(): "

             "You must create an instance of EventLoopInteractor "

             "before using anything that needs one." << endl;

#endif

        return;

    }

    if (manage) {

        EventLoopInteractor::instance()->manage(this);

    } else {

        EventLoopInteractor::instance()->unmanage(this);

    }

}

bool Context::managedByEventLoopInteractor() const

{

    return d->iocbs != 0;

}

void Context::installIOCallbacks(gpgme_io_cbs *iocbs)

{

    if (!iocbs) {

        uninstallIOCallbacks();

        return;

    }

    gpgme_set_io_cbs(d->ctx, iocbs);

    delete d->iocbs; d->iocbs = iocbs;

}

void Context::uninstallIOCallbacks()

{

    static gpgme_io_cbs noiocbs = { 0, 0, 0, 0, 0 };

    // io.add == 0 means disable io callbacks:

    gpgme_set_io_cbs(d->ctx, &noiocbs);

    delete d->iocbs; d->iocbs = 0;

}

Error Context::setLocale(int cat, const char *val)

{

    return Error(d->lasterr = gpgme_set_locale(d->ctx, cat, val));

}

EngineInfo Context::engineInfo() const

{

    return EngineInfo(gpgme_ctx_get_engine_info(d->ctx));

}

Error Context::setEngineFileName(const char *filename)

{

    const char *const home_dir = engineInfo().homeDirectory();

    return Error(gpgme_ctx_set_engine_info(d->ctx, gpgme_get_protocol(d->ctx), filename, home_dir));

}

Error Context::setEngineHomeDirectory(const char *home_dir)

{

    const char *const filename = engineInfo().fileName();

    return Error(gpgme_ctx_set_engine_info(d->ctx, gpgme_get_protocol(d->ctx), filename, home_dir));

}

Error Context::setSender (const char *sender)

{

    return Error(gpgme_set_sender(d->ctx, sender));

}

const char *Context::getSender ()

{

    return gpgme_get_sender(d->ctx);

}

//

//

// Key Management

//

//

Error Context::startKeyListing(const char *pattern, bool secretOnly)

{

    d->lastop = Private::KeyList;

    return Error(d->lasterr = gpgme_op_keylist_start(d->ctx, pattern, int(secretOnly)));

}

Error Context::startKeyListing(const char *patterns[], bool secretOnly)

{

    d->lastop = Private::KeyList;

#ifndef HAVE_GPGME_EXT_KEYLIST_MODE_EXTERNAL_NONBROKEN

    if (!patterns || !patterns[0] || !patterns[1]) {

        // max. one pattern -> use the non-ext version

        return startKeyListing(patterns ? patterns[0] : 0, secretOnly);

    }

#endif

    return Error(d->lasterr = gpgme_op_keylist_ext_start(d->ctx, patterns, int(secretOnly), 0));

}

Key Context::nextKey(GpgME::Error &e)

{

    d->lastop = Private::KeyList;

    gpgme_key_t key;

    e = Error(d->lasterr = gpgme_op_keylist_next(d->ctx, &key));

    return Key(key, false);

}

KeyListResult Context::endKeyListing()

{

    d->lasterr = gpgme_op_keylist_end(d->ctx);

    return keyListResult();

}

KeyListResult Context::keyListResult() const

{

    return KeyListResult(d->ctx, Error(d->lasterr));

}

Key Context::key(const char *fingerprint, GpgME::Error &e , bool secret /*, bool forceUpdate*/)

{

    d->lastop = Private::KeyList;

    gpgme_key_t key;

    e = Error(d->lasterr = gpgme_get_key(d->ctx, fingerprint, &key, int(secret)/*, int( forceUpdate )*/));

    return Key(key, false);

}

KeyGenerationResult Context::generateKey(const char *parameters, Data &pubKey)

{

    d->lastop = Private::KeyGen;

    Data::Private *const dp = pubKey.impl();

    d->lasterr = gpgme_op_genkey(d->ctx, parameters, dp ? dp->data : 0, 0);

    return KeyGenerationResult(d->ctx, Error(d->lasterr));

}

Error Context::startKeyGeneration(const char *parameters, Data &pubKey)

{

    d->lastop = Private::KeyGen;

    Data::Private *const dp = pubKey.impl();

    return Error(d->lasterr = gpgme_op_genkey_start(d->ctx, parameters, dp ? dp->data : 0, 0));

}

KeyGenerationResult Context::keyGenerationResult() const

{

    if (d->lastop & Private::KeyGen) {

        return KeyGenerationResult(d->ctx, Error(d->lasterr));

    } else {

        return KeyGenerationResult();

    }

}

Error Context::exportPublicKeys(const char *pattern, Data &keyData)

{

    d->lastop = Private::Export;

    Data::Private *const dp = keyData.impl();

    return Error(d->lasterr = gpgme_op_export(d->ctx, pattern, 0, dp ? dp->data : 0));

}

Error Context::exportPublicKeys(const char *patterns[], Data &keyData)

{

    d->lastop = Private::Export;

#ifndef HAVE_GPGME_EXT_KEYLIST_MODE_EXTERNAL_NONBROKEN

    if (!patterns || !patterns[0] || !patterns[1]) {

        // max. one pattern -> use the non-ext version

        return exportPublicKeys(patterns ? patterns[0] : 0, keyData);

    }

#endif

    Data::Private *const dp = keyData.impl();

    return Error(d->lasterr = gpgme_op_export_ext(d->ctx, patterns, 0, dp ? dp->data : 0));

}

Error Context::startPublicKeyExport(const char *pattern, Data &keyData)

{

    d->lastop = Private::Export;

    Data::Private *const dp = keyData.impl();

    return Error(d->lasterr = gpgme_op_export_start(d->ctx, pattern, 0, dp ? dp->data : 0));

}

Error Context::startPublicKeyExport(const char *patterns[], Data &keyData)

{

    d->lastop = Private::Export;

#ifndef HAVE_GPGME_EXT_KEYLIST_MODE_EXTERNAL_NONBROKEN

    if (!patterns || !patterns[0] || !patterns[1]) {

        // max. one pattern -> use the non-ext version

        return startPublicKeyExport(patterns ? patterns[0] : 0, keyData);

    }

#endif

    Data::Private *const dp = keyData.impl();

    return Error(d->lasterr = gpgme_op_export_ext_start(d->ctx, patterns, 0, dp ? dp->data : 0));

}

ImportResult Context::importKeys(const Data &data)

{

    d->lastop = Private::Import;

    const Data::Private *const dp = data.impl();

    d->lasterr = gpgme_op_import(d->ctx, dp ? dp->data : 0);

    return ImportResult(d->ctx, Error(d->lasterr));

}

ImportResult Context::importKeys(const std::vector<Key> &kk)

{

    d->lastop = Private::Import;

    d->lasterr = make_error(GPG_ERR_NOT_IMPLEMENTED);

    bool shouldHaveResult = false;

    gpgme_key_t * const keys = new gpgme_key_t[ kk.size() + 1 ];

    gpgme_key_t *keys_it = &keys[0];

    for (std::vector<Key>::const_iterator it = kk.begin(), end = kk.end() ; it != end ; ++it) {

        if (it->impl()) {

            *keys_it++ = it->impl();

        }

    }

    *keys_it++ = 0;

    d->lasterr = gpgme_op_import_keys(d->ctx, keys);

    shouldHaveResult = true;

    if ((gpgme_err_code(d->lasterr) == GPG_ERR_NOT_IMPLEMENTED ||

            gpgme_err_code(d->lasterr) == GPG_ERR_NOT_SUPPORTED) &&

            protocol() == CMS) {

        // ok, try the workaround (export+import):

        std::vector<const char *> fprs;

        for (std::vector<Key>::const_iterator it = kk.begin(), end = kk.end() ; it != end ; ++it) {

            if (const char *fpr = it->primaryFingerprint()) {

                if (*fpr) {

                    fprs.push_back(fpr);

                }

            } else if (const char *keyid = it->keyID()) {

                if (*keyid) {

                    fprs.push_back(keyid);

                }

            }

        }

        fprs.push_back(0);

        Data data;

        Data::Private *const dp = data.impl();

        const gpgme_keylist_mode_t oldMode = gpgme_get_keylist_mode(d->ctx);

        gpgme_set_keylist_mode(d->ctx, GPGME_KEYLIST_MODE_EXTERN);

        d->lasterr = gpgme_op_export_ext(d->ctx, &fprs[0], 0, dp ? dp->data : 0);

        gpgme_set_keylist_mode(d->ctx, oldMode);

        if (!d->lasterr) {

            data.seek(0, SEEK_SET);

            d->lasterr = gpgme_op_import(d->ctx, dp ? dp->data : 0);

            shouldHaveResult = true;

        }

    }

    delete[] keys;

    if (shouldHaveResult) {

        return ImportResult(d->ctx, Error(d->lasterr));

    } else {

        return ImportResult(Error(d->lasterr));

    }

}

Error Context::startKeyImport(const Data &data)

{

    d->lastop = Private::Import;

    const Data::Private *const dp = data.impl();

    return Error(d->lasterr = gpgme_op_import_start(d->ctx, dp ? dp->data : 0));

}

Error Context::startKeyImport(const std::vector<Key> &kk)

{

    d->lastop = Private::Import;

    gpgme_key_t * const keys = new gpgme_key_t[ kk.size() + 1 ];

    gpgme_key_t *keys_it = &keys[0];

    for (std::vector<Key>::const_iterator it = kk.begin(), end = kk.end() ; it != end ; ++it) {

        if (it->impl()) {

            *keys_it++ = it->impl();

        }

    }

    *keys_it++ = 0;

    Error err = Error(d->lasterr = gpgme_op_import_keys_start(d->ctx, keys));

    delete[] keys;

    return err;

}

ImportResult Context::importResult() const

{

    if (d->lastop & Private::Import) {

        return ImportResult(d->ctx, Error(d->lasterr));

    } else {

        return ImportResult();

    }

}

Error Context::deleteKey(const Key &key, bool allowSecretKeyDeletion)

{

    d->lastop = Private::Delete;

    return Error(d->lasterr = gpgme_op_delete(d->ctx, key.impl(), int(allowSecretKeyDeletion)));

}

Error Context::startKeyDeletion(const Key &key, bool allowSecretKeyDeletion)

{

    d->lastop = Private::Delete;

    return Error(d->lasterr = gpgme_op_delete_start(d->ctx, key.impl(), int(allowSecretKeyDeletion)));

}

Error Context::passwd(const Key &key)

{

    d->lastop = Private::Passwd;

    return Error(d->lasterr = gpgme_op_passwd(d->ctx, key.impl(), 0U));

}

Error Context::startPasswd(const Key &key)

{

    d->lastop = Private::Passwd;

    return Error(d->lasterr = gpgme_op_passwd_start(d->ctx, key.impl(), 0U));

}

#pragma GCC diagnostic push

#pragma GCC diagnostic ignored "-Wdeprecated-declarations"

Error Context::edit(const Key &key, std::unique_ptr<EditInteractor> func, Data &data)

{

    d->lastop = Private::Edit;

    d->lastEditInteractor = std::move(func);

    Data::Private *const dp = data.impl();

    return Error(d->lasterr = gpgme_op_edit(d->ctx, key.impl(),

                                            d->lastEditInteractor.get() ? edit_interactor_callback : 0,

                                            d->lastEditInteractor.get() ? d->lastEditInteractor->d : 0,

                                            dp ? dp->data : 0));

}

Error Context::startEditing(const Key &key, std::unique_ptr<EditInteractor> func, Data &data)

{

    d->lastop = Private::Edit;

    d->lastEditInteractor = std::move(func);

    Data::Private *const dp = data.impl();

    return Error(d->lasterr = gpgme_op_edit_start(d->ctx, key.impl(),

                              d->lastEditInteractor.get() ? edit_interactor_callback : 0,

                              d->lastEditInteractor.get() ? d->lastEditInteractor->d : 0,

                              dp ? dp->data : 0));

}

EditInteractor *Context::lastEditInteractor() const

{

    return d->lastEditInteractor.get();

}

std::unique_ptr<EditInteractor> Context::takeLastEditInteractor()

{

    return std::move(d->lastEditInteractor);

}

Error Context::cardEdit(const Key &key, std::unique_ptr<EditInteractor> func, Data &data)

{

    d->lastop = Private::CardEdit;

    d->lastCardEditInteractor = std::move(func);

    Data::Private *const dp = data.impl();

    return Error(d->lasterr = gpgme_op_card_edit(d->ctx, key.impl(),

                              d->lastCardEditInteractor.get() ? edit_interactor_callback : 0,

                              d->lastCardEditInteractor.get() ? d->lastCardEditInteractor->d : 0,

                              dp ? dp->data : 0));

}

Error Context::startCardEditing(const Key &key, std::unique_ptr<EditInteractor> func, Data &data)

{

    d->lastop = Private::CardEdit;

    d->lastCardEditInteractor = std::move(func);

    Data::Private *const dp = data.impl();

    return Error(d->lasterr = gpgme_op_card_edit_start(d->ctx, key.impl(),

                              d->lastCardEditInteractor.get() ? edit_interactor_callback : 0,

                              d->lastCardEditInteractor.get() ? d->lastCardEditInteractor->d : 0,

                              dp ? dp->data : 0));

}

#pragma GCC diagnostic pop

EditInteractor *Context::lastCardEditInteractor() const

{

    return d->lastCardEditInteractor.get();

}

std::unique_ptr<EditInteractor> Context::takeLastCardEditInteractor()

{

    return std::move(d->lastCardEditInteractor);

}

Error Context::startTrustItemListing(const char *pattern, int maxLevel)

{

    d->lastop = Private::TrustList;

    return Error(d->lasterr = gpgme_op_trustlist_start(d->ctx, pattern, maxLevel));

}

TrustItem Context::nextTrustItem(Error &e)

{

    gpgme_trust_item_t ti = 0;

    e = Error(d->lasterr = gpgme_op_trustlist_next(d->ctx, &ti);;

    return TrustItem(ti);

}

Error Context::endTrustItemListing()

{

    return Error(d->lasterr = gpgme_op_trustlist_end(d->ctx));

}

static gpgme_error_t assuan_transaction_data_callback(void *opaque, const void *data, size_t datalen)

{

    assert(opaque);

    AssuanTransaction *t = static_cast<AssuanTransaction *>(opaque);

    return t->data(static_cast<const char *>(data), datalen).encodedError();

}

static gpgme_error_t assuan_transaction_inquire_callback(void *opaque, const char *name, const char *args, gpgme_data_t *r_data)

{

    assert(opaque);

    Context::Private *p = static_cast<Context::Private *>(opaque);

    AssuanTransaction *t = p->lastAssuanTransaction.get();

    assert(t);

    Error err;

    if (name) {

        p->lastAssuanInquireData = t->inquire(name, args, err);

    } else {

        p->lastAssuanInquireData = Data::null;

    }

    if (!p->lastAssuanInquireData.isNull()) {

        *r_data = p->lastAssuanInquireData.impl()->data;

    }

    return err.encodedError();

}

static gpgme_error_t assuan_transaction_status_callback(void *opaque, const char *status, const char *args)

{

    assert(opaque);

    AssuanTransaction *t = static_cast<AssuanTransaction *>(opaque);

    std::string a = args;

    percent_unescape(a, true);   // ### why doesn't gpgme do this??

    return t->status(status, a.c_str()).encodedError();

}

Error Context::assuanTransact(const char *command)

{

    return assuanTransact(command, std::unique_ptr<AssuanTransaction>(new DefaultAssuanTransaction));

}

Error Context::assuanTransact(const char *command, std::unique_ptr<AssuanTransaction> transaction)

{

    gpgme_error_t err, operr;

    d->lastop = Private::AssuanTransact;

    d->lastAssuanTransaction = std::move(transaction);

    if (!d->lastAssuanTransaction.get()) {

        return Error(d->lasterr = make_error(GPG_ERR_INV_ARG));

    }

    err = gpgme_op_assuan_transact_ext

      (d->ctx,

       command,

       assuan_transaction_data_callback,

       d->lastAssuanTransaction.get(),

       assuan_transaction_inquire_callback,

       d,

       assuan_transaction_status_callback,

       d->lastAssuanTransaction.get(),

       &operr;;

    if (!err)

      err = operr;

    d->lasterr = err;

    return Error(d->lasterr);

}

Error Context::startAssuanTransaction(const char *command)

{

    return startAssuanTransaction(command, std::unique_ptr<AssuanTransaction>(new DefaultAssuanTransaction));

}