work on DB logic for FIXME in taler-exchange-aggregator: refactoring exchange logic a bit

5 files changed, 507 insertions, 419 deletions

diff --git a/src/exchange/taler-exchange-httpd_common_kyc.c b/src/exchange/taler-exchange-httpd_common_kyc.c
index eaf7fc1c1..13454d35a 100644
--- a/src/exchange/taler-exchange-httpd_common_kyc.c
+++ b/src/exchange/taler-exchange-httpd_common_kyc.c
@@ -180,78 +180,20 @@ kyc_aml_finished (
 {
   struct TEH_KycMeasureRunContext *kat = cls;
   enum GNUNET_DB_QueryStatus qs;
-  size_t eas = 0;
-  void *ea = NULL;
   unsigned int birthday = 0;
   struct GNUNET_AsyncScopeSave old_scope;
 
   kat->kyc_aml = NULL;
   GNUNET_async_scope_enter (&kat->scope,
                             &old_scope);
-  if (TALER_KYCLOGIC_AMLR_SUCCESS != apr->status)
-  {
-    if (! TEH_kyc_failed (
-          kat->process_row,
-          &kat->account_id,
-          kat->provider_name,
-          kat->provider_user_id,
-          kat->provider_legitimization_id,
-          apr->details.failure.error_message,
-          apr->details.failure.ec))
-    {
-      /* double-bad: error during error handling */
-      GNUNET_break (0);
-      kat->cb (kat->cb_cls,
-               TALER_EC_GENERIC_DB_STORE_FAILED,
-               "insert_kyc_failure");
-      TEH_kyc_run_measure_cancel (kat);
-      GNUNET_async_scope_restore (&old_scope);
-      return;
-    }
-    if (NULL == apr->details.failure.fallback_measure)
-    {
-      /* Not sure this can happen (fallback required?),
-         but report AML program failure to client */
-      kat->cb (kat->cb_cls,
-               TALER_EC_EXCHANGE_KYC_AML_PROGRAM_FAILURE,
-               NULL);
-      TEH_kyc_run_measure_cancel (kat);
-      GNUNET_async_scope_restore (&old_scope);
-      return;
-    }
-    kat->fallback_name
-      = GNUNET_strdup (
-          apr->details.failure.fallback_measure);
-    kat->fb
-      = TEH_kyc_fallback (
-          &kat->scope,
-          &kat->account_id,
-          kat->process_row,
-          kat->attributes,
-          kat->fallback_name,
-          &fallback_result_cb,
-          kat);
-    if (NULL == kat->fb)
-    {
-      GNUNET_break (0);
-      kat->cb (kat->cb_cls,
-               TALER_EC_EXCHANGE_GENERIC_KYC_FALLBACK_UNKNOWN,
-               kat->fallback_name);
-      TEH_kyc_run_measure_cancel (kat);
-      GNUNET_async_scope_restore (&old_scope);
-      return;
-    }
-    GNUNET_async_scope_restore (&old_scope);
-    return;
-  }
+  if (TEH_age_restriction_enabled)
   {
     const char *birthdate;
 
     birthdate = json_string_value (
       json_object_get (kat->attributes,
                        TALER_ATTRIBUTE_BIRTHDATE));
-    if ( (TEH_age_restriction_enabled) &&
-         (NULL != birthdate) )
+    if (NULL != birthdate)
     {
       enum GNUNET_GenericReturnValue ret;
 
@@ -261,63 +203,83 @@ kyc_aml_finished (
 
       if (GNUNET_OK != ret)
       {
-        GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+        GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                     "Failed to parse birthdate `%s' from KYC attributes\n",
                     birthdate);
-        kat->cb (kat->cb_cls,
-                 TALER_EC_GENERIC_PARAMETER_MALFORMED,
-                 "TALER_ATTRIBUTE_BIRTHDATE");
-        goto done;
       }
     }
   }
 
-  if (NULL != kat->attributes)
-  {
-    TALER_CRYPTO_kyc_attributes_encrypt (&TEH_attribute_key,
-                                         kat->attributes,
-                                         &ea,
-                                         &eas);
-  }
-
-  qs = TEH_plugin->insert_kyc_measure_result (
-    TEH_plugin->cls,
+  qs = TALER_EXCHANGEDB_persist_aml_program_result (
+    TEH_plugin,
     kat->process_row,
-    &kat->account_id,
-    birthday,
-    GNUNET_TIME_timestamp_get (),
     kat->provider_name,
     kat->provider_user_id,
     kat->provider_legitimization_id,
+    kat->attributes,
+    &TEH_attribute_key,
+    birthday,
     kat->expiration,
-    apr->details.success.account_properties,
-    apr->details.success.new_rules,
-    apr->details.success.to_investigate,
-    apr->details.success.num_events,
-    apr->details.success.events,
-    eas,
-    ea);
-  GNUNET_free (ea);
-  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
-              "Stored encrypted KYC process #%llu attributes: %d\n",
-              (unsigned long long) kat->process_row,
-              qs);
-  if (qs < 0)
+    &kat->account_id,
+    apr);
+  switch (qs)
   {
+  case GNUNET_DB_STATUS_HARD_ERROR:
+  case GNUNET_DB_STATUS_SOFT_ERROR:
+  case GNUNET_DB_STATUS_SUCCESS_NO_RESULTS:
+    /* double-bad: error during error handling */
     GNUNET_break (0);
     kat->cb (kat->cb_cls,
              TALER_EC_GENERIC_DB_STORE_FAILED,
-             "do_insert_kyc_measure_result");
-    /* Continued below to clean up. */
+             "persist_aml_program_result");
+    TEH_kyc_run_measure_cancel (kat);
+    GNUNET_async_scope_restore (&old_scope);
+    return;
+  case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT:
+    break;
   }
-  else
+  switch (apr->status)
   {
+  case TALER_KYCLOGIC_AMLR_FAILURE:
+    if (NULL == apr->details.failure.fallback_measure)
+    {
+      /* Not sure this can happen (fallback required?),
+         but report AML program failure to client */
+      kat->cb (kat->cb_cls,
+               TALER_EC_EXCHANGE_KYC_AML_PROGRAM_FAILURE,
+               NULL);
+      break;
+    }
+    kat->fallback_name
+      = GNUNET_strdup (
+          apr->details.failure.fallback_measure);
+    kat->fb
+      = TEH_kyc_fallback (
+          &kat->scope,
+          &kat->account_id,
+          kat->process_row,
+          kat->attributes,
+          kat->fallback_name,
+          &fallback_result_cb,
+          kat);
+    if (NULL == kat->fb)
+    {
+      GNUNET_break (0);
+      kat->cb (kat->cb_cls,
+               TALER_EC_EXCHANGE_GENERIC_KYC_FALLBACK_UNKNOWN,
+               kat->fallback_name);
+      break;
+    }
+    /* continued in fallback_result_cb */
+    GNUNET_async_scope_restore (&old_scope);
+    return;
+  case TALER_KYCLOGIC_AMLR_SUCCESS:
     /* Finally, return result to main handler */
     kat->cb (kat->cb_cls,
              TALER_EC_NONE,
              0);
+    break;
   }
-done:
   TEH_kyc_run_measure_cancel (kat);
   GNUNET_async_scope_restore (&old_scope);
 }
diff --git a/src/exchangedb/Makefile.am b/src/exchangedb/Makefile.am
index a6c8be7c0..5017b5e78 100644
--- a/src/exchangedb/Makefile.am
+++ b/src/exchangedb/Makefile.am
@@ -340,6 +340,7 @@ lib_LTLIBRARIES = \
 
 libtalerexchangedb_la_SOURCES = \
   exchangedb_accounts.c \
+  exchangedb_aml.c \
   exchangedb_history.c \
   exchangedb_plugin.c \
   exchangedb_transactions.c
