exchange

taler-exchange-httpd_get-keys.c (99616B)

---

 /*
    This file is part of TALER
    Copyright (C) 2020-2025 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 taler-exchange-httpd_get-keys.c
  * @brief management of our various keys
  * @author Christian Grothoff
  * @author Özgür Kesim
  */
 #include "taler/taler_json_lib.h"
 #include "taler/taler_mhd_lib.h"
 #include "taler/taler_kyclogic_lib.h"
 #include "taler/taler_dbevents.h"
 #include "taler-exchange-httpd.h"
 #include "exchange-database/preflight.h"
 #include "taler-exchange-httpd_get-config.h"
 #include "taler-exchange-httpd_get-keys.h"
 #include "taler-exchange-httpd_secmod-helpers.h"
 #include "taler-exchange-httpd_responses.h"
 #include "taler-exchange-httpd_configuration.h"
 #include "exchange-database/event_listen.h"
 #include "exchange-database/event_listen_cancel.h"
 #include "exchange-database/event_notify.h"
 struct TEH_KeyStateHandle;
 struct AddContext;
 #define TALER_EXCHANGEDB_GLOBAL_FEE_RESULT_CLOSURE struct TEH_KeyStateHandle
 #define TALER_EXCHANGEDB_WIRE_ACCOUNT_RESULT_CLOSURE json_t
 #define TALER_EXCHANGEDB_WIRE_FEE_RESULT_CLOSURE struct AddContext
 #define TALER_EXCHANGEDB_AUDITORS_RESULT_CLOSURE struct TEH_KeyStateHandle
 #define TALER_EXCHANGEDB_ACTIVE_SIGNKEYS_RESULT_CLOSURE struct \
         TEH_KeyStateHandle
 #define TALER_EXCHANGEDB_AUDITOR_DENOMINATIONS_RESULT_CLOSURE struct \
         TEH_KeyStateHandle
 #define TALER_EXCHANGEDB_DENOMINATIONS_RESULT_CLOSURE struct TEH_KeyStateHandle
 #include "exchange-database/iterate_global_fees.h"
 #include "exchange-database/iterate_wire_accounts.h"
 #include "exchange-database/iterate_wire_fees.h"
 #include "exchange-database/iterate_active_auditors.h"
 #include "exchange-database/iterate_active_signkeys.h"
 #include "exchange-database/iterate_auditor_denominations.h"
 #include "exchange-database/iterate_denominations.h"
 
 
 /**
  * How many /keys request do we hold in suspension at
  * most at any time?
  */
 #define SKR_LIMIT 32
 
 
 /**
  * When do we forcefully timeout a /keys request?
  * Matches the 120s hard-coded into exchange_api_handle.c
  */
 #define KEYS_TIMEOUT \
         GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 2)
 
 
 /**
  * Signatures of an auditor over a denomination key of this exchange.
  */
 struct TEH_AuditorSignature
 {
   /**
    * We store the signatures in a DLL.
    */
   struct TEH_AuditorSignature *prev;
 
   /**
    * We store the signatures in a DLL.
    */
   struct TEH_AuditorSignature *next;
 
   /**
    * A signature from the auditor.
    */
   struct TALER_AuditorSignatureP asig;
 
   /**
    * Public key of the auditor.
    */
   struct TALER_AuditorPublicKeyP apub;
 
 };
 
 
 /**
  * Entry in (sorted) array with possible pre-build responses for /keys.
  * We keep pre-build responses for the various (valid) cherry-picking
  * values around.
  */
 struct KeysResponseData
 {
 
   /**
    * Response to return if the client supports (deflate) compression.
    */
   struct MHD_Response *response_compressed;
 
   /**
    * Response to return if the client does not support compression.
    */
   struct MHD_Response *response_uncompressed;
 
   /**
    * ETag for these responses.
    */
   char *etag;
 
   /**
    * Cherry-picking timestamp the client must have set for this
    * response to be valid.  0 if this is the "full" response.
    * The client's request must include this date or a higher one
    * for this response to be applicable.
    */
   struct GNUNET_TIME_Timestamp cherry_pick_date;
 
 };
 
 
 /**
  * @brief All information about an exchange online signing key (which is used to
  * sign messages from the exchange).
  */
 struct SigningKey
 {
 
   /**
    * The exchange's (online signing) public key.
    */
   struct TALER_ExchangePublicKeyP exchange_pub;
 
   /**
    * Meta data about the signing key, such as validity periods.
    */
   struct TALER_EXCHANGEDB_SignkeyMetaData meta;
 
   /**
    * The long-term offline master key's signature for this signing key.
    * Signs over @e exchange_pub and @e meta.
    */
   struct TALER_MasterSignatureP master_sig;
 
 };
 
 struct TEH_KeyStateHandle
 {
 
   /**
    * Mapping from denomination keys to denomination key issue struct.
    * Used to lookup the key by hash.
    */
   struct GNUNET_CONTAINER_MultiHashMap *denomkey_map;
 
   /**
    * Mapping from serial ID's to denomination key issue struct.
    * Used to lookup the key by serial ID.
    *
    * FIXME: We need a 64-bit version of this in GNUNET.
    */
   struct GNUNET_CONTAINER_MultiHashMap32 *denomserial_map;
 
   /**
    * Map from `struct TALER_ExchangePublicKey` to `struct SigningKey`
    * entries.  Based on the fact that a `struct GNUNET_PeerIdentity` is also
    * an EdDSA public key.
    */
   struct GNUNET_CONTAINER_MultiPeerMap *signkey_map;
 
   /**
    * Head of DLL of our global fees.
    */
   struct TEH_GlobalFee *gf_head;
 
   /**
    * Tail of DLL of our global fees.
    */
   struct TEH_GlobalFee *gf_tail;
 
   /**
    * json array with the auditors of this exchange. Contains exactly
    * the information needed for the "auditors" field of the /keys response.
    */
   json_t *auditors;
 
   /**
    * json array with the global fees of this exchange. Contains exactly
    * the information needed for the "global_fees" field of the /keys response.
    */
   json_t *global_fees;
 
   /**
    * Sorted array of responses to /keys (MUST be sorted by cherry-picking date) of
    * length @e krd_array_length;
    */
   struct KeysResponseData *krd_array;
 
   /**
    * Length of the @e krd_array.
    */
   unsigned int krd_array_length;
 
   /**
    * Cached reply for a GET /management/keys request.  Used so we do not
    * re-create the reply every time.
    */
   json_t *management_keys_reply;
 
   /**
    * For which (global) key_generation was this data structure created?
    * Used to check when we are outdated and need to be re-generated.
    */
   uint64_t key_generation;
 
   /**
    * When did we initiate the key reloading?
    */
   struct GNUNET_TIME_Timestamp reload_time;
 
   /**
    * What is the period at which we rotate keys
    * (signing or denomination keys)?
    */
   struct GNUNET_TIME_Relative rekey_frequency;
 
   /**
    * When does our online signing key expire and we
    * thus need to re-generate this response?
    */
   struct GNUNET_TIME_Timestamp signature_expires;
 
   /**
    * True if #finish_keys_response() was not yet run and this key state
    * is only suitable for the /management/keys API.
    */
   bool management_only;
 
 };
 
 
 /**
  * Entry of /keys requests that are currently suspended because we are
  * waiting for /keys to become ready.
  */
 struct SuspendedKeysRequests
 {
   /**
    * Kept in a DLL.
    */
   struct SuspendedKeysRequests *next;
 
   /**
    * Kept in a DLL.
    */
   struct SuspendedKeysRequests *prev;
 
   /**
    * The suspended connection.
    */
   struct MHD_Connection *connection;
 
   /**
    * When does this request timeout?
    */
   struct GNUNET_TIME_Absolute timeout;
 };
 
 
 /**
  * Information we track about wire fees.
  */
 struct WireFeeSet
 {
 
   /**
    * Kept in a DLL.
    */
   struct WireFeeSet *next;
 
   /**
    * Kept in a DLL.
    */
   struct WireFeeSet *prev;
 
   /**
    * Actual fees.
    */
   struct TALER_WireFeeSet fees;
 
   /**
    * Start date of fee validity (inclusive).
    */
   struct GNUNET_TIME_Timestamp start_date;
 
   /**
    * End date of fee validity (exclusive).
    */
   struct GNUNET_TIME_Timestamp end_date;
 
   /**
    * Wire method the fees apply to.
    */
   char *method;
 };
 
 
 /**
  * State we keep per thread to cache the wire part of the /keys response.
  */
 struct WireStateHandle
 {
 
   /**
    * JSON reply for wire response.
    */
   json_t *json_reply;
 
   /**
    * ETag for this response (if any).
    */
   char *etag;
 
   /**
    * head of DLL of wire fees.
    */
   struct WireFeeSet *wfs_head;
 
   /**
    * Tail of DLL of wire fees.
    */
   struct WireFeeSet *wfs_tail;
 
   /**
    * Earliest timestamp of all the wire methods when we have no more fees.
    */
   struct GNUNET_TIME_Absolute cache_expiration;
 
   /**
    * @e cache_expiration time, formatted.
    */
   char dat[128];
 
   /**
    * For which (global) wire_generation was this data structure created?
    * Used to check when we are outdated and need to be re-generated.
    */
   uint64_t wire_generation;
 
   /**
    * Is the wire data ready?
    */
   bool ready;
 
 };
 
 
 /**
  * Stores the latest generation of our wire response.
  */
 static struct WireStateHandle *wire_state;
 
 /**
  * Handler listening for wire updates by other exchange
  * services.
  */
 static struct GNUNET_DB_EventHandler *wire_eh;
 
 /**
  * Counter incremented whenever we have a reason to re-build the #wire_state
  * because something external changed.
  */
 static uint64_t wire_generation;
 
 /**
  * Counter incremented whenever we have a reason to re-build the keys because
  * something external changed.  See #TEH_keys_get_state() and
  * #TEH_keys_update_states() for uses of this variable.
  */
 static uint64_t key_generation;
 
 /**
  * Stores the latest generation of our key state.
  */
 static struct TEH_KeyStateHandle *key_state;
 
 /**
  * Handler listening for wire updates by other exchange
  * services.
  */
 static struct GNUNET_DB_EventHandler *keys_eh;
 
 /**
  * Head of DLL of suspended /keys requests.
  */
 static struct SuspendedKeysRequests *skr_head;
 
 /**
  * Tail of DLL of suspended /keys requests.
  */
 static struct SuspendedKeysRequests *skr_tail;
 
 /**
  * Number of entries in the @e skr_head DLL.
  */
 static unsigned int skr_size;
 
 /**
  * Task to force timeouts on /keys requests.
  */
 static struct GNUNET_SCHEDULER_Task *keys_tt;
 
 /**
  * For how long should a signing key be legally retained?
  * Configuration value.
  */
 static struct GNUNET_TIME_Relative signkey_legal_duration;
 
 /**
  * What type of asset are we dealing with here?
  */
 static char *asset_type;
 
 /**
  * Are we shutting down?
  */
 static bool terminating;
 
 
 /**
  * Free memory associated with @a wsh
  *
  * @param[in] wsh wire state to destroy
  */
 static void
 destroy_wire_state (struct WireStateHandle *wsh)
 {
   struct WireFeeSet *wfs;
 
   while (NULL != (wfs = wsh->wfs_head))
   {
     GNUNET_CONTAINER_DLL_remove (wsh->wfs_head,
                                  wsh->wfs_tail,
                                  wfs);
     GNUNET_free (wfs->method);
     GNUNET_free (wfs);
   }
   json_decref (wsh->json_reply);
   GNUNET_free (wsh->etag);
   GNUNET_free (wsh);
 }
 
 
 /**
  * Function called whenever another exchange process has updated
  * the wire data in the database.
  *
  * @param cls NULL
  * @param extra unused
  * @param extra_size number of bytes in @a extra unused
  */
 static void
 wire_update_event_cb (void *cls,
                       const void *extra,
                       size_t extra_size)
 {
   (void) cls;
   (void) extra;
   (void) extra_size;
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "Received wire update event\n");
   TEH_check_invariants ();
   wire_generation++;
   key_generation++;
   TEH_resume_keys_requests (false);
 }
 
 
 /**
  * Add information about a wire account to @a a.
  *
  * @param a a `json_t *` array to expand with wire account details
  * @param payto_uri the exchange bank account URI to add
  * @param conversion_url URL of a conversion service, NULL if there is no conversion
  * @param open_banking_gateway URL of an open banking gateway, NULL if there is none
  * @param prepared_transfer_url URL of a wire transfer gateway, NULL if there is none
  * @param debit_restrictions JSON array with debit restrictions on the account
  * @param credit_restrictions JSON array with credit restrictions on the account
  * @param master_sig master key signature affirming that this is a bank
  *                   account of the exchange (of purpose #TALER_SIGNATURE_MASTER_WIRE_DETAILS)
  * @param bank_label label the wallet should use to display the account, can be NULL
  * @param priority priority for ordering bank account labels
  */
 static void
 add_wire_account (
   json_t *a,
   const struct TALER_FullPayto payto_uri,
   const char *conversion_url,
   const char *open_banking_gateway,
   const char *prepared_transfer_url,
   const json_t *debit_restrictions,
   const json_t *credit_restrictions,
   const struct TALER_MasterSignatureP *master_sig,
   const char *bank_label,
   int64_t priority)
 {
   if (GNUNET_OK !=
       TALER_exchange_wire_signature_check (
         payto_uri,
         conversion_url,
         open_banking_gateway,
         prepared_transfer_url,
         debit_restrictions,
         credit_restrictions,
         &TEH_master_public_key,
         master_sig))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Database has wire account with invalid signature. Skipping entry. Did the exchange offline public key change?\n");
     return;
   }
   if (0 !=
       json_array_append_new (
         a,
         GNUNET_JSON_PACK (
           TALER_JSON_pack_full_payto (
             "payto_uri",
             payto_uri),
           GNUNET_JSON_pack_allow_null (
             GNUNET_JSON_pack_string (
               "conversion_url",
               conversion_url)),
           GNUNET_JSON_pack_allow_null (
             GNUNET_JSON_pack_string (
               "open_banking_gateway",
               open_banking_gateway)),
           GNUNET_JSON_pack_allow_null (
             GNUNET_JSON_pack_string (
               "prepared_transfer_url",
               prepared_transfer_url)),
           GNUNET_JSON_pack_allow_null (
             GNUNET_JSON_pack_string (
               "bank_label",
               bank_label)),
           GNUNET_JSON_pack_int64 (
             "priority",
             priority),
           GNUNET_JSON_pack_array_incref (
             "debit_restrictions",
             (json_t *) debit_restrictions),
           GNUNET_JSON_pack_array_incref (
             "credit_restrictions",
             (json_t *) credit_restrictions),
           GNUNET_JSON_pack_data_auto (
             "master_sig",
             master_sig))))
   {
     GNUNET_break (0);   /* out of memory!? */
     return;
   }
 }
 
 
 /**
  * Closure for #add_wire_fee().
  */
 struct AddContext
 {
   /**
    * Wire method the fees are for.
    */
   char *wire_method;
 
   /**
    * Wire state we are building.
    */
   struct WireStateHandle *wsh;
 
   /**
    * Array to append the fee to.
    */
   json_t *a;
 
   /**
    * Set to the maximum end-date seen.
    */
   struct GNUNET_TIME_Absolute max_seen;
 };
 
 
 /**
  * Add information about a wire account to @a ac.
  *
  * @param ac a `struct AddContext`
  * @param fees the wire fees we charge
  * @param start_date from when are these fees valid (start date)
  * @param end_date until when are these fees valid (end date, exclusive)
  * @param master_sig master key signature affirming that this is the correct
  *                   fee (of purpose #TALER_SIGNATURE_MASTER_WIRE_FEES)
  */
 static void
 add_wire_fee (struct AddContext *ac,
               const struct TALER_WireFeeSet *fees,
               struct GNUNET_TIME_Timestamp start_date,
               struct GNUNET_TIME_Timestamp end_date,
               const struct TALER_MasterSignatureP *master_sig)
 {
   struct WireFeeSet *wfs;
 
   if (GNUNET_OK !=
       TALER_exchange_offline_wire_fee_verify (
         ac->wire_method,
         start_date,
         end_date,
         fees,
         &TEH_master_public_key,
         master_sig))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Database has wire fee with invalid signature. Skipping entry. Did the exchange offline public key change?\n");
     return;
   }
   ac->max_seen = GNUNET_TIME_absolute_max (ac->max_seen,
                                            end_date.abs_time);
   wfs = GNUNET_new (struct WireFeeSet);
   wfs->start_date = start_date;
   wfs->end_date = end_date;
   wfs->fees = *fees;
   wfs->method = GNUNET_strdup (ac->wire_method);
   GNUNET_CONTAINER_DLL_insert (ac->wsh->wfs_head,
                                ac->wsh->wfs_tail,
                                wfs);
   if (0 !=
       json_array_append_new (
         ac->a,
         GNUNET_JSON_PACK (
           TALER_JSON_pack_amount ("wire_fee",
                                   &fees->wire),
           TALER_JSON_pack_amount ("closing_fee",
                                   &fees->closing),
           GNUNET_JSON_pack_timestamp ("start_date",
                                       start_date),
           GNUNET_JSON_pack_timestamp ("end_date",
                                       end_date),
           GNUNET_JSON_pack_data_auto ("sig",
                                       master_sig))))
   {
     GNUNET_break (0);   /* out of memory!? */
     return;
   }
 }
 
 
 /**
  * Create the wire response from our database state.
  *
  * @return NULL on error
  */
 static struct WireStateHandle *
 build_wire_state (void)
 {
   json_t *wire_accounts_array;
   json_t *wire_fee_object;
   uint64_t wg = wire_generation; /* must be obtained FIRST */
   enum GNUNET_DB_QueryStatus qs;
   struct WireStateHandle *wsh;
   json_t *wads;
 
   wsh = GNUNET_new (struct WireStateHandle);
   wsh->wire_generation = wg;
   wire_accounts_array = json_array ();
   GNUNET_assert (NULL != wire_accounts_array);
   qs = TALER_EXCHANGEDB_iterate_wire_accounts (TEH_pg,
                                                &add_wire_account,
                                                wire_accounts_array);
   if (0 > qs)
   {
     GNUNET_break (0);
     json_decref (wire_accounts_array);
     wsh->ready = false;
     return wsh;
   }
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "Built wire data with %u accounts (%d)\n",
               (unsigned int) json_array_size (wire_accounts_array),
               (int) qs);
   wire_fee_object = json_object ();
   GNUNET_assert (NULL != wire_fee_object);
   wsh->cache_expiration = GNUNET_TIME_UNIT_FOREVER_ABS;
   {
     json_t *account;
     size_t index;
 
     json_array_foreach (wire_accounts_array,
                         index,
                         account)
     {
       char *wire_method;
       const char *payto_uri = json_string_value (json_object_get (account,
                                                                   "payto_uri"));
 
       GNUNET_assert (NULL != payto_uri);
       wire_method = TALER_payto_get_method (payto_uri);
       if (NULL == wire_method)
       {
         GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                     "No wire method in `%s'\n",
                     payto_uri);
         wsh->ready = false;
         json_decref (wire_accounts_array);
         json_decref (wire_fee_object);
         return wsh;
       }
       if (NULL == json_object_get (wire_fee_object,
                                    wire_method))
       {
         struct AddContext ac = {
           .wire_method = wire_method,
           .wsh = wsh,
           .a = json_array ()
         };
 
         GNUNET_assert (NULL != ac.a);
         qs = TALER_EXCHANGEDB_iterate_wire_fees (TEH_pg,
                                                  wire_method,
                                                  &add_wire_fee,
                                                  &ac);
         if (0 > qs)
         {
           GNUNET_break (0);
           json_decref (ac.a);
           json_decref (wire_fee_object);
           json_decref (wire_accounts_array);
           GNUNET_free (wire_method);
           wsh->ready = false;
           return wsh;
         }
         if (0 != json_array_size (ac.a))
         {
           wsh->cache_expiration
             = GNUNET_TIME_absolute_min (ac.max_seen,
                                         wsh->cache_expiration);
           GNUNET_assert (0 ==
                          json_object_set_new (wire_fee_object,
                                               wire_method,
                                               ac.a));
         }
         else
         {
           json_decref (ac.a);
         }
       }
       GNUNET_free (wire_method);
     }
   }
 
   wads = json_array (); /* #7271 */
   GNUNET_assert (NULL != wads);
   wsh->json_reply = GNUNET_JSON_PACK (
     GNUNET_JSON_pack_array_steal ("accounts",
                                   wire_accounts_array),
     GNUNET_JSON_pack_array_steal ("wads",
                                   wads),
     GNUNET_JSON_pack_object_steal ("fees",
                                    wire_fee_object));
   wsh->ready = true;
   return wsh;
 }
 
 
 void
 TEH_wire_update_state (void)
 {
   struct GNUNET_DB_EventHeaderP es = {
     .size = htons (sizeof (es)),
     .type = htons (TALER_DBEVENT_EXCHANGE_WIRE_UPDATED),
   };
 
   TALER_EXCHANGEDB_event_notify (TEH_pg,
                                  &es,
                                  NULL,
                                  0);
   wire_generation++;
   key_generation++;
 }
 
 
 void
 TEH_keys_bump_generation (void)
 {
   key_generation++;
 }
 
 
 /**
  * Return the current key state for this thread.  Possibly
  * re-builds the key state if we have reason to believe
  * that something changed.
  *
  * @return NULL on error
  */
 static struct WireStateHandle *
 get_wire_state (void)
 {
   struct WireStateHandle *old_wsh;
 
   old_wsh = wire_state;
   if ( (NULL == old_wsh) ||
        (old_wsh->wire_generation < wire_generation) )
   {
     struct WireStateHandle *wsh;
 
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "Rebuilding wire, generation upgrade from %llu to %llu\n",
                 (unsigned long long) (NULL == old_wsh) ? 0LL :
                 old_wsh->wire_generation,
                 (unsigned long long) wire_generation);
     TEH_check_invariants ();
     wsh = build_wire_state ();
     wire_state = wsh;
     if (NULL != old_wsh)
       destroy_wire_state (old_wsh);
     TEH_check_invariants ();
     return wsh;
   }
   return old_wsh;
 }
 
 
 const struct TALER_WireFeeSet *
 TEH_wire_fees_by_time (
   struct GNUNET_TIME_Timestamp ts,
   const char *method)
 {
   struct WireStateHandle *wsh = get_wire_state ();
 
   for (struct WireFeeSet *wfs = wsh->wfs_head;
        NULL != wfs;
        wfs = wfs->next)
   {
     if (0 != strcmp (method,
                      wfs->method))
       continue;
     if ( (GNUNET_TIME_timestamp_cmp (wfs->start_date,
                                      >,
                                      ts)) ||
          (GNUNET_TIME_timestamp_cmp (ts,
                                      >=,
                                      wfs->end_date)) )
       continue;
     return &wfs->fees;
   }
   GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
               "No wire fees for method `%s' at %s configured\n",
               method,
               GNUNET_TIME_timestamp2s (ts));
   return NULL;
 }
 
 
 /**
  * Function called to forcefully resume suspended keys requests.
  *
  * @param cls unused, NULL
  */
 static void
 keys_timeout_cb (void *cls)
 {
   struct SuspendedKeysRequests *skr;
 
   (void) cls;
   keys_tt = NULL;
   while (NULL != (skr = skr_head))
   {
     if (GNUNET_TIME_absolute_is_future (skr->timeout))
       break;
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "Resuming /keys request due to timeout\n");
     GNUNET_CONTAINER_DLL_remove (skr_head,
                                  skr_tail,
                                  skr);
     skr_size--;
     MHD_resume_connection (skr->connection);
     TALER_MHD_daemon_trigger ();
     GNUNET_free (skr);
   }
   if (NULL == skr)
     return;
   keys_tt = GNUNET_SCHEDULER_add_at (skr->timeout,
                                      &keys_timeout_cb,
                                      NULL);
 }
 
 
 /**
  * Suspend /keys request while we (hopefully) are waiting to be
  * provisioned with key material.
  *
  * @param[in] connection to suspend
  */
 static enum MHD_Result
 suspend_request (struct MHD_Connection *connection)
 {
   struct SuspendedKeysRequests *skr;
 
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "Suspending /keys request until key material changes\n");
   if (terminating)
   {
     return TALER_MHD_reply_with_error (connection,
                                        MHD_HTTP_SERVICE_UNAVAILABLE,
                                        TALER_EC_EXCHANGE_GENERIC_KEYS_MISSING,
                                        "Exchange terminating");
   }
   skr = GNUNET_new (struct SuspendedKeysRequests);
   skr->connection = connection;
   MHD_suspend_connection (connection);
   GNUNET_CONTAINER_DLL_insert (skr_head,
                                skr_tail,
                                skr);
   skr_size++;
   skr->timeout = GNUNET_TIME_relative_to_absolute (KEYS_TIMEOUT);
   if (NULL == keys_tt)
   {
     keys_tt = GNUNET_SCHEDULER_add_at (skr->timeout,
                                        &keys_timeout_cb,
                                        NULL);
   }
   while (skr_size > SKR_LIMIT)
   {
     skr = skr_tail;
     GNUNET_CONTAINER_DLL_remove (skr_head,
                                  skr_tail,
                                  skr);
     skr_size--;
     MHD_resume_connection (skr->connection);
     TALER_MHD_daemon_trigger ();
     GNUNET_free (skr);
   }
   return MHD_YES;
 }
 
 
 /**
  * Called on each denomination key. Checks that the key still works.
  *
  * @param cls NULL
  * @param hc denomination hash (unused)
  * @param value a `struct TEH_DenominationKey`
  * @return #GNUNET_OK
  */
 static enum GNUNET_GenericReturnValue
 check_dk (void *cls,
           const struct GNUNET_HashCode *hc,
           void *value)
 {
   struct TEH_DenominationKey *dk = value;
 
   (void) cls;
   (void) hc;
   switch (dk->denom_pub.bsign_pub_key->cipher)
   {
   case GNUNET_CRYPTO_BSA_INVALID:
     break;
   case GNUNET_CRYPTO_BSA_RSA:
     GNUNET_assert (GNUNET_CRYPTO_rsa_public_key_check (
                      dk->denom_pub.bsign_pub_key->details.rsa_public_key));
     return GNUNET_OK;
   case GNUNET_CRYPTO_BSA_CS:
     /* nothing to do for GNUNET_CRYPTO_BSA_CS */
     return GNUNET_OK;
   }
   GNUNET_assert (0);
   return GNUNET_SYSERR;
 }
 
 
 void
 TEH_check_invariants ()
 {
   struct TEH_KeyStateHandle *ksh;
 
   if (0 == TEH_check_invariants_flag)
     return;
   ksh = TEH_keys_get_state ();
   if (NULL == ksh)
     return;
   GNUNET_CONTAINER_multihashmap_iterate (ksh->denomkey_map,
                                          &check_dk,
                                          NULL);
 }
 
 
 void
 TEH_resume_keys_requests (bool do_shutdown)
 {
   struct SuspendedKeysRequests *skr;
 
   if (do_shutdown)
     terminating = true;
   while (NULL != (skr = skr_head))
   {
     GNUNET_CONTAINER_DLL_remove (skr_head,
                                  skr_tail,
                                  skr);
     skr_size--;
     MHD_resume_connection (skr->connection);
     TALER_MHD_daemon_trigger ();
     GNUNET_free (skr);
   }
   GNUNET_assert (0 == skr_size);
 }
 
 
 /**
  * Clear memory for responses to "/keys" in @a ksh.
  *
  * @param[in,out] ksh key state to update
  */
 static void
 clear_response_cache (struct TEH_KeyStateHandle *ksh)
 {
   for (unsigned int i = 0; i<ksh->krd_array_length; i++)
   {
     struct KeysResponseData *krd = &ksh->krd_array[i];
 
     MHD_destroy_response (krd->response_compressed);
     MHD_destroy_response (krd->response_uncompressed);
     GNUNET_free (krd->etag);
   }
   GNUNET_array_grow (ksh->krd_array,
                      ksh->krd_array_length,
                      0);
 }
 
 
 /**
  * Free denomination key data.
  *
  * @param cls a `struct TEH_KeyStateHandle`, unused
  * @param h_denom_pub hash of the denomination public key, unused
  * @param value a `struct TEH_DenominationKey` to free
  * @return #GNUNET_OK (continue to iterate)
  */
 static enum GNUNET_GenericReturnValue
 clear_denomination_cb (void *cls,
                        const struct GNUNET_HashCode *h_denom_pub,
                        void *value)
 {
   struct TEH_DenominationKey *dk = value;
   struct TEH_AuditorSignature *as;
 
   (void) cls;
   (void) h_denom_pub;
   TALER_denom_pub_free (&dk->denom_pub);
   while (NULL != (as = dk->as_head))
   {
     GNUNET_CONTAINER_DLL_remove (dk->as_head,
                                  dk->as_tail,
                                  as);
     GNUNET_free (as);
   }
   GNUNET_free (dk);
   return GNUNET_OK;
 }
 
 
 /**
  * Free denomination key data.
  *
  * @param cls a `struct TEH_KeyStateHandle`, unused
  * @param pid the online signing key (type-disguised), unused
  * @param value a `struct SigningKey` to free
  * @return #GNUNET_OK (continue to iterate)
  */
 static enum GNUNET_GenericReturnValue
 clear_signkey_cb (void *cls,
                   const struct GNUNET_PeerIdentity *pid,
                   void *value)
 {
   struct SigningKey *sk = value;
 
   (void) cls;
   (void) pid;
   GNUNET_free (sk);
   return GNUNET_OK;
 }
 
 
 /**
  * Free resources associated with @a cls, possibly excluding
  * the helper data.
  *
  * @param[in] ksh key state to release
  */
 static void
 destroy_key_state (struct TEH_KeyStateHandle *ksh)
 {
   struct TEH_GlobalFee *gf;
 
   clear_response_cache (ksh);
   while (NULL != (gf = ksh->gf_head))
   {
     GNUNET_CONTAINER_DLL_remove (ksh->gf_head,
                                  ksh->gf_tail,
                                  gf);
     GNUNET_free (gf);
   }
   GNUNET_CONTAINER_multihashmap_iterate (ksh->denomkey_map,
                                          &clear_denomination_cb,
                                          ksh);
   GNUNET_CONTAINER_multihashmap_destroy (ksh->denomkey_map);
   GNUNET_CONTAINER_multihashmap32_destroy (ksh->denomserial_map);
   GNUNET_CONTAINER_multipeermap_iterate (ksh->signkey_map,
                                          &clear_signkey_cb,
                                          ksh);
   GNUNET_CONTAINER_multipeermap_destroy (ksh->signkey_map);
   json_decref (ksh->auditors);
   ksh->auditors = NULL;
   json_decref (ksh->global_fees);
   ksh->global_fees = NULL;
   if (NULL != ksh->management_keys_reply)
   {
     json_decref (ksh->management_keys_reply);
     ksh->management_keys_reply = NULL;
   }
   GNUNET_free (ksh);
 }
 
 
 /**
  * Function called whenever another exchange process has updated
  * the keys data in the database.
  *
  * @param cls NULL
  * @param extra unused
  * @param extra_size number of bytes in @a extra unused
  */
 static void
 keys_update_event_cb (void *cls,
                       const void *extra,
                       size_t extra_size)
 {
   (void) cls;
   (void) extra;
   (void) extra_size;
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "Received /keys update event\n");
   TEH_check_invariants ();
   key_generation++;
   TEH_resume_keys_requests (false);
   TEH_check_invariants ();
 }
 
 
 enum GNUNET_GenericReturnValue
 TEH_keys_init ()
 {
   if (GNUNET_OK !=
       TEH_SECMOD_setup_key_helpers ())
   {
     TEH_SECMOD_destroy_key_helpers ();
     return GNUNET_SYSERR;
   }
   if (GNUNET_OK !=
       GNUNET_CONFIGURATION_get_value_time (TEH_cfg,
                                            "exchange",
                                            "SIGNKEY_LEGAL_DURATION",
                                            &signkey_legal_duration))
   {
     GNUNET_log_config_missing (GNUNET_ERROR_TYPE_ERROR,
                                "exchange",
                                "SIGNKEY_LEGAL_DURATION");
     return GNUNET_SYSERR;
   }
   if (GNUNET_OK !=
       GNUNET_CONFIGURATION_get_value_string (TEH_cfg,
                                              "exchange",
                                              "ASSET_TYPE",
                                              &asset_type))
   {
     GNUNET_log_config_missing (GNUNET_ERROR_TYPE_WARNING,
                                "exchange",
                                "ASSET_TYPE");
     asset_type = GNUNET_strdup ("fiat");
   }
   {
     struct GNUNET_DB_EventHeaderP es = {
       .size = htons (sizeof (es)),
       .type = htons (TALER_DBEVENT_EXCHANGE_KEYS_UPDATED),
     };
 
     keys_eh = TALER_EXCHANGEDB_event_listen (TEH_pg,
                                              GNUNET_TIME_UNIT_FOREVER_REL,
                                              &es,
                                              &keys_update_event_cb,
                                              NULL);
     if (NULL == keys_eh)
     {
       GNUNET_break (0);
       return GNUNET_SYSERR;
     }
   }
   {
     struct GNUNET_DB_EventHeaderP es = {
       .size = htons (sizeof (es)),
       .type = htons (TALER_DBEVENT_EXCHANGE_KEYS_UPDATED),
     };
 
     wire_eh = TALER_EXCHANGEDB_event_listen (TEH_pg,
                                              GNUNET_TIME_UNIT_FOREVER_REL,
                                              &es,
                                              &wire_update_event_cb,
                                              NULL);
     if (NULL == wire_eh)
     {
       GNUNET_break (0);
       return GNUNET_SYSERR;
     }
   }
   return GNUNET_OK;
 }
 
 
 /**
  * Fully clean up our state.
  */
 void
 TEH_keys_finished ()
 {
   if (NULL != wire_state)
   {
     destroy_wire_state (wire_state);
     wire_state = NULL;
   }
   if (NULL != wire_eh)
   {
     TALER_EXCHANGEDB_event_listen_cancel (TEH_pg,
                                           wire_eh);
     wire_eh = NULL;
   }
   if (NULL != keys_tt)
   {
     GNUNET_SCHEDULER_cancel (keys_tt);
     keys_tt = NULL;
   }
   if (NULL != key_state)
     destroy_key_state (key_state);
   if (NULL != keys_eh)
   {
     TALER_EXCHANGEDB_event_listen_cancel (TEH_pg,
                                           keys_eh);
     keys_eh = NULL;
   }
   TEH_SECMOD_destroy_key_helpers ();
 }
 
 
 /**
  * Function called with information about the exchange's denomination keys.
  *
  * @param ksh closure with a `struct TEH_KeyStateHandle *`
  * @param denom_pub public key of the denomination
  * @param h_denom_pub hash of @a denom_pub
  * @param meta meta data information about the denomination type (value, expirations, fees)
  * @param master_sig master signature affirming the validity of this denomination
  * @param recoup_possible true if the key was revoked and clients can currently recoup
  *        coins of this denomination
  */
 static void
 denomination_info_cb (
   struct TEH_KeyStateHandle *ksh,
   const struct TALER_DenominationPublicKey *denom_pub,
   const struct TALER_DenominationHashP *h_denom_pub,
   const struct TALER_EXCHANGEDB_DenominationKeyMetaData *meta,
   const struct TALER_MasterSignatureP *master_sig,
   bool recoup_possible)
 {
   struct TEH_DenominationKey *dk;
 
   if (GNUNET_TIME_absolute_is_past (meta->expire_deposit.abs_time))
   {
     /* should have been filtered by DB query already! */
     GNUNET_break (0);
     return;
   }
   if (GNUNET_OK !=
       TALER_exchange_offline_denom_validity_verify (
         h_denom_pub,
         meta->start,
         meta->expire_withdraw,
         meta->expire_deposit,
         meta->expire_legal,
         &meta->value,
         &meta->fees,
         &TEH_master_public_key,
         master_sig))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Database has denomination with invalid signature. Skipping entry. Did the exchange offline public key change?\n");
     return;
   }
 
   GNUNET_assert (GNUNET_CRYPTO_BSA_INVALID !=
                  denom_pub->bsign_pub_key->cipher);
   if (GNUNET_TIME_absolute_is_zero (meta->start.abs_time) ||
       GNUNET_TIME_absolute_is_zero (meta->expire_withdraw.abs_time) ||
       GNUNET_TIME_absolute_is_zero (meta->expire_deposit.abs_time) ||
       GNUNET_TIME_absolute_is_zero (meta->expire_legal.abs_time) )
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Database contains invalid denomination key %s\n",
                 GNUNET_h2s (&h_denom_pub->hash));
     return;
   }
   dk = GNUNET_new (struct TEH_DenominationKey);
   TALER_denom_pub_copy (&dk->denom_pub,
                         denom_pub);
   dk->h_denom_pub = *h_denom_pub;
   dk->meta = *meta;
   dk->master_sig = *master_sig;
   dk->recoup_possible = recoup_possible;
   dk->denom_pub.age_mask = meta->age_mask;
 
   GNUNET_assert (
     GNUNET_OK ==
     GNUNET_CONTAINER_multihashmap_put (ksh->denomkey_map,
                                        &dk->h_denom_pub.hash,
                                        dk,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
   {
     uint32_t serial32 = (uint32_t) dk->meta.serial;
 
     GNUNET_assert (dk->meta.serial == (uint64_t) serial32);
     GNUNET_assert (
       GNUNET_OK ==
       GNUNET_CONTAINER_multihashmap32_put (ksh->denomserial_map,
                                            serial32,
                                            dk,
                                            GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
   }
 }
 
 
 /**
  * Function called with information about the exchange's online signing keys.
  *
  * @param ksh closure with a `struct TEH_KeyStateHandle *`
  * @param exchange_pub the public key
  * @param meta meta data information about the denomination type (expirations)
  * @param master_sig master signature affirming the validity of this denomination
  */
 static void
 signkey_info_cb (
   struct TEH_KeyStateHandle *ksh,
   const struct TALER_ExchangePublicKeyP *exchange_pub,
   const struct TALER_EXCHANGEDB_SignkeyMetaData *meta,
   const struct TALER_MasterSignatureP *master_sig)
 {
   struct SigningKey *sk;
   struct GNUNET_PeerIdentity pid;
 
   if (GNUNET_OK !=
       TALER_exchange_offline_signkey_validity_verify (
         exchange_pub,
         meta->start,
         meta->expire_sign,
         meta->expire_legal,
         &TEH_master_public_key,
         master_sig))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Database has signing key with invalid signature. Skipping entry. Did the exchange offline public key change?\n");
     return;
   }
   sk = GNUNET_new (struct SigningKey);
   sk->exchange_pub = *exchange_pub;
   sk->meta = *meta;
   sk->master_sig = *master_sig;
   pid.public_key = exchange_pub->eddsa_pub;
   GNUNET_assert (
     GNUNET_OK ==
     GNUNET_CONTAINER_multipeermap_put (ksh->signkey_map,
                                        &pid,
                                        sk,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
 }
 
 
 /**
  * Closure for #get_auditor_sigs.
  */
 struct GetAuditorSigsContext
 {
   /**
    * Where to store the matching signatures.
    */
   json_t *denom_keys;
 
   /**
    * Public key of the auditor to match against.
    */
   const struct TALER_AuditorPublicKeyP *auditor_pub;
 };
 
 
 /**
  * Extract the auditor signatures matching the auditor's public
  * key from the @a value and generate the respective JSON.
  *
  * @param cls a `struct GetAuditorSigsContext`
  * @param h_denom_pub hash of the denomination public key
  * @param value a `struct TEH_DenominationKey`
  * @return #GNUNET_OK (continue to iterate)
  */
 static enum GNUNET_GenericReturnValue
 get_auditor_sigs (void *cls,
                   const struct GNUNET_HashCode *h_denom_pub,
                   void *value)
 {
   struct GetAuditorSigsContext *ctx = cls;
   struct TEH_DenominationKey *dk = value;
 
   for (struct TEH_AuditorSignature *as = dk->as_head;
        NULL != as;
        as = as->next)
   {
     if (0 !=
         GNUNET_memcmp (ctx->auditor_pub,
                        &as->apub))
       continue;
     GNUNET_break (0 ==
                   json_array_append_new (
                     ctx->denom_keys,
                     GNUNET_JSON_PACK (
                       GNUNET_JSON_pack_data_auto ("denom_pub_h",
                                                   h_denom_pub),
                       GNUNET_JSON_pack_data_auto ("auditor_sig",
                                                   &as->asig))));
   }
   return GNUNET_OK;
 }
 
 
 /**
  * Function called with information about the exchange's auditors.
  *
  * @param ksh closure with a `struct TEH_KeyStateHandle *`
  * @param auditor_pub the public key of the auditor
  * @param auditor_url URL of the REST API of the auditor
  * @param auditor_name human readable official name of the auditor
  */
 static void
 auditor_info_cb (
   struct TEH_KeyStateHandle *ksh,
   const struct TALER_AuditorPublicKeyP *auditor_pub,
   const char *auditor_url,
   const char *auditor_name)
 {
   struct GetAuditorSigsContext ctx;
 
   ctx.denom_keys = json_array ();
   GNUNET_assert (NULL != ctx.denom_keys);
   ctx.auditor_pub = auditor_pub;
   GNUNET_CONTAINER_multihashmap_iterate (ksh->denomkey_map,
                                          &get_auditor_sigs,
                                          &ctx);
   GNUNET_break (0 ==
                 json_array_append_new (
                   ksh->auditors,
                   GNUNET_JSON_PACK (
                     GNUNET_JSON_pack_string ("auditor_name",
                                              auditor_name),
                     GNUNET_JSON_pack_data_auto ("auditor_pub",
                                                 auditor_pub),
                     GNUNET_JSON_pack_string ("auditor_url",
                                              auditor_url),
                     GNUNET_JSON_pack_array_steal ("denomination_keys",
                                                   ctx.denom_keys))));
 }
 
 
 /**
  * Function called with information about the denominations
  * audited by the exchange's auditors.
  *
  * @param ksh closure with a `struct TEH_KeyStateHandle *`
  * @param auditor_pub the public key of an auditor
  * @param h_denom_pub hash of a denomination key audited by this auditor
  * @param auditor_sig signature from the auditor affirming this
  */
 static void
 auditor_denom_cb (
   struct TEH_KeyStateHandle *ksh,
   const struct TALER_AuditorPublicKeyP *auditor_pub,
   const struct TALER_DenominationHashP *h_denom_pub,
   const struct TALER_AuditorSignatureP *auditor_sig)
 {
   struct TEH_DenominationKey *dk;
   struct TEH_AuditorSignature *as;
 
   dk = GNUNET_CONTAINER_multihashmap_get (ksh->denomkey_map,
                                           &h_denom_pub->hash);
   if (NULL == dk)
   {
     /* Odd, this should be impossible as per foreign key
        constraint on 'auditor_denom_sigs'! Well, we can
        safely continue anyway, so let's just log it. */
     GNUNET_break (0);
     return;
   }
   as = GNUNET_new (struct TEH_AuditorSignature);
   as->asig = *auditor_sig;
   as->apub = *auditor_pub;
   GNUNET_CONTAINER_DLL_insert (dk->as_head,
                                dk->as_tail,
                                as);
 }
 
 
 /**
  * Closure for #add_sign_key_cb.
  */
 struct SignKeyCtx
 {
   /**
    * What is the current rotation frequency for signing keys. Updated.
    */
   struct GNUNET_TIME_Relative min_sk_frequency;
 
   /**
    * JSON array of signing keys (being created).
    */
   json_t *signkeys;
 };
 
 
 /**
  * Function called for all signing keys, used to build up the
  * respective JSON response.
  *
  * @param cls a `struct SignKeyCtx *` with the array to append keys to
  * @param pid the exchange public key (in type disguise)
  * @param value a `struct SigningKey`
  * @return #GNUNET_OK (continue to iterate)
  */
 static enum GNUNET_GenericReturnValue
 add_sign_key_cb (void *cls,
                  const struct GNUNET_PeerIdentity *pid,
                  void *value)
 {
   struct SignKeyCtx *ctx = cls;
   struct SigningKey *sk = value;
 
   (void) pid;
   if (GNUNET_TIME_absolute_is_future (sk->meta.expire_sign.abs_time))
   {
     ctx->min_sk_frequency =
       GNUNET_TIME_relative_min (ctx->min_sk_frequency,
                                 GNUNET_TIME_absolute_get_difference (
                                   sk->meta.start.abs_time,
                                   sk->meta.expire_sign.abs_time));
   }
   GNUNET_assert (
     0 ==
     json_array_append_new (
       ctx->signkeys,
       GNUNET_JSON_PACK (
         GNUNET_JSON_pack_timestamp ("stamp_start",
                                     sk->meta.start),
         GNUNET_JSON_pack_timestamp ("stamp_expire",
                                     sk->meta.expire_sign),
         GNUNET_JSON_pack_timestamp ("stamp_end",
                                     sk->meta.expire_legal),
         GNUNET_JSON_pack_data_auto ("master_sig",
                                     &sk->master_sig),
         GNUNET_JSON_pack_data_auto ("key",
                                     &sk->exchange_pub))));
   return GNUNET_OK;
 }
 
 
 /**
  * Closure for #add_denom_key_cb.
  */
 struct DenomKeyCtx
 {
   /**
    * Heap for sorting active denomination keys by start time.
    */
   struct GNUNET_CONTAINER_Heap *heap;
 
   /**
    * JSON array of revoked denomination keys.
    */
   json_t *recoup;
 
   /**
    * What is the minimum key rotation frequency of
    * valid denomination keys?
    */
   struct GNUNET_TIME_Relative min_dk_frequency;
 };
 
 
 /**
  * Function called for all denomination keys, used to build up the
  * JSON list of *revoked* denomination keys and the
  * heap of non-revoked denomination keys by timeout.
  *
  * @param cls a `struct DenomKeyCtx`
  * @param h_denom_pub hash of the denomination key
  * @param value a `struct TEH_DenominationKey`
  * @return #GNUNET_OK (continue to iterate)
  */
 static enum GNUNET_GenericReturnValue
 add_denom_key_cb (void *cls,
                   const struct GNUNET_HashCode *h_denom_pub,
                   void *value)
 {
   struct DenomKeyCtx *dkc = cls;
   struct TEH_DenominationKey *dk = value;
 
   if (dk->recoup_possible)
   {
     GNUNET_assert (
       0 ==
       json_array_append_new (
         dkc->recoup,
         GNUNET_JSON_PACK (
           GNUNET_JSON_pack_data_auto ("h_denom_pub",
                                       h_denom_pub))));
   }
   else
   {
     if (GNUNET_TIME_absolute_is_future (dk->meta.start.abs_time))
     {
       dkc->min_dk_frequency =
         GNUNET_TIME_relative_min (dkc->min_dk_frequency,
                                   GNUNET_TIME_absolute_get_difference (
                                     dk->meta.start.abs_time,
                                     dk->meta.expire_withdraw.abs_time));
     }
     (void) GNUNET_CONTAINER_heap_insert (dkc->heap,
                                          dk,
                                          dk->meta.start.abs_time.abs_value_us);
   }
   return GNUNET_OK;
 }
 
 
 /**
  * Add the headers we want to set for every /keys response.
  *
  * @param cls the key state to use
  * @param[in,out] response the response to modify
  */
 static void
 setup_general_response_headers (void *cls,
                                 struct MHD_Response *response)
 {
   struct TEH_KeyStateHandle *ksh = cls;
   char dat[128];
 
   TALER_MHD_add_global_headers (response,
                                 true);
   GNUNET_break (MHD_YES ==
                 MHD_add_response_header (response,
                                          MHD_HTTP_HEADER_CONTENT_TYPE,
                                          "application/json"));
   GNUNET_break (MHD_YES ==
                 MHD_add_response_header (response,
                                          MHD_HTTP_HEADER_CACHE_CONTROL,
                                          "public,must-revalidate,max-age=86400")
                 );
   if (! GNUNET_TIME_relative_is_zero (ksh->rekey_frequency))
   {
     struct GNUNET_TIME_Relative r;
     struct GNUNET_TIME_Absolute a;
     struct GNUNET_TIME_Timestamp km;
     struct GNUNET_TIME_Timestamp m;
     struct GNUNET_TIME_Timestamp we;
 
     r = GNUNET_TIME_relative_min (TEH_max_keys_caching,
                                   ksh->rekey_frequency);
     a = GNUNET_TIME_relative_to_absolute (r);
     /* Round up to next full day to ensure the expiration
        time does not become a fingerprint! */
     a = GNUNET_TIME_absolute_round_down (a,
                                          GNUNET_TIME_UNIT_DAYS);
     a = GNUNET_TIME_absolute_add (a,
                                   GNUNET_TIME_UNIT_DAYS);
     km = GNUNET_TIME_absolute_to_timestamp (a);
     we = GNUNET_TIME_absolute_to_timestamp (wire_state->cache_expiration);
     m = GNUNET_TIME_timestamp_min (we,
                                    km);
     TALER_MHD_get_date_string (m.abs_time,
                                dat);
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "Setting /keys 'Expires' header to '%s' (rekey frequency is %s)\n",
                 dat,
                 GNUNET_TIME_relative2s (ksh->rekey_frequency,
                                         false));
     GNUNET_break (MHD_YES ==
                   MHD_add_response_header (response,
                                            MHD_HTTP_HEADER_EXPIRES,
                                            dat));
     ksh->signature_expires
       = GNUNET_TIME_timestamp_min (m,
                                    ksh->signature_expires);
   }
   /* Set cache control headers: our response varies depending on these headers */
   GNUNET_break (MHD_YES ==
                 MHD_add_response_header (response,
                                          MHD_HTTP_HEADER_VARY,
                                          MHD_HTTP_HEADER_ACCEPT_ENCODING));
 }
 
 
 /**
  * Initialize @a krd using the given values for @a signkeys,
  * @a recoup and @a denoms.
  *
  * @param[in,out] ksh key state handle we build @a krd for
  * @param[in] denom_keys_hash hash over all the denomination keys in @a denoms
  * @param last_cherry_pick_date timestamp to use
  * @param[in,out] signkeys list of sign keys to return
  * @param[in,out] recoup list of revoked keys to return
  * @param[in,out] grouped_denominations list of grouped denominations to return
  * @return #GNUNET_OK on success
  */
 static enum GNUNET_GenericReturnValue
 create_krd (struct TEH_KeyStateHandle *ksh,
             const struct GNUNET_HashCode *denom_keys_hash,
             struct GNUNET_TIME_Timestamp last_cherry_pick_date,
             json_t *signkeys,
             json_t *recoup,
             json_t *grouped_denominations)
 {
   struct KeysResponseData krd;
   struct TALER_ExchangePublicKeyP exchange_pub;
   struct TALER_ExchangeSignatureP exchange_sig;
   struct WireStateHandle *wsh;
   json_t *keys;
 
   wsh = get_wire_state ();
   if (! wsh->ready)
   {
     GNUNET_break (0);
     return GNUNET_SYSERR;
   }
   GNUNET_assert (! GNUNET_TIME_absolute_is_zero (
                    last_cherry_pick_date.abs_time));
   GNUNET_assert (NULL != signkeys);
   GNUNET_assert (NULL != recoup);
   GNUNET_assert (NULL != grouped_denominations);
   GNUNET_assert (NULL != ksh->auditors);
   GNUNET_assert (NULL != TEH_currency);
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Creating /keys at cherry pick date %s\n",
               GNUNET_TIME_timestamp2s (last_cherry_pick_date));
 
   /* Sign hash over master signatures of all denomination keys until this time
      (in reverse order). */
   {
     enum TALER_ErrorCode ec;
 
     if (TALER_EC_NONE !=
         (ec =
            TALER_exchange_online_key_set_sign (
              &TEH_keys_exchange_sign2_,
              ksh,
              last_cherry_pick_date,
              denom_keys_hash,
              &exchange_pub,
              &exchange_sig)))
     {
       GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                   "Could not create key response data: cannot sign (%s)\n",
                   TALER_ErrorCode_get_hint (ec));
       return GNUNET_SYSERR;
     }
   }
 
   {
     const struct SigningKey *sk;
 
     sk = GNUNET_CONTAINER_multipeermap_get (
       ksh->signkey_map,
       (const struct GNUNET_PeerIdentity *) &exchange_pub);
     GNUNET_assert (NULL != sk);
     ksh->signature_expires = GNUNET_TIME_timestamp_min (sk->meta.expire_sign,
                                                         ksh->signature_expires);
   }
 
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "Build /keys data with %u wire accounts\n",
               (unsigned int) json_array_size (
                 json_object_get (wsh->json_reply,
                                  "accounts")));
 
   keys = GNUNET_JSON_PACK (
     GNUNET_JSON_pack_string ("version",
                              EXCHANGE_PROTOCOL_VERSION),
     GNUNET_JSON_pack_string ("base_url",
                              TEH_base_url),
     GNUNET_JSON_pack_string ("currency",
                              TEH_currency),
     GNUNET_JSON_pack_allow_null (
       GNUNET_JSON_pack_string (
         "bank_compliance_language",
         TEH_bank_compliance_language)),
     GNUNET_JSON_pack_object_steal (
       "currency_specification",
       TALER_JSON_currency_specs_to_json (TEH_cspec)),
     GNUNET_JSON_pack_array_incref (
       "hard_limits",
       TEH_hard_limits),
     GNUNET_JSON_pack_array_incref (
       "zero_limits",
       TEH_zero_limits),
     TALER_JSON_pack_amount ("stefan_abs",
                             &TEH_stefan_abs),
     TALER_JSON_pack_amount ("stefan_log",
                             &TEH_stefan_log),
     GNUNET_JSON_pack_double ("stefan_lin",
                              (double) TEH_stefan_lin),
     GNUNET_JSON_pack_string ("asset_type",
                              asset_type),
     GNUNET_JSON_pack_bool ("kyc_enabled",
                            GNUNET_YES == TEH_enable_kyc),
     GNUNET_JSON_pack_bool ("kyc_swap_tos_acceptance",
                            GNUNET_YES == TEH_kyc_swap_tos_acceptance),
     GNUNET_JSON_pack_bool ("disable_direct_deposit",
                            GNUNET_YES == TEH_disable_direct_deposit),
     GNUNET_JSON_pack_bool ("rewards_allowed",
                            false),
     GNUNET_JSON_pack_data_auto ("master_public_key",
                                 &TEH_master_public_key),
     GNUNET_JSON_pack_time_rel ("reserve_closing_delay",
                                TEH_reserve_closing_delay),
     GNUNET_JSON_pack_time_rel ("default_p2p_push_expiration",
                                TEH_default_p2p_expiration),
     GNUNET_JSON_pack_array_incref ("signkeys",
                                    signkeys),
     GNUNET_JSON_pack_array_incref ("recoup",
                                    recoup),
     GNUNET_JSON_pack_array_incref ("wads",
                                    json_object_get (wsh->json_reply,
                                                     "wads")),
     GNUNET_JSON_pack_array_incref ("accounts",
                                    json_object_get (wsh->json_reply,
                                                     "accounts")),
     GNUNET_JSON_pack_object_incref ("wire_fees",
                                     json_object_get (wsh->json_reply,
                                                      "fees")),
     GNUNET_JSON_pack_array_incref ("denominations",
                                    grouped_denominations),
     GNUNET_JSON_pack_array_incref ("auditors",
                                    ksh->auditors),
     GNUNET_JSON_pack_array_incref ("global_fees",
                                    ksh->global_fees),
     GNUNET_JSON_pack_timestamp ("list_issue_date",
                                 last_cherry_pick_date),
     GNUNET_JSON_pack_allow_null (
       GNUNET_JSON_pack_array_steal (
         "wallet_balance_limit_without_kyc",
         TALER_KYCLOGIC_get_wallet_thresholds ())),
     GNUNET_JSON_pack_allow_null (
       GNUNET_JSON_pack_string ("shopping_url",
                                TEH_shopping_url)),
     TALER_JSON_pack_amount ("tiny_amount",
                             &TEH_tiny_amount),
     GNUNET_JSON_pack_data_auto ("exchange_pub",
                                 &exchange_pub),
     GNUNET_JSON_pack_data_auto ("exchange_sig",
                                 &exchange_sig));
   GNUNET_assert (NULL != keys);
 
   {
     char *keys_json;
     void *keys_jsonz;
     size_t keys_jsonz_size;
     int comp;
     char etag[sizeof (struct GNUNET_HashCode) * 2];
 
     /* Convert /keys response to UTF8-String */
     keys_json = json_dumps (keys,
                             JSON_INDENT (2));
     json_decref (keys);
     GNUNET_assert (NULL != keys_json);
 
     /* Keep copy for later compression... */
     keys_jsonz = GNUNET_strdup (keys_json);
     keys_jsonz_size = strlen (keys_json);
 
     /* hash to compute etag */
     {
       struct GNUNET_HashCode ehash;
       char *end;
 
       GNUNET_CRYPTO_hash (keys_jsonz,
                           keys_jsonz_size,
                           &ehash);
       end = GNUNET_STRINGS_data_to_string (&ehash,
                                            sizeof (ehash),
                                            etag,
                                            sizeof (etag));
       *end = '\0';
     }
 
     /* Create uncompressed response */
     krd.response_uncompressed
       = MHD_create_response_from_buffer (keys_jsonz_size,
                                          keys_json,
                                          MHD_RESPMEM_MUST_FREE);
     GNUNET_assert (NULL != krd.response_uncompressed);
     setup_general_response_headers (ksh,
                                     krd.response_uncompressed);
     /* Information is always public, revalidate after 1 day */
     GNUNET_break (MHD_YES ==
                   MHD_add_response_header (krd.response_uncompressed,
                                            MHD_HTTP_HEADER_ETAG,
                                            etag));
     /* Also compute compressed version of /keys response */
     comp = TALER_MHD_body_compress (&keys_jsonz,
                                     &keys_jsonz_size);
     krd.response_compressed
       = MHD_create_response_from_buffer (keys_jsonz_size,
                                          keys_jsonz,
                                          MHD_RESPMEM_MUST_FREE);
     GNUNET_assert (NULL != krd.response_compressed);
     /* If the response is actually compressed, set the
        respective header. */
     GNUNET_assert ( (MHD_YES != comp) ||
                     (MHD_YES ==
                      MHD_add_response_header (krd.response_compressed,
                                               MHD_HTTP_HEADER_CONTENT_ENCODING,
                                               "deflate")) );
     setup_general_response_headers (ksh,
                                     krd.response_compressed);
     /* Information is always public, revalidate after 1 day */
     GNUNET_break (MHD_YES ==
                   MHD_add_response_header (krd.response_compressed,
                                            MHD_HTTP_HEADER_ETAG,
                                            etag));
     krd.etag = GNUNET_strdup (etag);
   }
   krd.cherry_pick_date = last_cherry_pick_date;
   GNUNET_array_append (ksh->krd_array,
                        ksh->krd_array_length,
                        krd);
   return GNUNET_OK;
 }
 
 
 /**
  * Element in the `struct SignatureContext` array.
  */
 struct SignatureElement
 {
 
   /**
    * Offset of the denomination in the group array,
    * for sorting (2nd rank, ascending).
    */
   unsigned int offset;
 
   /**
    * Offset of the group in the denominations array,
    * for sorting (2nd rank, ascending).
    */
   unsigned int group_offset;
 
   /**
    * Pointer to actual master signature to hash over.
    */
   struct TALER_MasterSignatureP master_sig;
 };
 
 /**
  * Context for collecting the array of master signatures
  * needed to verify the exchange_sig online signature.
  */
 struct SignatureContext
 {
   /**
    * Array of signatures to hash over.
    */
   struct SignatureElement *elements;
 
   /**
    * Write offset in the @e elements array.
    */
   unsigned int elements_pos;
 
   /**
    * Allocated space for @e elements.
    */
   unsigned int elements_size;
 };
 
 
 /**
  * Determine order to sort two elements by before
  * we hash the master signatures.  Used for
  * sorting with qsort().
  *
  * @param a pointer to a `struct SignatureElement`
  * @param b pointer to a `struct SignatureElement`
  * @return 0 if equal, -1 if a < b, 1 if a > b.
  */
 static int
 signature_context_sort_cb (const void *a,
                            const void *b)
 {
   const struct SignatureElement *sa = a;
   const struct SignatureElement *sb = b;
 
   if (sa->group_offset < sb->group_offset)
     return -1;
   if (sa->group_offset > sb->group_offset)
     return 1;
   if (sa->offset < sb->offset)
     return -1;
   if (sa->offset > sb->offset)
     return 1;
   /* We should never have two disjoint elements
      with same time and offset */
   GNUNET_assert (sa == sb);
   return 0;
 }
 
 
 /**
  * Append a @a master_sig to the @a sig_ctx using the
  * given attributes for (later) sorting.
  *
  * @param[in,out] sig_ctx signature context to update
  * @param group_offset offset for the group
  * @param offset offset for the entry
  * @param master_sig master signature for the entry
  */
 static void
 append_signature (struct SignatureContext *sig_ctx,
                   unsigned int group_offset,
                   unsigned int offset,
                   const struct TALER_MasterSignatureP *master_sig)
 {
   struct SignatureElement *element;
   unsigned int new_size;
 
   if (sig_ctx->elements_pos == sig_ctx->elements_size)
   {
     if (0 == sig_ctx->elements_size)
       new_size = 1024;
     else
       new_size = sig_ctx->elements_size * 2;
     GNUNET_array_grow (sig_ctx->elements,
                        sig_ctx->elements_size,
                        new_size);
   }
   element = &sig_ctx->elements[sig_ctx->elements_pos++];
   element->offset = offset;
   element->group_offset = group_offset;
   element->master_sig = *master_sig;
 }
 
 
 /**
  * GroupData is the value we store for each group meta-data
  */
 struct GroupData
 {
   /**
    * The json blob with the group meta-data and list of denominations
    */
   json_t *json;
 
   /**
    * List of denominations for the group,
    * included in @e json, do not free separately!
    */
   json_t *list;
 
   /**
    * Offset of the group in the final array.
    */
   unsigned int group_off;
 
 };
 
 
 /**
  * Helper function called to clean up the group data
  * in the denominations_by_group below.
  *
  * @param cls unused
  * @param key unused
  * @param value a `struct GroupData` to free
  * @return #GNUNET_OK
  */
 static int
 free_group (void *cls,
             const struct GNUNET_HashCode *key,
             void *value)
 {
   struct GroupData *gd = value;
 
   (void) cls;
   (void) key;
   GNUNET_free (gd);
   return GNUNET_OK;
 }
 
 
 static void
 compute_msig_hash (struct SignatureContext *sig_ctx,
                    struct GNUNET_HashCode *hc)
 {
   struct GNUNET_HashContext *hash_context;
 
   hash_context = GNUNET_CRYPTO_hash_context_start ();
   qsort (sig_ctx->elements,
          sig_ctx->elements_pos,
          sizeof (struct SignatureElement),
          &signature_context_sort_cb);
   for (unsigned int i = 0; i<sig_ctx->elements_pos; i++)
   {
     struct SignatureElement *element = &sig_ctx->elements[i];
 
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Adding %u,%u,%s\n",
                 element->group_offset,
                 element->offset,
                 TALER_B2S (&element->master_sig));
     GNUNET_CRYPTO_hash_context_read (hash_context,
                                      &element->master_sig,
                                      sizeof (element->master_sig));
   }
   GNUNET_CRYPTO_hash_context_finish (hash_context,
                                      hc);
 }
 
 
 /**
  * Update the "/keys" responses in @a ksh, computing the detailed replies.
  *
  * This function is to recompute all (including cherry-picked) responses we
  * might want to return, based on the state already in @a ksh.
  *
  * @param[in,out] ksh state handle to update
  * @return #GNUNET_OK on success
  */
 static enum GNUNET_GenericReturnValue
 finish_keys_response (struct TEH_KeyStateHandle *ksh)
 {
   enum GNUNET_GenericReturnValue ret = GNUNET_SYSERR;
   json_t *recoup;
   struct SignKeyCtx sctx = {
     .min_sk_frequency = GNUNET_TIME_UNIT_FOREVER_REL
   };
   json_t *grouped_denominations = NULL;
   struct GNUNET_TIME_Timestamp last_cherry_pick_date;
   struct GNUNET_CONTAINER_Heap *heap;
   struct SignatureContext sig_ctx = { 0 };
   /* Remember if we have any denomination with age restriction */
   bool has_age_restricted_denomination = false;
   struct WireStateHandle *wsh;
 
   wsh = get_wire_state ();
   if (! wsh->ready)
   {
     GNUNET_break (0);
     return GNUNET_SYSERR;
   }
   if (0 ==
       json_array_size (json_object_get (wsh->json_reply,
                                         "accounts")) )
   {
     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                 "No wire accounts available. Refusing to generate /keys response.\n");
     return GNUNET_NO;
   }
   sctx.signkeys = json_array ();
   GNUNET_assert (NULL != sctx.signkeys);
   recoup = json_array ();
   GNUNET_assert (NULL != recoup);
   grouped_denominations = json_array ();
   GNUNET_assert (NULL != grouped_denominations);
 
   GNUNET_CONTAINER_multipeermap_iterate (ksh->signkey_map,
                                          &add_sign_key_cb,
                                          &sctx);
   if (0 == json_array_size (sctx.signkeys))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                 "No online signing keys available. Refusing to generate /keys response.\n");
     ret = GNUNET_NO;
     goto CLEANUP;
   }
   heap = GNUNET_CONTAINER_heap_create (GNUNET_CONTAINER_HEAP_ORDER_MAX);
   {
     struct DenomKeyCtx dkc = {
       .recoup = recoup,
       .heap = heap,
       .min_dk_frequency = GNUNET_TIME_UNIT_FOREVER_REL,
     };
 
     GNUNET_CONTAINER_multihashmap_iterate (ksh->denomkey_map,
                                            &add_denom_key_cb,
                                            &dkc);
     ksh->rekey_frequency
       = GNUNET_TIME_relative_min (dkc.min_dk_frequency,
                                   sctx.min_sk_frequency);
   }
 
   last_cherry_pick_date = GNUNET_TIME_UNIT_ZERO_TS;
 
   {
     struct TEH_DenominationKey *dk;
     struct GNUNET_CONTAINER_MultiHashMap *denominations_by_group;
 
     denominations_by_group =
       GNUNET_CONTAINER_multihashmap_create (1024,
                                             GNUNET_NO /* NO, because keys are only on the stack */
                                             );
     /* heap = max heap, sorted by start time */
     while (NULL != (dk = GNUNET_CONTAINER_heap_remove_root (heap)))
     {
       if (GNUNET_TIME_timestamp_cmp (last_cherry_pick_date,
                                      !=,
                                      dk->meta.start) &&
           (! GNUNET_TIME_absolute_is_zero (last_cherry_pick_date.abs_time)) )
       {
         /*
          * This is not the first entry in the heap (because last_cherry_pick_date !=
          * GNUNET_TIME_UNIT_ZERO_TS) and the previous entry had a different
          * start time.  Therefore, we create a new entry in ksh.
          */
         struct GNUNET_HashCode hc;
 
         compute_msig_hash (&sig_ctx,
                            &hc);
         if (GNUNET_OK !=
             create_krd (ksh,
                         &hc,
                         last_cherry_pick_date,
                         sctx.signkeys,
                         recoup,
                         grouped_denominations))
         {
           GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                       "Failed to generate key response data for %s\n",
                       GNUNET_TIME_timestamp2s (last_cherry_pick_date));
           /* drain heap before destroying it */
           while (NULL != (dk = GNUNET_CONTAINER_heap_remove_root (heap)))
             /* intentionally empty */;
           GNUNET_CONTAINER_heap_destroy (heap);
           goto CLEANUP;
         }
       }
 
       last_cherry_pick_date = dk->meta.start;
       /*
        * Group the denominations by {cipher, value, fees, age_mask}.
        *
        * For each group we save the group meta-data and the list of
        * denominations in this group as a json-blob in the multihashmap
        * denominations_by_group.
        */
       {
         struct GroupData *group;
         json_t *entry;
         struct GNUNET_HashCode key;
         struct TALER_DenominationGroup meta = {
           .cipher = dk->denom_pub.bsign_pub_key->cipher,
           .value = dk->meta.value,
           .fees = dk->meta.fees,
           .age_mask = dk->meta.age_mask,
         };
 
         /* Search the group/JSON-blob for the key */
         TALER_denomination_group_get_key (&meta,
                                           &key);
         group = GNUNET_CONTAINER_multihashmap_get (
           denominations_by_group,
           &key);
         if (NULL == group)
         {
           /* There is no group for this meta-data yet, so we create a new group */
           bool age_restricted = meta.age_mask.bits != 0;
           const char *cipher;
 
           group = GNUNET_new (struct GroupData);
           switch (meta.cipher)
           {
           case GNUNET_CRYPTO_BSA_RSA:
             cipher = age_restricted ? "RSA+age_restricted" : "RSA";
             break;
           case GNUNET_CRYPTO_BSA_CS:
             cipher = age_restricted ? "CS+age_restricted" : "CS";
             break;
           default:
             GNUNET_assert (false);
           }
           /* Create a new array for the denominations in this group */
           group->list = json_array ();
           GNUNET_assert (NULL != group->list);
           group->json = GNUNET_JSON_PACK (
             GNUNET_JSON_pack_string ("cipher",
                                      cipher),
             GNUNET_JSON_pack_array_steal ("denoms",
                                           group->list),
             TALER_JSON_PACK_DENOM_FEES ("fee",
                                         &meta.fees),
             TALER_JSON_pack_amount ("value",
                                     &meta.value));
           GNUNET_assert (NULL != group->json);
           if (age_restricted)
           {
             GNUNET_assert (
               0 ==
               json_object_set_new (group->json,
                                    "age_mask",
                                    json_integer (
                                      meta.age_mask.bits)));
             /* Remember that we have found at least _one_ age restricted denomination */
             has_age_restricted_denomination = true;
           }
           group->group_off
             = json_array_size (grouped_denominations);
           GNUNET_assert (0 ==
                          json_array_append_new (
                            grouped_denominations,
                            group->json));
           GNUNET_assert (
             GNUNET_OK ==
             GNUNET_CONTAINER_multihashmap_put (denominations_by_group,
                                                &key,
                                                group,
                                                GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
         }
 
         /* Now that we have found/created the right group, add the
            denomination to the list */
         {
           struct GNUNET_JSON_PackSpec key_spec;
           bool private_key_lost;
 
           private_key_lost
             = TEH_SECMOD_denom_priv_check_lost (&dk->h_denom_pub);
           switch (meta.cipher)
           {
           case GNUNET_CRYPTO_BSA_RSA:
             key_spec =
               GNUNET_JSON_pack_rsa_public_key (
                 "rsa_pub",
                 dk->denom_pub.bsign_pub_key->details.rsa_public_key);
             break;
           case GNUNET_CRYPTO_BSA_CS:
             key_spec =
               GNUNET_JSON_pack_data_varsize (
                 "cs_pub",
                 &dk->denom_pub.bsign_pub_key->details.cs_public_key,
                 sizeof (dk->denom_pub.bsign_pub_key->details.cs_public_key));
             break;
           default:
             GNUNET_assert (false);
           }
 
           entry = GNUNET_JSON_PACK (
             GNUNET_JSON_pack_data_auto ("master_sig",
                                         &dk->master_sig),
             GNUNET_JSON_pack_allow_null (
               private_key_lost
               ? GNUNET_JSON_pack_bool ("lost",
                                        true)
               : GNUNET_JSON_pack_string ("dummy",
                                          NULL)),
             GNUNET_JSON_pack_timestamp ("stamp_start",
                                         dk->meta.start),
             GNUNET_JSON_pack_timestamp ("stamp_expire_withdraw",
                                         dk->meta.expire_withdraw),
             GNUNET_JSON_pack_timestamp ("stamp_expire_deposit",
                                         dk->meta.expire_deposit),
             GNUNET_JSON_pack_timestamp ("stamp_expire_legal",
                                         dk->meta.expire_legal),
             key_spec
             );
           GNUNET_assert (NULL != entry);
         }
 
         /* Build up the running hash of all master signatures of the
            denominations */
         append_signature (&sig_ctx,
                           group->group_off,
                           (unsigned int) json_array_size (group->list),
                           &dk->master_sig);
         /* Finally, add the denomination to the list of denominations in this
            group */
         GNUNET_assert (json_is_array (group->list));
         GNUNET_assert (0 ==
                        json_array_append_new (group->list,
                                               entry));
       }
     } /* loop over heap ends */
 
     GNUNET_CONTAINER_multihashmap_iterate (denominations_by_group,
                                            &free_group,
                                            NULL);
     GNUNET_CONTAINER_multihashmap_destroy (denominations_by_group);
   }
   GNUNET_CONTAINER_heap_destroy (heap);
 
   if (! GNUNET_TIME_absolute_is_zero (last_cherry_pick_date.abs_time))
   {
     struct GNUNET_HashCode hc;
 
     compute_msig_hash (&sig_ctx,
                        &hc);
     if (GNUNET_OK !=
         create_krd (ksh,
                     &hc,
                     last_cherry_pick_date,
                     sctx.signkeys,
                     recoup,
                     grouped_denominations))
     {
       GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                   "Failed to generate key response data for %s\n",
                   GNUNET_TIME_timestamp2s (last_cherry_pick_date));
       goto CLEANUP;
     }
     ksh->management_only = false;
 
     /* Sanity check:  Make sure that age restriction is enabled IFF at least
      * one age restricted denomination exist */
     if (! has_age_restricted_denomination && TEH_age_restriction_enabled)
     {
       GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                   "Age restriction is enabled, but NO denominations with age restriction found!\n");
       goto CLEANUP;
     }
     else if (has_age_restricted_denomination && ! TEH_age_restriction_enabled)
     {
       GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                   "Age restriction is NOT enabled, but denominations with age restriction found!\n")
       ;
       goto CLEANUP;
     }
   }
   else
   {
     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                 "No denomination keys available. Refusing to generate /keys response.\n");
   }
   ret = GNUNET_OK;
 
 CLEANUP:
   GNUNET_array_grow (sig_ctx.elements,
                      sig_ctx.elements_size,
                      0);
   json_decref (grouped_denominations);
   if (NULL != sctx.signkeys)
     json_decref (sctx.signkeys);
   json_decref (recoup);
   return ret;
 }
 
 
 /**
  * Called with information about global fees.
  *
  * @param ksh `struct TEH_KeyStateHandle *` we are building
  * @param fees the global fees we charge
  * @param purse_timeout when do purses time out
  * @param history_expiration how long are account histories preserved
  * @param purse_account_limit how many purses are free per account
  * @param start_date from when are these fees valid (start date)
  * @param end_date until when are these fees valid (end date, exclusive)
  * @param master_sig master key signature affirming that this is the correct
  *                   fee (of purpose #TALER_SIGNATURE_MASTER_GLOBAL_FEES)
  */
 static void
 global_fee_info_cb (
   struct TEH_KeyStateHandle *ksh,
   const struct TALER_GlobalFeeSet *fees,
   struct GNUNET_TIME_Relative purse_timeout,
   struct GNUNET_TIME_Relative history_expiration,
   uint32_t purse_account_limit,
   struct GNUNET_TIME_Timestamp start_date,
   struct GNUNET_TIME_Timestamp end_date,
   const struct TALER_MasterSignatureP *master_sig)
 {
   struct TEH_GlobalFee *gf;
 
   if (GNUNET_OK !=
       TALER_exchange_offline_global_fee_verify (
         start_date,
         end_date,
         fees,
         purse_timeout,
         history_expiration,
         purse_account_limit,
         &TEH_master_public_key,
         master_sig))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Database has global fee with invalid signature. Skipping entry. Did the exchange offline public key change?\n");
     return;
   }
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "Found global fees with %u purses\n",
               purse_account_limit);
   gf = GNUNET_new (struct TEH_GlobalFee);
   gf->start_date = start_date;
   gf->end_date = end_date;
   gf->fees = *fees;
   gf->purse_timeout = purse_timeout;
   gf->history_expiration = history_expiration;
   gf->purse_account_limit = purse_account_limit;
   gf->master_sig = *master_sig;
   GNUNET_CONTAINER_DLL_insert (ksh->gf_head,
                                ksh->gf_tail,
                                gf);
   GNUNET_assert (
     0 ==
     json_array_append_new (
       ksh->global_fees,
       GNUNET_JSON_PACK (
         GNUNET_JSON_pack_timestamp ("start_date",
                                     start_date),
         GNUNET_JSON_pack_timestamp ("end_date",
                                     end_date),
         TALER_JSON_PACK_GLOBAL_FEES (fees),
         GNUNET_JSON_pack_time_rel ("history_expiration",
                                    history_expiration),
         GNUNET_JSON_pack_time_rel ("purse_timeout",
                                    purse_timeout),
         GNUNET_JSON_pack_uint64 ("purse_account_limit",
                                  purse_account_limit),
         GNUNET_JSON_pack_data_auto ("master_sig",
                                     master_sig))));
 }
 
 
 /**
  * Create a key state.
  *
  * @param management_only if we should NOT run 'finish_keys_response()'
  *                  because we only need the state for the /management/keys API
  * @return NULL on error (i.e. failed to access database)
  */
 static struct TEH_KeyStateHandle *
 build_key_state (bool management_only)
 {
   struct TEH_KeyStateHandle *ksh;
   enum GNUNET_DB_QueryStatus qs;
 
   ksh = GNUNET_new (struct TEH_KeyStateHandle);
   ksh->signature_expires = GNUNET_TIME_UNIT_FOREVER_TS;
   ksh->reload_time = GNUNET_TIME_timestamp_get ();
   /* We must use the key_generation from when we STARTED the process! */
   ksh->key_generation = key_generation;
   ksh->denomserial_map = GNUNET_CONTAINER_multihashmap32_create (1024);
   ksh->denomkey_map = GNUNET_CONTAINER_multihashmap_create (1024,
                                                             true);
   ksh->signkey_map = GNUNET_CONTAINER_multipeermap_create (32,
                                                            false /* MUST be false! */
                                                            );
   ksh->auditors = json_array ();
   GNUNET_assert (NULL != ksh->auditors);
   /* NOTE: fetches master-signed signkeys, but ALSO those that were revoked! */
   GNUNET_break (GNUNET_OK ==
                 TALER_EXCHANGEDB_preflight (TEH_pg));
   if (NULL != ksh->global_fees)
     json_decref (ksh->global_fees);
   ksh->global_fees = json_array ();
   qs = TALER_EXCHANGEDB_iterate_global_fees (TEH_pg,
                                              &global_fee_info_cb,
                                              ksh);
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "Loading global fees from DB: %d\n",
               qs);
   if (qs < 0)
   {
     GNUNET_break (GNUNET_DB_STATUS_SOFT_ERROR != qs);
     GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR != qs);
     destroy_key_state (ksh);
     return NULL;
   }
   qs = TALER_EXCHANGEDB_iterate_denominations (TEH_pg,
                                                &denomination_info_cb,
                                                ksh);
   if (qs < 0)
   {
     GNUNET_break (GNUNET_DB_STATUS_SOFT_ERROR != qs);
     GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR != qs);
     destroy_key_state (ksh);
     return NULL;
   }
   /* NOTE: ONLY fetches non-revoked AND master-signed signkeys! */
   qs = TALER_EXCHANGEDB_iterate_active_signkeys (TEH_pg,
                                                  &signkey_info_cb,
                                                  ksh);
   if (qs < 0)
   {
     GNUNET_break (0);
     destroy_key_state (ksh);
     return NULL;
   }
   qs = TALER_EXCHANGEDB_iterate_auditor_denominations (TEH_pg,
                                                        &auditor_denom_cb,
                                                        ksh);
   if (qs < 0)
   {
     GNUNET_break (0);
     destroy_key_state (ksh);
     return NULL;
   }
   qs = TALER_EXCHANGEDB_iterate_active_auditors (TEH_pg,
                                                  &auditor_info_cb,
                                                  ksh);
   if (qs < 0)
   {
     GNUNET_break (0);
     destroy_key_state (ksh);
     return NULL;
   }
 
   if (management_only)
   {
     ksh->management_only = true;
     return ksh;
   }
 
   if (GNUNET_OK !=
       finish_keys_response (ksh))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                 "Could not finish /keys response (required data not configured yet)\n");
     destroy_key_state (ksh);
     return NULL;
   }
   TEH_resume_keys_requests (false);
   return ksh;
 }
 
 
 void
 TEH_keys_update_states ()
 {
   struct GNUNET_DB_EventHeaderP es = {
     .size = htons (sizeof (es)),
     .type = htons (TALER_DBEVENT_EXCHANGE_KEYS_UPDATED),
   };
 
   TALER_EXCHANGEDB_event_notify (TEH_pg,
                                  &es,
                                  NULL,
                                  0);
   key_generation++;
   TEH_resume_keys_requests (false);
 }
 
 
 static struct TEH_KeyStateHandle *
 keys_get_state (bool management_only)
 {
   struct TEH_KeyStateHandle *old_ksh;
   struct TEH_KeyStateHandle *ksh;
 
   old_ksh = key_state;
   if (NULL == old_ksh)
   {
     ksh = build_key_state (management_only);
     if (NULL == ksh)
       return NULL;
     key_state = ksh;
     return ksh;
   }
   if ( (old_ksh->key_generation < key_generation) ||
        (GNUNET_TIME_absolute_is_past (old_ksh->signature_expires.abs_time)) )
   {
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "Rebuilding /keys, generation upgrade from %llu to %llu\n",
                 (unsigned long long) old_ksh->key_generation,
                 (unsigned long long) key_generation);
     ksh = build_key_state (management_only);
     key_state = ksh;
     destroy_key_state (old_ksh);
     return ksh;
   }
   TEH_SECMOD_sync_key_helpers ();
   return old_ksh;
 }
 
 
 struct TEH_KeyStateHandle *
 TEH_keys_get_state_for_management_only (void)
 {
   return keys_get_state (true);
 }
 
 
 struct TEH_KeyStateHandle *
 TEH_keys_get_state (void)
 {
   struct TEH_KeyStateHandle *ksh;
 
   ksh = keys_get_state (false);
   if (NULL == ksh)
     return NULL;
 
   if (ksh->management_only)
   {
     if (GNUNET_OK !=
         finish_keys_response (ksh))
       return NULL;
   }
 
   return ksh;
 }
 
 
 const struct TEH_GlobalFee *
 TEH_keys_global_fee_by_time (
   struct TEH_KeyStateHandle *ksh,
   struct GNUNET_TIME_Timestamp ts)
 {
   for (const struct TEH_GlobalFee *gf = ksh->gf_head;
        NULL != gf;
        gf = gf->next)
   {
     if (GNUNET_TIME_timestamp_cmp (ts,
                                    >=,
                                    gf->start_date) &&
         GNUNET_TIME_timestamp_cmp (ts,
                                    <,
                                    gf->end_date))
       return gf;
   }
   return NULL;
 }
 
 
 struct TEH_DenominationKey *
 TEH_keys_denomination_by_hash (
   const struct TALER_DenominationHashP *h_denom_pub,
   struct MHD_Connection *conn,
   enum MHD_Result *mret)
 {
   struct TEH_KeyStateHandle *ksh;
 
   ksh = TEH_keys_get_state ();
   if (NULL == ksh)
   {
     *mret = TALER_MHD_reply_with_error (conn,
                                         MHD_HTTP_SERVICE_UNAVAILABLE,
                                         TALER_EC_EXCHANGE_GENERIC_KEYS_MISSING,
                                         NULL);
     return NULL;
   }
 
   return TEH_keys_denomination_by_hash_from_state (ksh,
                                                    h_denom_pub,
                                                    conn,
                                                    mret);
 }
 
 
 struct TEH_DenominationKey *
 TEH_keys_denomination_by_hash_from_state (
   const struct TEH_KeyStateHandle *ksh,
   const struct TALER_DenominationHashP *h_denom_pub,
   struct MHD_Connection *conn,
   enum MHD_Result *mret)
 {
   struct TEH_DenominationKey *dk;
 
   dk = GNUNET_CONTAINER_multihashmap_get (ksh->denomkey_map,
                                           &h_denom_pub->hash);
   if (NULL == dk)
   {
     if (NULL == conn)
       return NULL;
     *mret = TEH_RESPONSE_reply_unknown_denom_pub_hash (conn,
                                                        h_denom_pub);
     return NULL;
   }
   return dk;
 }
 
 
 struct TEH_DenominationKey *
 TEH_keys_denomination_by_serial_from_state (
   const struct TEH_KeyStateHandle *ksh,
   uint64_t denom_serial)
 {
   struct TEH_DenominationKey *dk;
   uint32_t serial32 = (uint32_t) denom_serial;
 
   GNUNET_assert (denom_serial == (uint64_t) serial32);
   dk = GNUNET_CONTAINER_multihashmap32_get (ksh->denomserial_map,
                                             serial32);
   return dk;
 }
 
 
 enum TALER_ErrorCode
 TEH_keys_exchange_sign_ (
   const struct GNUNET_CRYPTO_SignaturePurpose *purpose,
   struct TALER_ExchangePublicKeyP *pub,
   struct TALER_ExchangeSignatureP *sig)
 {
   struct TEH_KeyStateHandle *ksh;
 
   ksh = TEH_keys_get_state ();
   if (NULL == ksh)
   {
     /* This *can* happen if the exchange's crypto helper is not running
        or had some bad error. */
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Cannot sign request, no valid signing keys available.\n");
     return TALER_EC_EXCHANGE_GENERIC_KEYS_MISSING;
   }
   return TEH_keys_exchange_sign2_ (ksh,
                                    purpose,
                                    pub,
                                    sig);
 }
 
 
 enum TALER_ErrorCode
 TEH_keys_exchange_sign2_ (
   void *cls,
   const struct GNUNET_CRYPTO_SignaturePurpose *purpose,
   struct TALER_ExchangePublicKeyP *pub,
   struct TALER_ExchangeSignatureP *sig)
 {
   struct TEH_KeyStateHandle *ksh = cls;
   enum TALER_ErrorCode ec;
 
   TEH_METRICS_num_signatures[TEH_MT_SIGNATURE_EDDSA]++;
   ec = TEH_SECMOD_exchange_sign (purpose,
                                  pub,
                                  sig);
   if (TALER_EC_NONE != ec)
     return ec;
   {
     /* Here we check here that 'pub' is set to an exchange public key that is
        actually signed by the master key! Otherwise, we happily continue to
        use key material even if the offline signatures have not been made
        yet! */
     struct GNUNET_PeerIdentity pid;
     struct SigningKey *sk;
 
     pid.public_key = pub->eddsa_pub;
     sk = GNUNET_CONTAINER_multipeermap_get (ksh->signkey_map,
                                             &pid);
     if (NULL == sk)
     {
       /* just to be safe, zero out the (valid) signature, as the key
          should not or no longer be used */
       GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                   "Cannot sign, offline key signatures are missing!\n");
       memset (sig,
               0,
               sizeof (*sig));
       return TALER_EC_EXCHANGE_SIGNKEY_HELPER_OFFLINE_MISSING;
     }
   }
   return ec;
 }
 
 
 /**
  * Comparator used for a binary search by cherry_pick_date for @a key in the
  * `struct KeysResponseData` array. See libc's qsort() and bsearch() functions.
  *
  * @param key pointer to a `struct GNUNET_TIME_Timestamp`
  * @param value pointer to a `struct KeysResponseData` array entry
  * @return 0 if time matches, -1 if key is smaller, 1 if key is larger
  */
 static int
 krd_search_comparator (const void *key,
                        const void *value)
 {
   const struct GNUNET_TIME_Timestamp *kd = key;
   const struct KeysResponseData *krd = value;
 
   if (GNUNET_TIME_timestamp_cmp (*kd,
                                  >,
                                  krd->cherry_pick_date))
     return -1;
   if (GNUNET_TIME_timestamp_cmp (*kd,
                                  <,
                                  krd->cherry_pick_date))
     return 1;
   return 0;
 }
 
 
 enum MHD_Result
 TEH_keys_get_handler (struct TEH_RequestContext *rc,
                       const char *const args[])
 {
   struct GNUNET_TIME_Timestamp last_issue_date;
   const char *etag;
 
   etag = MHD_lookup_connection_value (rc->connection,
                                       MHD_HEADER_KIND,
                                       MHD_HTTP_HEADER_IF_NONE_MATCH);
   (void) args;
   {
     const char *have_cherrypick;
 
     have_cherrypick = MHD_lookup_connection_value (rc->connection,
                                                    MHD_GET_ARGUMENT_KIND,
                                                    "last_issue_date");
     if (NULL != have_cherrypick)
     {
       unsigned long long cherrypickn;
 
       if (1 !=
           sscanf (have_cherrypick,
                   "%llu",
                   &cherrypickn))
       {
         GNUNET_break_op (0);
         return TALER_MHD_reply_with_error (rc->connection,
                                            MHD_HTTP_BAD_REQUEST,
                                            TALER_EC_GENERIC_PARAMETER_MALFORMED,
                                            have_cherrypick);
       }
       /* The following multiplication may overflow; but this should not really
          be a problem, as giving back 'older' data than what the client asks for
          (given that the client asks for data in the distant future) is not
          problematic */
       last_issue_date = GNUNET_TIME_timestamp_from_s (cherrypickn);
     }
     else
     {
       last_issue_date = GNUNET_TIME_UNIT_ZERO_TS;
     }
   }
 
   {
     struct TEH_KeyStateHandle *ksh;
     const struct KeysResponseData *krd;
 
     ksh = TEH_keys_get_state ();
     if ( (NULL == ksh) ||
          (0 == ksh->krd_array_length) )
     {
       if ( ( (SKR_LIMIT <= skr_size) &&
              (GNUNET_TIME_relative_cmp (
                 GNUNET_TIME_absolute_get_duration (rc->start_time),
                 >,
                 GNUNET_TIME_UNIT_SECONDS)) ) ||
            TEH_suicide)
       {
         return TALER_MHD_reply_with_error (
           rc->connection,
           MHD_HTTP_SERVICE_UNAVAILABLE,
           TALER_EC_EXCHANGE_GENERIC_KEYS_MISSING,
           TEH_suicide
           ? "server terminating"
           : "too many connections suspended waiting on /keys");
       }
       return suspend_request (rc->connection);
     }
     krd = bsearch (&last_issue_date,
                    ksh->krd_array,
                    ksh->krd_array_length,
                    sizeof (struct KeysResponseData),
                    &krd_search_comparator);
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "Filtering /keys by cherry pick date %s found entry %u/%u\n",
                 GNUNET_TIME_timestamp2s (last_issue_date),
                 (unsigned int) (krd - ksh->krd_array),
                 ksh->krd_array_length);
     if ( (NULL == krd) &&
          (ksh->krd_array_length > 0) )
     {
       if (! GNUNET_TIME_absolute_is_zero (last_issue_date.abs_time))
         GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                     "Client provided invalid cherry picking timestamp %s, returning full response\n",
                     GNUNET_TIME_timestamp2s (last_issue_date));
       krd = &ksh->krd_array[ksh->krd_array_length - 1];
     }
     if (NULL == krd)
     {
       /* Likely keys not ready *yet*.
          Wait until they are. */
       return suspend_request (rc->connection);
     }
     if ( (NULL != etag) &&
          (0 == strcmp (etag,
                        krd->etag)) )
       return TEH_RESPONSE_reply_not_modified (rc->connection,
                                               krd->etag,
                                               &setup_general_response_headers,
                                               ksh);
 
     return MHD_queue_response (
       rc->connection,
       MHD_HTTP_OK,
       (TALER_MHD_CT_DEFLATE ==
        TALER_MHD_can_compress (rc->connection,
                                TALER_MHD_CT_DEFLATE))
       ? krd->response_compressed
       : krd->response_uncompressed);
   }
 }
 
 
 /**
  * Closure for #add_future_denomkey_cb and #add_future_signkey_cb.
  */
 struct FutureBuilderContext
 {
   /**
    * Our key state.
    */
   struct TEH_KeyStateHandle *ksh;
 
   /**
    * Array of denomination keys.
    */
   json_t *denoms;
 
   /**
    * Array of signing keys.
    */
   json_t *signkeys;
 
 };
 
 
 /**
  * Function called on all of our current and future denomination keys
  * known to the helper process. Filters out those that are current
  * and adds the remaining denomination keys (with their configuration
  * data) to the JSON array.
  *
  * @param cls the `struct FutureBuilderContext *`
  * @param h_denom_pub hash of the denomination public key
  * @param value a `struct HelperDenomination`
  * @return #GNUNET_OK (continue to iterate)
  */
 static enum GNUNET_GenericReturnValue
 add_future_denomkey_cb (void *cls,
                         const struct GNUNET_HashCode *h_denom_pub,
                         void *value)
 {
   struct FutureBuilderContext *fbc = cls;
   struct HelperDenomination *hd = value;
   struct TEH_DenominationKey *dk;
   struct TALER_EXCHANGEDB_DenominationKeyMetaData meta = {0};
 
   dk = GNUNET_CONTAINER_multihashmap_get (fbc->ksh->denomkey_map,
                                           h_denom_pub);
   if (NULL != dk)
     return GNUNET_OK; /* skip: this key is already active! */
   if (GNUNET_TIME_relative_is_zero (hd->validity_duration))
     return GNUNET_OK; /* this key already expired! */
   meta.start = hd->start_time;
   meta.expire_withdraw = GNUNET_TIME_absolute_to_timestamp (
     GNUNET_TIME_absolute_add (meta.start.abs_time,
                               hd->validity_duration));
   if (GNUNET_OK !=
       TEH_CONFIG_load_denom_data (hd->section_name,
                                   &meta))
   {
     /* Woops, couldn't determine fee structure!? */
     return GNUNET_OK;
   }
   GNUNET_assert (
     0 ==
     json_array_append_new (
       fbc->denoms,
       GNUNET_JSON_PACK (
         TALER_JSON_pack_amount ("value",
                                 &meta.value),
         GNUNET_JSON_pack_timestamp ("stamp_start",
                                     meta.start),
         GNUNET_JSON_pack_timestamp ("stamp_expire_withdraw",
                                     meta.expire_withdraw),
         GNUNET_JSON_pack_timestamp ("stamp_expire_deposit",
                                     meta.expire_deposit),
         GNUNET_JSON_pack_timestamp ("stamp_expire_legal",
                                     meta.expire_legal),
         TALER_JSON_pack_denom_pub ("denom_pub",
                                    &hd->denom_pub),
         TALER_JSON_PACK_DENOM_FEES ("fee",
                                     &meta.fees),
         GNUNET_JSON_pack_data_auto ("denom_secmod_sig",
                                     &hd->sm_sig),
         GNUNET_JSON_pack_string ("section_name",
                                  hd->section_name))));
   return GNUNET_OK;
 }
 
 
 /**
  * Function called on all of our current and future exchange signing keys
  * known to the helper process. Filters out those that are current
  * and adds the remaining signing keys (with their configuration
  * data) to the JSON array.
  *
  * @param cls the `struct FutureBuilderContext *`
  * @param pid actually the exchange public key (type disguised)
  * @param value a `struct HelperDenomination`
  * @return #GNUNET_OK (continue to iterate)
  */
 static enum GNUNET_GenericReturnValue
 add_future_signkey_cb (void *cls,
                        const struct GNUNET_PeerIdentity *pid,
                        void *value)
 {
   struct FutureBuilderContext *fbc = cls;
   struct HelperSignkey *hsk = value;
   struct SigningKey *sk;
   struct GNUNET_TIME_Timestamp stamp_expire;
   struct GNUNET_TIME_Timestamp legal_end;
 
   sk = GNUNET_CONTAINER_multipeermap_get (fbc->ksh->signkey_map,
                                           pid);
   if (NULL != sk)
     return GNUNET_OK; /* skip: this key is already active */
   if (GNUNET_TIME_relative_is_zero (hsk->validity_duration))
     return GNUNET_OK; /* this key already expired! */
   stamp_expire = GNUNET_TIME_absolute_to_timestamp (
     GNUNET_TIME_absolute_add (hsk->start_time.abs_time,
                               hsk->validity_duration));
   legal_end = GNUNET_TIME_absolute_to_timestamp (
     GNUNET_TIME_absolute_add (stamp_expire.abs_time,
                               signkey_legal_duration));
   GNUNET_assert (0 ==
                  json_array_append_new (
                    fbc->signkeys,
                    GNUNET_JSON_PACK (
                      GNUNET_JSON_pack_data_auto ("key",
                                                  &hsk->exchange_pub),
                      GNUNET_JSON_pack_timestamp ("stamp_start",
                                                  hsk->start_time),
                      GNUNET_JSON_pack_timestamp ("stamp_expire",
                                                  stamp_expire),
                      GNUNET_JSON_pack_timestamp ("stamp_end",
                                                  legal_end),
                      GNUNET_JSON_pack_data_auto ("signkey_secmod_sig",
                                                  &hsk->sm_sig))));
   return GNUNET_OK;
 }
 
 
 enum MHD_Result
 TEH_keys_management_get_keys_handler (const struct TEH_RequestHandler *rh,
                                       struct MHD_Connection *connection)
 {
   struct TEH_KeyStateHandle *ksh;
   json_t *reply;
 
   (void) rh;
   ksh = TEH_keys_get_state_for_management_only ();
   if (NULL == ksh)
   {
     return TALER_MHD_reply_with_error (connection,
                                        MHD_HTTP_SERVICE_UNAVAILABLE,
                                        TALER_EC_EXCHANGE_GENERIC_KEYS_MISSING,
                                        "no key state");
   }
   TEH_SECMOD_sync_key_helpers ();
   if (NULL == ksh->management_keys_reply)
   {
     struct FutureBuilderContext fbc = {
       .ksh = ksh,
     };
 
     if (! TEH_SECMOD_have_denom_sm_pub ())
     {
       /* Either IPC failed, or neither helper had any denominations configured. */
       return TALER_MHD_reply_with_error (connection,
                                          MHD_HTTP_BAD_GATEWAY,
                                          TALER_EC_EXCHANGE_DENOMINATION_HELPER_UNAVAILABLE,
                                          NULL);
     }
     if (! TEH_SECMOD_have_esign_sm_pub ())
     {
       return TALER_MHD_reply_with_error (connection,
                                          MHD_HTTP_BAD_GATEWAY,
                                          TALER_EC_EXCHANGE_SIGNKEY_HELPER_UNAVAILABLE,
                                          NULL);
     }
     fbc.denoms = json_array ();
     GNUNET_assert (NULL != fbc.denoms);
     fbc.signkeys = json_array ();
     GNUNET_assert (NULL != fbc.signkeys);
     TEH_SECMOD_iterate_denom_keys (&add_future_denomkey_cb,
                                    &fbc);
     TEH_SECMOD_iterate_esign_keys (&add_future_signkey_cb,
                                    &fbc);
     reply = GNUNET_JSON_PACK (
       GNUNET_JSON_pack_array_steal ("future_denoms",
                                     fbc.denoms),
       GNUNET_JSON_pack_array_steal ("future_signkeys",
                                     fbc.signkeys),
       GNUNET_JSON_pack_data_auto ("master_pub",
                                   &TEH_master_public_key));
     {
       json_t *sj = TEH_SECMOD_get_sm_pubs_as_json ();
 
       json_object_update (reply,
                           sj);
       json_decref (sj);
     }
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "Returning GET /management/keys response:\n");
     if (NULL == reply)
     {
       GNUNET_break (0);
       return TALER_MHD_reply_with_error (connection,
                                          MHD_HTTP_INTERNAL_SERVER_ERROR,
                                          TALER_EC_GENERIC_JSON_ALLOCATION_FAILURE,
                                          NULL);
     }
     GNUNET_assert (NULL == ksh->management_keys_reply);
     ksh->management_keys_reply = reply;
   }
   else
   {
     reply = ksh->management_keys_reply;
   }
   return TALER_MHD_reply_json (connection,
                                reply,
                                MHD_HTTP_OK);
 }
 
 
 /* end of taler-exchange-httpd_keys.c */