diff --git a/src/exchangedb/exchangedb_aml.c b/src/exchangedb/exchangedb_aml.c
new file mode 100644
index 000000000..c709ce1be
--- /dev/null
+++ b/src/exchangedb/exchangedb_aml.c
@@ -0,0 +1,96 @@
+/*
+  This file is part of TALER
+  Copyright (C) 2023, 2024 Taler Systems SA
+
+  TALER is free software; you can redistribute it and/or modify it under the
+  terms of the GNU Affero General Public License as published by the Free Software
+  Foundation; either version 3, or (at your option) any later version.
+
+  TALER 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 Affero General Public License for more details.
+
+  You should have received a copy of the GNU Affero General Public License along with
+  TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
+*/
+/**
+ * @file exchangedb_aml.c
+ * @brief helper function to handle AML programs
+ * @author Christian Grothoff
+ */
+#include "taler_exchangedb_plugin.h"
+#include "taler_exchangedb_lib.h"
+#include "taler_kyclogic_lib.h"
+#include "taler_json_lib.h"
+#include <gnunet/gnunet_common.h>
+
+
+enum GNUNET_DB_QueryStatus
+TALER_EXCHANGEDB_persist_aml_program_result (
+  struct TALER_EXCHANGEDB_Plugin *plugin,
+  uint64_t process_row,
+  const char *provider_name,
+  const char *provider_user_id,
+  const char *provider_legitimization_id,
+  const json_t *attributes,
+  const struct TALER_AttributeEncryptionKeyP *attribute_key,
+  unsigned int birthday,
+  struct GNUNET_TIME_Absolute expiration,
+  const struct TALER_NormalizedPaytoHashP *account_id,
+  const struct TALER_KYCLOGIC_AmlProgramResult *apr)
+{
+  enum GNUNET_DB_QueryStatus qs;
+  size_t eas = 0;
+  void *ea = NULL;
+
+  /* TODO: also clear lock on AML program (#9303) */
+  switch (apr->status)
+  {
+  case TALER_KYCLOGIC_AMLR_FAILURE:
+    qs = plugin->insert_kyc_failure (
+      plugin->cls,
+      process_row,
+      account_id,
+      provider_name,
+      provider_user_id,
+      provider_legitimization_id,
+      apr->details.failure.error_message,
+      apr->details.failure.ec);
+    GNUNET_break (qs > 0);
+    return qs;
+  case TALER_KYCLOGIC_AMLR_SUCCESS:
+    if (NULL != attributes)
+    {
+      TALER_CRYPTO_kyc_attributes_encrypt (attribute_key,
+                                           attributes,
+                                           &ea,
+                                           &eas);
+    }
+    qs = plugin->insert_kyc_measure_result (
+      plugin->cls,
+    process_row,
+    account_id,
+    birthday,
+    GNUNET_TIME_timestamp_get (),
+    provider_name,
+    provider_user_id,
+    provider_legitimization_id,
+    expiration,
+    apr->details.success.account_properties,
+    apr->details.success.new_rules,
+    apr->details.success.to_investigate,
+    apr->details.success.num_events,
+    apr->details.success.events,
+    eas,
+    ea);
+    GNUNET_free (ea);
+    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+                "Stored encrypted KYC process #%llu attributes: %d\n",
+                (unsigned long long) process_row,
+                qs);
+    GNUNET_break (qs > 0);
+    return qs;
+  }
+  GNUNET_assert (0);
+  return GNUNET_DB_STATUS_HARD_ERROR;
+}
diff --git a/src/include/taler_exchangedb_lib.h b/src/include/taler_exchangedb_lib.h
index e5644fa63..77f48b482 100644
--- a/src/include/taler_exchangedb_lib.h
+++ b/src/include/taler_exchangedb_lib.h
@@ -26,6 +26,7 @@
 #include "taler_signatures.h"
 #include "taler_exchangedb_plugin.h"
 #include "taler_bank_service.h"
+#include "taler_kyclogic_lib.h"
 
 
 /**
@@ -258,4 +259,32 @@ json_t *
 TALER_EXCHANGEDB_current_rule_builder (void *cls);
 
 
+/**
+ * Persist the given @a apr for the given process and account
+ * into the database via @a plugin.
+ *
+ * @param plugin database API handle
+ * @param process_row row identifying the AML process that was run
+ * @param provider_name name of the provider that provided the attributes
+ * @param provider_user_id set to user ID at the provider, or NULL if not supported or unknown
+ * @param provider_legitimization_id set to legitimization process ID at the provider, or NULL if not supported or unknown
+ * @param expiration until when is the KYC check valid
+ * @param account_id hash of account the result is about
+ * @param apr AML program result to persist
+ */
+enum GNUNET_DB_QueryStatus
+TALER_EXCHANGEDB_persist_aml_program_result (
+  struct TALER_EXCHANGEDB_Plugin *plugin,
+  uint64_t process_row,
+  const char *provider_name,
+  const char *provider_user_id,
+  const char *provider_legitimization_id,
+  const json_t *attributes,
+  const struct TALER_AttributeEncryptionKeyP *attribute_key,
+  unsigned int birthday,
+  struct GNUNET_TIME_Absolute expiration,
+  const struct TALER_NormalizedPaytoHashP *account_id,
+  const struct TALER_KYCLOGIC_AmlProgramResult *apr);
+
+
 #endif
diff --git a/src/include/taler_exchangedb_plugin.h b/src/include/taler_exchangedb_plugin.h
index 3b155dab7..072545f5b 100644
--- a/src/include/taler_exchangedb_plugin.h
+++ b/src/include/taler_exchangedb_plugin.h
@@ -3696,7 +3696,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return #GNUNET_OK upon success; #GNUNET_SYSERR upon failure
    */
   enum GNUNET_GenericReturnValue
-    (*drop_tables)(void *cls);
+  (*drop_tables)(void *cls);
 
   /**
    * Create the necessary tables if they are not present
@@ -3709,9 +3709,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return #GNUNET_OK upon success; #GNUNET_SYSERR upon failure
    */
   enum GNUNET_GenericReturnValue
-    (*create_tables)(void *cls,
-                     bool support_partitions,
-                     uint32_t num_partitions);
+  (*create_tables)(void *cls,
+                   bool support_partitions,
+                   uint32_t num_partitions);
 
 
   /**
@@ -3723,8 +3723,8 @@ struct TALER_EXCHANGEDB_Plugin
    * @return #GNUNET_OK on success
    */
   enum GNUNET_GenericReturnValue
-    (*start)(void *cls,
-             const char *name);
+  (*start)(void *cls,
+           const char *name);
 
 
   /**
@@ -3736,8 +3736,8 @@ struct TALER_EXCHANGEDB_Plugin
    * @return #GNUNET_OK on success
    */
   enum GNUNET_GenericReturnValue
-    (*start_read_committed)(void *cls,
-                            const char *name);
+  (*start_read_committed)(void *cls,
+                          const char *name);
 
   /**
    * Start a READ ONLY serializable transaction.
@@ -3748,8 +3748,8 @@ struct TALER_EXCHANGEDB_Plugin
    * @return #GNUNET_OK on success
    */
   enum GNUNET_GenericReturnValue
-    (*start_read_only)(void *cls,
-                       const char *name);
+  (*start_read_only)(void *cls,
+                     const char *name);
 
 
   /**
@@ -3759,7 +3759,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*commit)(void *cls);
+  (*commit)(void *cls);
 
 
   /**
@@ -3773,7 +3773,7 @@ struct TALER_EXCHANGEDB_Plugin
    *         #GNUNET_SYSERR on hard errors
    */
   enum GNUNET_GenericReturnValue
-    (*preflight)(void *cls);
+  (*preflight)(void *cls);
 
 
   /**
@@ -3840,7 +3840,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return status of the query
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_denomination_info)(
+  (*insert_denomination_info)(
     void *cls,
     const struct TALER_DenominationPublicKey *denom_pub,
     const struct TALER_EXCHANGEDB_DenominationKeyInformation *issue);
@@ -3855,7 +3855,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_denomination_info)(
+  (*get_denomination_info)(
     void *cls,
     const struct TALER_DenominationHashP *denom_pub_hash,
     struct TALER_EXCHANGEDB_DenominationKeyInformation *issue);
@@ -3873,9 +3873,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*iterate_denomination_info)(void *cls,
-                                 TALER_EXCHANGEDB_DenominationCallback cb,
-                                 void *cb_cls);
+  (*iterate_denomination_info)(void *cls,
+                               TALER_EXCHANGEDB_DenominationCallback cb,
+                               void *cb_cls);
 
 
   /**
@@ -3889,9 +3889,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*iterate_denominations)(void *cls,
-                             TALER_EXCHANGEDB_DenominationsCallback cb,
-                             void *cb_cls);
+  (*iterate_denominations)(void *cls,
+                           TALER_EXCHANGEDB_DenominationsCallback cb,
+                           void *cb_cls);
 
   /**
    * Function called to invoke @a cb on every non-revoked exchange signing key
@@ -3904,9 +3904,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*iterate_active_signkeys)(void *cls,
-                               TALER_EXCHANGEDB_ActiveSignkeysCallback cb,
-                               void *cb_cls);
+  (*iterate_active_signkeys)(void *cls,
+                             TALER_EXCHANGEDB_ActiveSignkeysCallback cb,
+                             void *cb_cls);
 
 
   /**
@@ -3919,9 +3919,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*iterate_active_auditors)(void *cls,
-                               TALER_EXCHANGEDB_AuditorsCallback cb,
-                               void *cb_cls);
+  (*iterate_active_auditors)(void *cls,
+                             TALER_EXCHANGEDB_AuditorsCallback cb,
+                             void *cb_cls);
 
 
   /**
@@ -3935,7 +3935,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*iterate_auditor_denominations)(
+  (*iterate_auditor_denominations)(
     void *cls,
     TALER_EXCHANGEDB_AuditorDenominationsCallback cb,
     void *cb_cls);
@@ -3951,8 +3951,8 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*reserves_get)(void *cls,
-                    struct TALER_EXCHANGEDB_Reserve *reserve);
+  (*reserves_get)(void *cls,
+                  struct TALER_EXCHANGEDB_Reserve *reserve);
 
 
   /**
@@ -3965,7 +3965,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*reserves_get_origin)(
+  (*reserves_get_origin)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     struct TALER_FullPaytoHashP *h_payto,
@@ -3981,9 +3981,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*drain_kyc_alert)(void *cls,
-                       uint32_t trigger_type,
-                       struct TALER_NormalizedPaytoHashP *h_payto);
+  (*drain_kyc_alert)(void *cls,
+                     uint32_t trigger_type,
+                     struct TALER_NormalizedPaytoHashP *h_payto);
 
 
   /**
@@ -3997,7 +3997,7 @@ struct TALER_EXCHANGEDB_Plugin
    *             set to the status of the
    */
   enum GNUNET_DB_QueryStatus
-    (*reserves_in_insert)(
+  (*reserves_in_insert)(
     void *cls,
     const struct TALER_EXCHANGEDB_ReserveInInfo *reserves,
     unsigned int reserves_length,
@@ -4018,7 +4018,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @param serial_id bank-specific row identifying the transfer
    */
   enum GNUNET_DB_QueryStatus
-    (*kycauth_in_insert)(
+  (*kycauth_in_insert)(
     void *cls,
     const union TALER_AccountPublicKeyP *account_pub,
     const struct TALER_Amount *credit_amount,
@@ -4041,7 +4041,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @param serial_id bank-specific row identifying the transfer
    */
   enum GNUNET_DB_QueryStatus
-    (*wad_in_insert)(
+  (*wad_in_insert)(
     void *cls,
     const struct TALER_WadIdentifierP *wad_id,
     const char *origin_exchange_url,
@@ -4062,10 +4062,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return statement execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*lock_nonce)(void *cls,
-                  const struct GNUNET_CRYPTO_CsSessionNonce *nonce,
-                  const struct TALER_DenominationHashP *denom_pub_hash,
-                  const union TALER_EXCHANGEDB_NonceLockTargetP *target);
+  (*lock_nonce)(void *cls,
+                const struct GNUNET_CRYPTO_CsSessionNonce *nonce,
+                const struct TALER_DenominationHashP *denom_pub_hash,
+                const union TALER_EXCHANGEDB_NonceLockTargetP *target);
 
 
   /**
@@ -4080,10 +4080,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return statement execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_withdraw_info)(void *cls,
-                         const struct TALER_BlindedCoinHashP *bch,
-                         struct TALER_EXCHANGEDB_CollectableBlindcoin *
-                         collectable);
+  (*get_withdraw_info)(void *cls,
+                       const struct TALER_BlindedCoinHashP *bch,
+                       struct TALER_EXCHANGEDB_CollectableBlindcoin *
+                       collectable);
 
 
   /**
@@ -4114,7 +4114,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*do_batch_withdraw)(
+  (*do_batch_withdraw)(
     void *cls,
     struct GNUNET_TIME_Timestamp now,
     const struct TALER_ReservePublicKeyP *reserve_pub,
@@ -4143,7 +4143,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*do_batch_withdraw_insert)(
+  (*do_batch_withdraw_insert)(
     void *cls,
     const union GNUNET_CRYPTO_BlindSessionNonce *nonce,
     const struct TALER_EXCHANGEDB_CollectableBlindcoin *collectable,
@@ -4165,7 +4165,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return statement execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_age_withdraw)(
+  (*get_age_withdraw)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     const struct TALER_AgeWithdrawCommitmentHashP *ach,
@@ -4187,7 +4187,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*do_age_withdraw)(
+  (*do_age_withdraw)(
     void *cls,
     const struct TALER_EXCHANGEDB_AgeWithdraw *commitment,
     struct GNUNET_TIME_Timestamp now,
@@ -4208,7 +4208,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_policy_details)(
+  (*get_policy_details)(
     void *cls,
     const struct GNUNET_HashCode *hc,
     struct TALER_PolicyDetails *detail);
@@ -4226,7 +4226,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*persist_policy_details)(
+  (*persist_policy_details)(
     void *cls,
     const struct TALER_PolicyDetails *details,
     uint64_t *policy_details_serial_id,
@@ -4248,7 +4248,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*do_deposit)(
+  (*do_deposit)(
     void *cls,
     const struct TALER_EXCHANGEDB_BatchDeposit *bd,
     struct GNUNET_TIME_Timestamp *exchange_timestamp,
@@ -4267,7 +4267,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*do_check_deposit_idempotent)(
+  (*do_check_deposit_idempotent)(
     void *cls,
     const struct TALER_EXCHANGEDB_BatchDeposit *bd,
     struct GNUNET_TIME_Timestamp *exchange_timestamp,
@@ -4288,7 +4288,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*do_melt)(
+  (*do_melt)(
     void *cls,
     const struct TALER_RefreshMasterSecretP *rms,
     struct TALER_EXCHANGEDB_Refresh *refresh,
@@ -4305,7 +4305,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*add_policy_fulfillment_proof)(
+  (*add_policy_fulfillment_proof)(
     void *cls,
     struct TALER_PolicyFulfillmentTransactionData *fulfillment);
 
@@ -4324,7 +4324,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*cs_refreshes_reveal)(
+  (*cs_refreshes_reveal)(
     void *cls,
     const struct GNUNET_CRYPTO_CsSessionNonce *nonce,
     const struct TALER_CoinSpendPublicKeyP *old_coin_pub,
@@ -4347,7 +4347,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*do_refund)(
+  (*do_refund)(
     void *cls,
     const struct TALER_EXCHANGEDB_Refund *refund,
     const struct TALER_Amount *deposit_fee,
@@ -4375,7 +4375,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*do_recoup)(
+  (*do_recoup)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     uint64_t reserve_out_serial_id,
@@ -4405,7 +4405,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*do_recoup_refresh)(
+  (*do_recoup_refresh)(
     void *cls,
     const struct TALER_CoinSpendPublicKeyP *old_coin_pub,
     uint64_t rrc_serial,
@@ -4436,7 +4436,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_reserve_history)(
+  (*get_reserve_history)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     uint64_t start_off,
@@ -4457,7 +4457,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_reserve_balance)(
+  (*get_reserve_balance)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     struct TALER_Amount *balance,
@@ -4559,7 +4559,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status, non-negative on success
    */
   enum GNUNET_DB_QueryStatus
-    (*batch_ensure_coin_known)(
+  (*batch_ensure_coin_known)(
     void *cls,
     const struct TALER_CoinPublicInfo *coin,
     struct TALER_EXCHANGEDB_CoinInfo *result,
@@ -4576,9 +4576,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status, non-negative on success
    */
   enum GNUNET_DB_QueryStatus
-    (*get_known_coin)(void *cls,
-                      const struct TALER_CoinSpendPublicKeyP *coin_pub,
-                      struct TALER_CoinPublicInfo *coin_info);
+  (*get_known_coin)(void *cls,
+                    const struct TALER_CoinSpendPublicKeyP *coin_pub,
+                    struct TALER_CoinPublicInfo *coin_info);
 
   /**
    * Retrieve the signature and corresponding denomination for a given @a coin
@@ -4590,7 +4590,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @param[out] denom_sig the signature with the denomination's private key over the coin_pub
    */
   enum GNUNET_DB_QueryStatus
-    (*get_signature_for_known_coin)(
+  (*get_signature_for_known_coin)(
     void *cls,
     const struct TALER_CoinSpendPublicKeyP *coin_pub,
     struct TALER_DenominationPublicKey *denom_pub,
@@ -4606,10 +4606,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_coin_denomination)(void *cls,
-                             const struct TALER_CoinSpendPublicKeyP *coin_pub,
-                             uint64_t *known_coin_id,
-                             struct TALER_DenominationHashP *denom_hash);
+  (*get_coin_denomination)(void *cls,
+                           const struct TALER_CoinSpendPublicKeyP *coin_pub,
+                           uint64_t *known_coin_id,
+                           struct TALER_DenominationHashP *denom_hash);
 
 
   /**
@@ -4624,7 +4624,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @param[out] h_wire hash of the wire details
    */
   enum GNUNET_DB_QueryStatus
-    (*get_wire_hash_for_contract)(
+  (*get_wire_hash_for_contract)(
     void *cls,
     const struct TALER_MerchantPublicKeyP *merchant_pub,
     const struct TALER_PrivateContractHashP *h_contract_terms,
@@ -4648,7 +4648,7 @@ struct TALER_EXCHANGEDB_Plugin
    */
   // FIXME: rename!
   enum GNUNET_DB_QueryStatus
-    (*have_deposit2)(
+  (*have_deposit2)(
     void *cls,
     const struct TALER_PrivateContractHashP *h_contract_terms,
     const struct TALER_MerchantWireHashP *h_wire,
@@ -4668,8 +4668,8 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_refund)(void *cls,
-                     const struct TALER_EXCHANGEDB_Refund *refund);
+  (*insert_refund)(void *cls,
+                   const struct TALER_EXCHANGEDB_Refund *refund);
 
 
   /**
@@ -4684,7 +4684,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
-    (*select_refunds_by_coin)(
+  (*select_refunds_by_coin)(
     void *cls,
     const struct TALER_CoinSpendPublicKeyP *coin_pub,
     const struct TALER_MerchantPublicKeyP *merchant_pub,
@@ -4707,11 +4707,11 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_ready_deposit)(void *cls,
-                         uint64_t start_shard_row,
-                         uint64_t end_shard_row,
-                         struct TALER_MerchantPublicKeyP *merchant_pub,
-                         struct TALER_FullPayto *payto_uri);
+  (*get_ready_deposit)(void *cls,
+                       uint64_t start_shard_row,
+                       uint64_t end_shard_row,
+                       struct TALER_MerchantPublicKeyP *merchant_pub,
+                       struct TALER_FullPayto *payto_uri);
 
 
   /**
@@ -4726,7 +4726,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*aggregate)(
+  (*aggregate)(
     void *cls,
     const struct TALER_FullPaytoHashP *h_payto,
     const struct TALER_MerchantPublicKeyP *merchant_pub,
@@ -4747,7 +4747,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*create_aggregation_transient)(
+  (*create_aggregation_transient)(
     void *cls,
     const struct TALER_FullPaytoHashP *h_payto,
     const char *exchange_account_section,
@@ -4769,7 +4769,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*select_aggregation_transient)(
+  (*select_aggregation_transient)(
     void *cls,
     const struct TALER_FullPaytoHashP *h_payto,
     const struct TALER_MerchantPublicKeyP *merchant_pub,
@@ -4788,7 +4788,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*find_aggregation_transient)(
+  (*find_aggregation_transient)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     TALER_EXCHANGEDB_TransientAggregationCallback cb,
@@ -4807,7 +4807,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*update_aggregation_transient)(
+  (*update_aggregation_transient)(
     void *cls,
     const struct TALER_FullPaytoHashP *h_payto,
     const struct TALER_WireTransferIdentifierRawP *wtid,
@@ -4825,7 +4825,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*delete_aggregation_transient)(
+  (*delete_aggregation_transient)(
     void *cls,
     const struct TALER_FullPaytoHashP *h_payto,
     const struct TALER_WireTransferIdentifierRawP *wtid);
@@ -4843,10 +4843,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_melt)(void *cls,
-                const struct TALER_RefreshCommitmentP *rc,
-                struct TALER_EXCHANGEDB_Melt *melt,
-                uint64_t *melt_serial_id);
+  (*get_melt)(void *cls,
+              const struct TALER_RefreshCommitmentP *rc,
+              struct TALER_EXCHANGEDB_Melt *melt,
+              uint64_t *melt_serial_id);
 
 
   /**
@@ -4864,7 +4864,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query status for the transaction
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_refresh_reveal)(
+  (*insert_refresh_reveal)(
     void *cls,
     uint64_t melt_serial_id,
     uint32_t num_rrcs,
@@ -4885,10 +4885,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_refresh_reveal)(void *cls,
-                          const struct TALER_RefreshCommitmentP *rc,
-                          TALER_EXCHANGEDB_RefreshCallback cb,
-                          void *cb_cls);
+  (*get_refresh_reveal)(void *cls,
+                        const struct TALER_RefreshCommitmentP *rc,
+                        TALER_EXCHANGEDB_RefreshCallback cb,
+                        void *cb_cls);
 
 
   /**
@@ -4904,10 +4904,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return statement execution status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_link_data)(void *cls,
-                     const struct TALER_CoinSpendPublicKeyP *coin_pub,
-                     TALER_EXCHANGEDB_LinkCallback ldc,
-                     void *tdc_cls);
+  (*get_link_data)(void *cls,
+                   const struct TALER_CoinSpendPublicKeyP *coin_pub,
+                   TALER_EXCHANGEDB_LinkCallback ldc,
+                   void *tdc_cls);
 
 
   /**
@@ -4932,7 +4932,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_coin_transactions)(
+  (*get_coin_transactions)(
     void *cls,
     bool begin_transaction,
     const struct TALER_CoinSpendPublicKeyP *coin_pub,
@@ -4967,7 +4967,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query status of the transaction
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_wire_transfer)(
+  (*lookup_wire_transfer)(
     void *cls,
     const struct TALER_WireTransferIdentifierRawP *wtid,
     TALER_EXCHANGEDB_AggregationDataCallback cb,
@@ -4996,7 +4996,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_transfer_by_deposit)(
+  (*lookup_transfer_by_deposit)(
     void *cls,
     const struct TALER_PrivateContractHashP *h_contract_terms,
     const struct TALER_MerchantWireHashP *h_wire,
@@ -5023,7 +5023,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_wire_fee)(
+  (*insert_wire_fee)(
     void *cls,
     const char *wire_method,
     struct GNUNET_TIME_Timestamp start_date,
@@ -5046,7 +5046,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_global_fee)(
+  (*insert_global_fee)(
     void *cls,
     struct GNUNET_TIME_Timestamp start_date,
     struct GNUNET_TIME_Timestamp end_date,
@@ -5070,7 +5070,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query status of the transaction
    */
   enum GNUNET_DB_QueryStatus
-    (*get_wire_fee)(
+  (*get_wire_fee)(
     void *cls,
     const char *type,
     struct GNUNET_TIME_Timestamp date,
@@ -5095,7 +5095,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query status of the transaction
    */
   enum GNUNET_DB_QueryStatus
-    (*get_global_fee)(
+  (*get_global_fee)(
     void *cls,
     struct GNUNET_TIME_Timestamp date,
     struct GNUNET_TIME_Timestamp *start_date,
@@ -5118,7 +5118,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_expired_reserves)(
+  (*get_expired_reserves)(
     void *cls,
     struct GNUNET_TIME_Timestamp now,
     TALER_EXCHANGEDB_ReserveExpiredCallback rec,
@@ -5137,7 +5137,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_unfinished_close_requests)(
+  (*get_unfinished_close_requests)(
     void *cls,
     TALER_EXCHANGEDB_ReserveExpiredCallback rec,
     void *rec_cls);
@@ -5158,7 +5158,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code, 0 if operation is already in the DB
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_reserve_open_deposit)(
+  (*insert_reserve_open_deposit)(
     void *cls,
     const struct TALER_CoinPublicInfo *cpi,
     const struct TALER_CoinSpendSignatureP *coin_sig,
@@ -5188,7 +5188,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*do_reserve_open)(
+  (*do_reserve_open)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     const struct TALER_Amount *total_paid,
@@ -5217,7 +5217,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code, 0 if reserve unknown
    */
   enum GNUNET_DB_QueryStatus
-    (*select_reserve_close_info)(
+  (*select_reserve_close_info)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     struct TALER_Amount *balance,
@@ -5240,7 +5240,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code, 0 if reserve unknown
    */
   enum GNUNET_DB_QueryStatus
-    (*select_reserve_close_request_info)(
+  (*select_reserve_close_request_info)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     uint64_t rowid,
@@ -5263,7 +5263,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code, @a kac aborting with #GNUNET_NO is not an error
    */
   enum GNUNET_DB_QueryStatus
-    (*iterate_reserve_close_info)(
+  (*iterate_reserve_close_info)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     struct GNUNET_TIME_Absolute time_limit,
@@ -5285,7 +5285,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_reserve_closed)(
+  (*insert_reserve_closed)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     struct GNUNET_TIME_Timestamp execution_date,
@@ -5306,10 +5306,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return query status code
    */
   enum GNUNET_DB_QueryStatus
-    (*wire_prepare_data_insert)(void *cls,
-                                const char *type,
-                                const char *buf,
-                                size_t buf_size);
+  (*wire_prepare_data_insert)(void *cls,
+                              const char *type,
+                              const char *buf,
+                              size_t buf_size);
 
 
   /**
@@ -5320,8 +5320,8 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*wire_prepare_data_mark_finished)(void *cls,
-                                       uint64_t rowid);
+  (*wire_prepare_data_mark_finished)(void *cls,
+                                     uint64_t rowid);
 
 
   /**
@@ -5332,8 +5332,8 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*wire_prepare_data_mark_failed)(void *cls,
-                                     uint64_t rowid);
+  (*wire_prepare_data_mark_failed)(void *cls,
+                                   uint64_t rowid);
 
 
   /**
@@ -5348,7 +5348,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*wire_prepare_data_get)(
+  (*wire_prepare_data_get)(
     void *cls,
     uint64_t start_row,
     uint64_t limit,
@@ -5365,7 +5365,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return #GNUNET_OK on success
    */
   enum GNUNET_GenericReturnValue
-    (*start_deferred_wire_out)(void *cls);
+  (*start_deferred_wire_out)(void *cls);
 
 
   /**
@@ -5382,7 +5382,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*store_wire_transfer_out)(
+  (*store_wire_transfer_out)(
     void *cls,
     struct GNUNET_TIME_Timestamp date,
     const struct TALER_WireTransferIdentifierRawP *wtid,
@@ -5400,7 +5400,7 @@ struct TALER_EXCHANGEDB_Plugin
    *         #GNUNET_SYSERR on DB errors
    */
   enum GNUNET_GenericReturnValue
-    (*gc)(void *cls);
+  (*gc)(void *cls);
 
 
   /**
@@ -5414,7 +5414,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_coin_deposits_above_serial_id)(
+  (*select_coin_deposits_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_DepositCallback cb,
@@ -5432,7 +5432,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_purse_requests_above_serial_id)(
+  (*select_purse_requests_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_PurseRequestCallback cb,
@@ -5450,7 +5450,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_purse_deposits_above_serial_id)(
+  (*select_purse_deposits_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_PurseDepositCallback cb,
@@ -5468,7 +5468,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_account_merges_above_serial_id)(
+  (*select_account_merges_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_AccountMergeCallback cb,
@@ -5486,7 +5486,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_purse_merges_above_serial_id)(
+  (*select_purse_merges_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_PurseMergeCallback cb,
@@ -5505,7 +5505,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_purse_decisions_above_serial_id)(
+  (*select_purse_decisions_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     bool refunded,
@@ -5524,7 +5524,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_all_purse_decisions_above_serial_id)(
+  (*select_all_purse_decisions_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_AllPurseDecisionCallback cb,
@@ -5541,7 +5541,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_purse_deposits_by_purse)(
+  (*select_purse_deposits_by_purse)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     TALER_EXCHANGEDB_PurseRefundCoinCallback cb,
@@ -5559,7 +5559,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_refreshes_above_serial_id)(
+  (*select_refreshes_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_RefreshesCallback cb,
@@ -5577,7 +5577,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_refunds_above_serial_id)(
+  (*select_refunds_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_RefundCallback cb,
@@ -5595,7 +5595,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_reserves_in_above_serial_id)(
+  (*select_reserves_in_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_ReserveInCallback cb,
@@ -5614,7 +5614,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_reserves_in_above_serial_id_by_account)(
+  (*select_reserves_in_above_serial_id_by_account)(
     void *cls,
     const char *account_name,
     uint64_t serial_id,
@@ -5634,7 +5634,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_withdrawals_above_serial_id)(
+  (*select_withdrawals_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_WithdrawCallback cb,
@@ -5652,7 +5652,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_wire_out_above_serial_id)(
+  (*select_wire_out_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_WireTransferOutCallback cb,
@@ -5670,7 +5670,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_wire_out_above_serial_id_by_account)(
+  (*select_wire_out_above_serial_id_by_account)(
     void *cls,
     const char *account_name,
     uint64_t serial_id,
@@ -5689,7 +5689,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_recoup_above_serial_id)(
+  (*select_recoup_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_RecoupCallback cb,
@@ -5707,7 +5707,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_recoup_refresh_above_serial_id)(
+  (*select_recoup_refresh_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_RecoupRefreshCallback cb,
@@ -5725,7 +5725,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_reserve_open_above_serial_id)(
+  (*select_reserve_open_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_ReserveOpenCallback cb,
@@ -5743,7 +5743,7 @@ struct TALER_EXCHANGEDB_Plugin
  * @return transaction status code
  */
   enum GNUNET_DB_QueryStatus
-    (*select_reserve_closed_above_serial_id)(
+  (*select_reserve_closed_above_serial_id)(
     void *cls,
     uint64_t serial_id,
     TALER_EXCHANGEDB_ReserveClosedCallback cb,
@@ -5761,7 +5761,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_reserve_by_h_blind)(
+  (*get_reserve_by_h_blind)(
     void *cls,
     const struct TALER_BlindedCoinHashP *bch,
     struct TALER_ReservePublicKeyP *reserve_pub,
@@ -5779,7 +5779,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_old_coin_by_h_blind)(
+  (*get_old_coin_by_h_blind)(
     void *cls,
     const struct TALER_BlindedCoinHashP *h_blind_ev,
     struct TALER_CoinSpendPublicKeyP *old_coin_pub,
@@ -5796,7 +5796,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_denomination_revocation)(
+  (*insert_denomination_revocation)(
     void *cls,
     const struct TALER_DenominationHashP *denom_pub_hash,
     const struct TALER_MasterSignatureP *master_sig);
@@ -5813,7 +5813,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_denomination_revocation)(
+  (*get_denomination_revocation)(
     void *cls,
     const struct TALER_DenominationHashP *denom_pub_hash,
     struct TALER_MasterSignatureP *master_sig,
@@ -5831,7 +5831,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_batch_deposits_missing_wire)(
+  (*select_batch_deposits_missing_wire)(
     void *cls,
     uint64_t min_batch_deposit_serial_id,
     TALER_EXCHANGEDB_WireMissingCallback cb,
@@ -5849,7 +5849,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_aggregations_above_serial)(
+  (*select_aggregations_above_serial)(
     void *cls,
     uint64_t min_tracking_serial_id,
     TALER_EXCHANGEDB_AggregationCallback cb,
@@ -5869,7 +5869,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_justification_for_missing_wire)(
+  (*select_justification_for_missing_wire)(
     void *cls,
     const struct TALER_FullPaytoHashP *wire_target_h_payto,
     struct TALER_FullPayto *payto_uri,
@@ -5886,7 +5886,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_auditor_timestamp)(
+  (*lookup_auditor_timestamp)(
     void *cls,
     const struct TALER_AuditorPublicKeyP *auditor_pub,
     struct GNUNET_TIME_Timestamp *last_date);
@@ -5903,7 +5903,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_auditor_status)(
+  (*lookup_auditor_status)(
     void *cls,
     const struct TALER_AuditorPublicKeyP *auditor_pub,
     char **auditor_url,
@@ -5922,7 +5922,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_auditor)(
+  (*insert_auditor)(
     void *cls,
     const struct TALER_AuditorPublicKeyP *auditor_pub,
     const char *auditor_url,
@@ -5943,7 +5943,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*update_auditor)(
+  (*update_auditor)(
     void *cls,
     const struct TALER_AuditorPublicKeyP *auditor_pub,
     const char *auditor_url,
@@ -5961,9 +5961,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_wire_timestamp)(void *cls,
-                             const struct TALER_FullPayto payto_uri,
-                             struct GNUNET_TIME_Timestamp *last_date);
+  (*lookup_wire_timestamp)(void *cls,
+                           const struct TALER_FullPayto payto_uri,
+                           struct GNUNET_TIME_Timestamp *last_date);
 
 
   /**
@@ -5983,15 +5983,15 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_wire)(void *cls,
-                   const struct TALER_FullPayto payto_uri,
-                   const char *conversion_url,
-                   const json_t *debit_restrictions,
-                   const json_t *credit_restrictions,
-                   struct GNUNET_TIME_Timestamp start_date,
-                   const struct TALER_MasterSignatureP *master_sig,
-                   const char *bank_label,
-                   int64_t priority);
+  (*insert_wire)(void *cls,
+                 const struct TALER_FullPayto payto_uri,
+                 const char *conversion_url,
+                 const json_t *debit_restrictions,
+                 const json_t *credit_restrictions,
+                 struct GNUNET_TIME_Timestamp start_date,
+                 const struct TALER_MasterSignatureP *master_sig,
+                 const char *bank_label,
+                 int64_t priority);
 
 
   /**
@@ -6011,16 +6011,16 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*update_wire)(void *cls,
-                   const struct TALER_FullPayto payto_uri,
-                   const char *conversion_url,
-                   const json_t *debit_restrictions,
-                   const json_t *credit_restrictions,
-                   struct GNUNET_TIME_Timestamp change_date,
-                   const struct TALER_MasterSignatureP *master_sig,
-                   const char *bank_label,
-                   int64_t priority,
-                   bool enabled);
+  (*update_wire)(void *cls,
+                 const struct TALER_FullPayto payto_uri,
+                 const char *conversion_url,
+                 const json_t *debit_restrictions,
+                 const json_t *credit_restrictions,
+                 struct GNUNET_TIME_Timestamp change_date,
+                 const struct TALER_MasterSignatureP *master_sig,
+                 const char *bank_label,
+                 int64_t priority,
+                 bool enabled);
 
 
   /**
@@ -6032,9 +6032,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_wire_accounts)(void *cls,
-                         TALER_EXCHANGEDB_WireAccountCallback cb,
-                         void *cb_cls);
+  (*get_wire_accounts)(void *cls,
+                       TALER_EXCHANGEDB_WireAccountCallback cb,
+                       void *cb_cls);
 
 
   /**
@@ -6048,10 +6048,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_wire_fees)(void *cls,
-                     const char *wire_method,
-                     TALER_EXCHANGEDB_WireFeeCallback cb,
-                     void *cb_cls);
+  (*get_wire_fees)(void *cls,
+                   const char *wire_method,
+                   TALER_EXCHANGEDB_WireFeeCallback cb,
+                   void *cb_cls);
 
 
   /**
@@ -6063,9 +6063,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_global_fees)(void *cls,
-                       TALER_EXCHANGEDB_GlobalFeeCallback cb,
-                       void *cb_cls);
+  (*get_global_fees)(void *cls,
+                     TALER_EXCHANGEDB_GlobalFeeCallback cb,
+                     void *cb_cls);
 
 
   /**
@@ -6077,7 +6077,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_signkey_revocation)(
+  (*insert_signkey_revocation)(
     void *cls,
     const struct TALER_ExchangePublicKeyP *exchange_pub,
     const struct TALER_MasterSignatureP *master_sig);
@@ -6092,7 +6092,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_signkey_revocation)(
+  (*lookup_signkey_revocation)(
     void *cls,
     const struct TALER_ExchangePublicKeyP *exchange_pub,
     struct TALER_MasterSignatureP *master_sig);
@@ -6107,7 +6107,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_denomination_key)(
+  (*lookup_denomination_key)(
     void *cls,
     const struct TALER_DenominationHashP *h_denom_pub,
     struct TALER_EXCHANGEDB_DenominationKeyMetaData *meta);
@@ -6124,7 +6124,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*add_denomination_key)(
+  (*add_denomination_key)(
     void *cls,
     const struct TALER_DenominationHashP *h_denom_pub,
     const struct TALER_DenominationPublicKey *denom_pub,
@@ -6143,7 +6143,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*activate_signing_key)(
+  (*activate_signing_key)(
     void *cls,
     const struct TALER_ExchangePublicKeyP *exchange_pub,
     const struct TALER_EXCHANGEDB_SignkeyMetaData *meta,
@@ -6159,7 +6159,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_signing_key)(
+  (*lookup_signing_key)(
     void *cls,
     const struct TALER_ExchangePublicKeyP *exchange_pub,
     struct TALER_EXCHANGEDB_SignkeyMetaData *meta);
@@ -6175,7 +6175,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_auditor_denom_sig)(
+  (*insert_auditor_denom_sig)(
     void *cls,
     const struct TALER_DenominationHashP *h_denom_pub,
     const struct TALER_AuditorPublicKeyP *auditor_pub,
@@ -6192,7 +6192,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_auditor_denom_sig)(
+  (*select_auditor_denom_sig)(
     void *cls,
     const struct TALER_DenominationHashP *h_denom_pub,
     const struct TALER_AuditorPublicKeyP *auditor_pub,
@@ -6212,7 +6212,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_wire_fee_by_time)(
+  (*lookup_wire_fee_by_time)(
     void *cls,
     const char *wire_method,
     struct GNUNET_TIME_Timestamp start_time,
@@ -6235,7 +6235,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_global_fee_by_time)(
+  (*lookup_global_fee_by_time)(
     void *cls,
     struct GNUNET_TIME_Timestamp start_time,
     struct GNUNET_TIME_Timestamp end_time,
@@ -6256,9 +6256,9 @@ struct TALER_EXCHANGEDB_Plugin
    *         @a table does not have a serial number
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_serial_by_table)(void *cls,
-                              enum TALER_EXCHANGEDB_ReplicatedTable table,
-                              uint64_t *serial);
+  (*lookup_serial_by_table)(void *cls,
+                            enum TALER_EXCHANGEDB_ReplicatedTable table,
+                            uint64_t *serial);
 
   /**
    * Lookup records above @a serial number in @a table. Used in
@@ -6273,11 +6273,11 @@ struct TALER_EXCHANGEDB_Plugin
    *         @a table does not have a serial number
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_records_by_table)(void *cls,
-                               enum TALER_EXCHANGEDB_ReplicatedTable table,
-                               uint64_t serial,
-                               TALER_EXCHANGEDB_ReplicationCallback cb,
-                               void *cb_cls);
+  (*lookup_records_by_table)(void *cls,
+                             enum TALER_EXCHANGEDB_ReplicatedTable table,
+                             uint64_t serial,
+                             TALER_EXCHANGEDB_ReplicationCallback cb,
+                             void *cb_cls);
 
 
   /**
@@ -6291,8 +6291,8 @@ struct TALER_EXCHANGEDB_Plugin
    *         @a table does not have a serial number
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_records_by_table)(void *cls,
-                               const struct TALER_EXCHANGEDB_TableData *td);
+  (*insert_records_by_table)(void *cls,
+                             const struct TALER_EXCHANGEDB_TableData *td);
 
 
   /**
@@ -6308,12 +6308,12 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*begin_shard)(void *cls,
-                   const char *job_name,
-                   struct GNUNET_TIME_Relative delay,
-                   uint64_t shard_size,
-                   uint64_t *start_row,
-                   uint64_t *end_row);
+  (*begin_shard)(void *cls,
+                 const char *job_name,
+                 struct GNUNET_TIME_Relative delay,
+                 uint64_t shard_size,
+                 uint64_t *start_row,
+                 uint64_t *end_row);
 
   /**
    * Function called to abort work on a shard.
@@ -6325,10 +6325,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*abort_shard)(void *cls,
-                   const char *job_name,
-                   uint64_t start_row,
-                   uint64_t end_row);
+  (*abort_shard)(void *cls,
+                 const char *job_name,
+                 uint64_t start_row,
+                 uint64_t end_row);
 
   /**
    * Function called to persist that work on a shard was completed.
@@ -6340,10 +6340,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*complete_shard)(void *cls,
-                      const char *job_name,
-                      uint64_t start_row,
-                      uint64_t end_row);
+  (*complete_shard)(void *cls,
+                    const char *job_name,
+                    uint64_t start_row,
+                    uint64_t end_row);
 
 
   /**
@@ -6359,12 +6359,12 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*begin_revolving_shard)(void *cls,
-                             const char *job_name,
-                             uint32_t shard_size,
-                             uint32_t shard_limit,
-                             uint32_t *start_row,
-                             uint32_t *end_row);
+  (*begin_revolving_shard)(void *cls,
+                           const char *job_name,
+                           uint32_t shard_size,
+                           uint32_t shard_limit,
+                           uint32_t *start_row,
+                           uint32_t *end_row);
 
 
   /**
@@ -6378,10 +6378,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*release_revolving_shard)(void *cls,
-                               const char *job_name,
-                               uint32_t start_row,
-                               uint32_t end_row);
+  (*release_revolving_shard)(void *cls,
+                             const char *job_name,
+                             uint32_t start_row,
+                             uint32_t end_row);
 
 
   /**
@@ -6394,7 +6394,7 @@ struct TALER_EXCHANGEDB_Plugin
    *         #GNUNET_SYSERR on failure
    */
   enum GNUNET_GenericReturnValue
-    (*delete_shard_locks)(void *cls);
+  (*delete_shard_locks)(void *cls);
 
 
   /**
@@ -6407,9 +6407,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*set_extension_manifest)(void *cls,
-                              const char *extension_name,
-                              const char *manifest);
+  (*set_extension_manifest)(void *cls,
+                            const char *extension_name,
+                            const char *manifest);
 
 
   /**
@@ -6422,9 +6422,9 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_extension_manifest)(void *cls,
-                              const char *extension_name,
-                              char **manifest);
+  (*get_extension_manifest)(void *cls,
+                            const char *extension_name,
+                            char **manifest);
 
 
   /**
@@ -6442,14 +6442,14 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_partner)(void *cls,
-                      const struct TALER_MasterPublicKeyP *master_pub,
-                      struct GNUNET_TIME_Timestamp start_date,
-                      struct GNUNET_TIME_Timestamp end_date,
-                      struct GNUNET_TIME_Relative wad_frequency,
-                      const struct TALER_Amount *wad_fee,
-                      const char *partner_base_url,
-                      const struct TALER_MasterSignatureP *master_sig);
+  (*insert_partner)(void *cls,
+                    const struct TALER_MasterPublicKeyP *master_pub,
+                    struct GNUNET_TIME_Timestamp start_date,
+                    struct GNUNET_TIME_Timestamp end_date,
+                    struct GNUNET_TIME_Relative wad_frequency,
+                    const struct TALER_Amount *wad_fee,
+                    const char *partner_base_url,
+                    const struct TALER_MasterSignatureP *master_sig);
 
 
   /**
@@ -6465,10 +6465,10 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_contract)(void *cls,
-                       const struct TALER_PurseContractPublicKeyP *purse_pub,
-                       const struct TALER_EncryptedContract *econtract,
-                       bool *in_conflict);
+  (*insert_contract)(void *cls,
+                     const struct TALER_PurseContractPublicKeyP *purse_pub,
+                     const struct TALER_EncryptedContract *econtract,
+                     bool *in_conflict);
 
 
   /**
@@ -6483,7 +6483,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_contract)(
+  (*select_contract)(
     void *cls,
     const struct TALER_ContractDiffiePublicP *pub_ckey,
     struct TALER_PurseContractPublicKeyP *purse_pub,
@@ -6501,7 +6501,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_contract_by_purse)(
+  (*select_contract_by_purse)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     struct TALER_EncryptedContract *econtract);
@@ -6527,7 +6527,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_purse_request)(
+  (*insert_purse_request)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     const struct TALER_PurseMergePublicKeyP *merge_pub,
@@ -6550,7 +6550,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code (#GNUNET_DB_STATUS_SUCCESS_NO_RESULTS if no purse expired in the given time interval).
    */
   enum GNUNET_DB_QueryStatus
-    (*expire_purse)(
+  (*expire_purse)(
     void *cls,
     struct GNUNET_TIME_Absolute start_time,
     struct GNUNET_TIME_Absolute end_time);
@@ -6572,7 +6572,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_purse)(
+  (*select_purse)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     struct GNUNET_TIME_Timestamp *purse_creation,
@@ -6601,7 +6601,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_purse_request)(
+  (*get_purse_request)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     struct TALER_PurseMergePublicKeyP *merge_pub,
@@ -6629,7 +6629,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_purse_by_merge_pub)(
+  (*select_purse_by_merge_pub)(
     void *cls,
     const struct TALER_PurseMergePublicKeyP *merge_pub,
     struct TALER_PurseContractPublicKeyP *purse_pub,
@@ -6665,7 +6665,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*do_purse_deposit)(
+  (*do_purse_deposit)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     const struct TALER_CoinSpendPublicKeyP *coin_pub,
@@ -6690,7 +6690,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*do_purse_delete)(
+  (*do_purse_delete)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     const struct TALER_PurseContractSignatureP *purse_sig,
@@ -6709,7 +6709,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*set_purse_balance)(
+  (*set_purse_balance)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     const struct TALER_Amount *balance);
@@ -6730,7 +6730,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_purse_deposit)(
+  (*get_purse_deposit)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     const struct TALER_CoinSpendPublicKeyP *coin_pub,
@@ -6760,7 +6760,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*do_purse_merge)(
+  (*do_purse_merge)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     const struct TALER_PurseMergeSignatureP *merge_sig,
@@ -6791,7 +6791,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*do_reserve_purse)(
+  (*do_reserve_purse)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     const struct TALER_PurseMergeSignatureP *merge_sig,
@@ -6818,7 +6818,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*select_purse_merge)(
+  (*select_purse_merge)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     struct TALER_PurseMergeSignatureP *merge_sig,
@@ -6841,13 +6841,13 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_close_request)(void *cls,
-                            const struct TALER_ReservePublicKeyP *reserve_pub,
-                            const struct TALER_FullPayto payto_uri,
-                            const struct TALER_ReserveSignatureP *reserve_sig,
-                            struct GNUNET_TIME_Timestamp request_timestamp,
-                            const struct TALER_Amount *balance,
-                            const struct TALER_Amount *closing_fee);
+  (*insert_close_request)(void *cls,
+                          const struct TALER_ReservePublicKeyP *reserve_pub,
+                          const struct TALER_FullPayto payto_uri,
+                          const struct TALER_ReserveSignatureP *reserve_sig,
+                          struct GNUNET_TIME_Timestamp request_timestamp,
+                          const struct TALER_Amount *balance,
+                          const struct TALER_Amount *closing_fee);
 
 
   /**
@@ -6863,13 +6863,13 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_drain_profit)(void *cls,
-                           const struct TALER_WireTransferIdentifierRawP *wtid,
-                           const char *account_section,
-                           const struct TALER_FullPayto payto_uri,
-                           struct GNUNET_TIME_Timestamp request_timestamp,
-                           const struct TALER_Amount *amount,
-                           const struct TALER_MasterSignatureP *master_sig);
+  (*insert_drain_profit)(void *cls,
+                         const struct TALER_WireTransferIdentifierRawP *wtid,
+                         const char *account_section,
+                         const struct TALER_FullPayto payto_uri,
+                         struct GNUNET_TIME_Timestamp request_timestamp,
+                         const struct TALER_Amount *amount,
+                         const struct TALER_MasterSignatureP *master_sig);
 
 
   /**
@@ -6886,14 +6886,14 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_drain_profit)(void *cls,
-                        const struct TALER_WireTransferIdentifierRawP *wtid,
-                        uint64_t *serial,
-                        char **account_section,
-                        struct TALER_FullPayto *payto_uri,
-                        struct GNUNET_TIME_Timestamp *request_timestamp,
-                        struct TALER_Amount *amount,
-                        struct TALER_MasterSignatureP *master_sig);
+  (*get_drain_profit)(void *cls,
+                      const struct TALER_WireTransferIdentifierRawP *wtid,
+                      uint64_t *serial,
+                      char **account_section,
+                      struct TALER_FullPayto *payto_uri,
+                      struct GNUNET_TIME_Timestamp *request_timestamp,
+                      struct TALER_Amount *amount,
+                      struct TALER_MasterSignatureP *master_sig);
 
 
   /**
@@ -6910,7 +6910,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*profit_drains_get_pending)(
+  (*profit_drains_get_pending)(
     void *cls,
     uint64_t *serial,
     struct TALER_WireTransferIdentifierRawP *wtid,
@@ -6929,7 +6929,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*profit_drains_set_finished)(
+  (*profit_drains_set_finished)(
     void *cls,
     uint64_t serial);
 
@@ -6955,7 +6955,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*trigger_kyc_rule_for_account)(
+  (*trigger_kyc_rule_for_account)(
     void *cls,
     const struct TALER_FullPayto payto_uri,
     const struct TALER_NormalizedPaytoHashP *h_payto,
@@ -6984,7 +6984,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_kyc_requirement_process)(
+  (*insert_kyc_requirement_process)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     uint32_t measure_index,
@@ -7005,7 +7005,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*get_pending_kyc_requirement_process)(
+  (*get_pending_kyc_requirement_process)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     const char *provider_name,
@@ -7030,7 +7030,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*update_kyc_process_by_row)(
+  (*update_kyc_process_by_row)(
     void *cls,
     uint64_t process_row,
     const char *provider_name,
@@ -7066,7 +7066,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_kyc_requirement_by_row)(
+  (*lookup_kyc_requirement_by_row)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     union TALER_AccountPublicKeyP *account_pub,
@@ -7087,7 +7087,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_kyc_status_by_token)(
+  (*lookup_kyc_status_by_token)(
     void *cls,
     const struct TALER_AccountAccessTokenP *access_token,
     uint64_t *row,
@@ -7104,7 +7104,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_rules_by_access_token)(
+  (*lookup_rules_by_access_token)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     json_t **jnew_rules,
@@ -7124,7 +7124,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_kyc_process_by_account)(
+  (*lookup_kyc_process_by_account)(
     void *cls,
     const char *provider_name,
     const struct TALER_NormalizedPaytoHashP *h_payto,
@@ -7145,7 +7145,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*kyc_provider_account_lookup)(
+  (*kyc_provider_account_lookup)(
     void *cls,
     const char *provider_name,
     const char *provider_legitimization_id,
@@ -7170,7 +7170,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_kyc_rules)(
+  (*get_kyc_rules)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     bool *no_account_pub,
@@ -7190,7 +7190,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*get_kyc_rules2)(
+  (*get_kyc_rules2)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     json_t **jrules);
@@ -7207,7 +7207,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
-    (*iterate_kyc_reference)(
+  (*iterate_kyc_reference)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     TALER_EXCHANGEDB_LegitimizationProcessCallback lpc,
@@ -7226,7 +7226,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code, @a kac aborting with #GNUNET_NO is not an error
    */
   enum GNUNET_DB_QueryStatus
-    (*select_withdraw_amounts_for_kyc_check)(
+  (*select_withdraw_amounts_for_kyc_check)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     struct GNUNET_TIME_Absolute time_limit,
@@ -7246,7 +7246,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code, @a kac aborting with #GNUNET_NO is not an error
    */
   enum GNUNET_DB_QueryStatus
-    (*select_aggregation_amounts_for_kyc_check)(
+  (*select_aggregation_amounts_for_kyc_check)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     struct GNUNET_TIME_Absolute time_limit,
@@ -7266,7 +7266,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code, @a kac aborting with #GNUNET_NO is not an error
    */
   enum GNUNET_DB_QueryStatus
-    (*select_merge_amounts_for_kyc_check)(
+  (*select_merge_amounts_for_kyc_check)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     struct GNUNET_TIME_Absolute time_limit,
@@ -7288,7 +7288,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return transaction status code, @a kac aborting with #GNUNET_NO is not an error
    */
   enum GNUNET_DB_QueryStatus
-    (*select_deposit_amounts_for_kyc_check)(
+  (*select_deposit_amounts_for_kyc_check)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     struct GNUNET_TIME_Absolute time_limit,
@@ -7319,7 +7319,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_kyc_measure_result)(
+  (*insert_kyc_measure_result)(
     void *cls,
     uint64_t process_row,
     const struct TALER_NormalizedPaytoHashP *h_payto,
@@ -7342,7 +7342,7 @@ struct TALER_EXCHANGEDB_Plugin
    * Revert account back to default rules and insert successor measure.
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_successor_measure)(
+  (*insert_successor_measure)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     struct GNUNET_TIME_Timestamp decision_time,
@@ -7362,7 +7362,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*select_kyc_attributes)(
+  (*select_kyc_attributes)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     TALER_EXCHANGEDB_AttributeCallback cb,
@@ -7384,7 +7384,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*select_aml_measures)(
+  (*select_aml_measures)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     enum TALER_EXCHANGE_YesNoAll active_only,
@@ -7408,7 +7408,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_aml_officer)(
+  (*insert_aml_officer)(
     void *cls,
     const struct TALER_AmlOfficerPublicKeyP *decider_pub,
     const struct TALER_MasterSignatureP *master_sig,
@@ -7428,7 +7428,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status, if member is unknown or not active, 1 if member is active
    */
   enum GNUNET_DB_QueryStatus
-    (*test_aml_officer)(
+  (*test_aml_officer)(
     void *cls,
     const struct TALER_AmlOfficerPublicKeyP *decider_pub);
 
@@ -7446,7 +7446,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_aml_officer)(
+  (*lookup_aml_officer)(
     void *cls,
     const struct TALER_AmlOfficerPublicKeyP *decider_pub,
     struct TALER_MasterSignatureP *master_sig,
@@ -7468,7 +7468,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status, 0 if no threshold was set
    */
   enum GNUNET_DB_QueryStatus
-    (*select_aml_statistics)(
+  (*select_aml_statistics)(
     void *cls,
     const char *name,
     struct GNUNET_TIME_Timestamp start_date,
@@ -7491,7 +7491,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*select_aml_decisions)(
+  (*select_aml_decisions)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     enum TALER_EXCHANGE_YesNoAll investigation_only,
@@ -7515,7 +7515,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*select_aml_attributes)(
+  (*select_aml_attributes)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     uint64_t offset,
@@ -7535,7 +7535,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_h_payto_by_access_token)(
+  (*lookup_h_payto_by_access_token)(
     void *cls,
     const struct TALER_AccountAccessTokenP *access_token,
     struct TALER_NormalizedPaytoHashP *h_payto);
@@ -7558,7 +7558,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_pending_legitimization)(
+  (*lookup_pending_legitimization)(
     void *cls,
     uint64_t legitimization_measure_serial_id,
     struct TALER_AccountAccessTokenP *access_token,
@@ -7591,7 +7591,7 @@ struct TALER_EXCHANGEDB_Plugin
  * @return database transaction status
  */
   enum GNUNET_DB_QueryStatus
-    (*lookup_completed_legitimization)(
+  (*lookup_completed_legitimization)(
     void *cls,
     uint64_t legitimization_measure_serial_id,
     uint32_t measure_index,
@@ -7614,7 +7614,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_aml_history)(
+  (*lookup_aml_history)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     TALER_EXCHANGEDB_AmlHistoryCallback cb,
@@ -7632,7 +7632,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_kyc_history)(
+  (*lookup_kyc_history)(
     void *cls,
     const struct TALER_NormalizedPaytoHashP *h_payto,
     TALER_EXCHANGEDB_KycHistoryCallback cb,
@@ -7653,7 +7653,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*lookup_active_legitimization) (
+  (*lookup_active_legitimization) (
     void *cls,
     uint64_t legitimization_process_serial_id,
     uint32_t *measure_index,
@@ -7674,7 +7674,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_active_legitimization_measure) (
+  (*insert_active_legitimization_measure) (
     void *cls,
     const struct TALER_AccountAccessTokenP *access_token,
     const json_t *jmeasures,
@@ -7709,7 +7709,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_aml_decision)(
+  (*insert_aml_decision)(
     void *cls,
     const struct TALER_FullPayto payto_uri,
     const struct TALER_NormalizedPaytoHashP *h_payto,
@@ -7743,7 +7743,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @return database transaction status
    */
   enum GNUNET_DB_QueryStatus
-    (*insert_kyc_failure)(
+  (*insert_kyc_failure)(
     void *cls,
     uint64_t process_row,
     const struct TALER_NormalizedPaytoHashP *h_payto,
@@ -7763,7 +7763,7 @@ struct TALER_EXCHANGEDB_Plugin
    *         #GNUNET_SYSERR on DB errors
    */
   enum GNUNET_GenericReturnValue
-    (*inject_auditor_triggers)(void *cls);
+  (*inject_auditor_triggers)(void *cls);
 
 };