exchange

taler_auditordb_plugin.h (61898B)

---

 /*
   This file is part of TALER
   Copyright (C) 2014-2024 Taler Systems SA
 
   TALER is free software; you can redistribute it and/or modify it under the
   terms of the GNU General Public License as published by the Free Software
   Foundation; either version 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 General Public License for more details.
 
   You should have received a copy of the GNU General Public License along with
   TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
 */
 /**
  * @file include/taler/taler_auditordb_plugin.h
  * @brief Low-level (statement-level) database access for the auditor
  * @author Florian Dold
  * @author Christian Grothoff
  */
 #ifndef TALER_AUDITORDB_PLUGIN_H
 #define TALER_AUDITORDB_PLUGIN_H
 
 #include <jansson.h>
 #include <gnunet/gnunet_util_lib.h>
 #include <gnunet/gnunet_db_lib.h>
 #include <taler/taler_util.h>
 #include <taler/taler_auditordb_lib.h>
 #include <taler/taler_signatures.h>
 
 
 /**
  * Function called with the results of select_historic_denom_revenue()
  *
  * @param cls closure
  * @param serial_id row for the denomination revenue in the auditor database
  * @param denom_pub_hash hash of the denomination key
  * @param revenue_timestamp when did this profit get realized
  * @param revenue_balance what was the total profit made from
  *                        deposit fees, melting fees, refresh fees
  *                        and coins that were never returned?
  * @param loss_balance what was the total loss
  * @return sets the return value of select_denomination_info(),
  *         #GNUNET_OK to continue,
  *         #GNUNET_NO to stop processing further rows
  *         #GNUNET_SYSERR or other values on error.
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_HistoricDenominationRevenueDataCallback)(
   void *cls,
   uint64_t serial_id,
   const struct TALER_DenominationHashP *denom_pub_hash,
   struct GNUNET_TIME_Timestamp revenue_timestamp,
   const struct TALER_Amount *revenue_balance,
   const struct TALER_Amount *loss_balance);
 
 
 /**
  * Function called with the results of select_historic_reserve_revenue()
  *
  * @param cls closure
  * @param serial_id row ID in the history table
  * @param start_time beginning of aggregated time interval
  * @param end_time end of aggregated time interval
  * @param reserve_profits total profits made
  *
  * @return sets the return value of select_denomination_info(),
  *         #GNUNET_OK to continue,
  *         #GNUNET_NO to stop processing further rows
  *         #GNUNET_SYSERR or other values on error.
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_HistoricReserveRevenueDataCallback)(
   void *cls,
   uint64_t serial_id,
   struct GNUNET_TIME_Timestamp start_time,
   struct GNUNET_TIME_Timestamp end_time,
   const struct TALER_Amount *reserve_profits);
 
 
 /**
  * Information about a signing key of an exchange.
  */
 struct TALER_AUDITORDB_ExchangeSigningKey
 {
 
   /**
    * When does @e exchange_pub start to be used?
    */
   struct GNUNET_TIME_Timestamp ep_start;
 
   /**
    * When will the exchange stop signing with @e exchange_pub?
    */
   struct GNUNET_TIME_Timestamp ep_expire;
 
   /**
    * When does the signing key expire (for legal disputes)?
    */
   struct GNUNET_TIME_Timestamp ep_end;
 
   /**
    * What is the public offline signing key this is all about?
    */
   struct TALER_ExchangePublicKeyP exchange_pub;
 
   /**
    * Signature by the offline master key affirming the above.
    */
   struct TALER_MasterSignatureP master_sig;
 };
 
 
 /**
  * Information about a deposit confirmation we received from
  * a merchant.
  */
 struct TALER_AUDITORDB_DepositConfirmation
 {
 
   /**
    * Hash over the contract for which this deposit is made.
    */
   struct TALER_PrivateContractHashP h_contract_terms;
 
   /**
    * Hash over the policy extension for the deposit.
    */
   struct TALER_ExtensionPolicyHashP h_policy;
 
   /**
    * Hash over the wiring information of the merchant.
    */
   struct TALER_MerchantWireHashP h_wire;
 
   /**
    * Time when this deposit confirmation was generated by the exchange.
    */
   struct GNUNET_TIME_Timestamp exchange_timestamp;
 
   /**
    * How much time does the @e merchant have to issue a refund
    * request?  Zero if refunds are not allowed.  After this time, the
    * coin cannot be refunded.  Note that the wire transfer will not be
    * performed by the exchange until the refund deadline.  This value
    * is taken from the original deposit request.
    */
   struct GNUNET_TIME_Timestamp refund_deadline;
 
   /**
    * How much time does the @e exchange have to wire the funds?
    */
   struct GNUNET_TIME_Timestamp wire_deadline;
 
   /**
    * Amount to be deposited, excluding fee.  Calculated from the
    * amount with fee and the fee from the deposit request.
    */
   struct TALER_Amount total_without_fee;
 
   /**
    * Array of the coin public keys involved in the
    * batch deposit operation.
    */
   const struct TALER_CoinSpendPublicKeyP *coin_pubs;
 
   /**
    * Array of coin deposit signatures from the deposit operation.
    */
   const struct TALER_CoinSpendSignatureP *coin_sigs;
 
   /**
    * The Merchant's public key.  Allows the merchant to later refund
    * the transaction or to inquire about the wire transfer identifier.
    */
   struct TALER_MerchantPublicKeyP merchant;
 
   /**
    * Signature from the exchange of type
    * #TALER_SIGNATURE_EXCHANGE_CONFIRM_DEPOSIT.
    */
   struct TALER_ExchangeSignatureP exchange_sig;
 
   /**
    * Public signing key from the exchange matching @e exchange_sig.
    */
   struct TALER_ExchangePublicKeyP exchange_pub;
 
   /**
    * Exchange master signature over @e exchange_sig.
    */
   struct TALER_MasterSignatureP master_sig;
 
   /**
    * Row of this entry in the auditor database.
    */
   uint64_t row_id;
 
   /**
    * Length of the @e coin_pubs and @e coin_sigs arrays.
    */
   unsigned int num_coins;
 
   bool suppressed;
 
 };
 
 // MARK: CRUD
 
 /**
  * Information about a row inconsistency
  */
 struct TALER_AUDITORDB_Generic_Update
 {
   uint64_t row_id;
   bool suppressed;
   bool ancient;
 };
 
 /**
  * Information about an arithmetic inconsistency
  */
 struct TALER_AUDITORDB_AmountArithmeticInconsistency
 {
   uint64_t row_id;
   uint64_t problem_row_id;
   char *operation;
   struct TALER_Amount exchange_amount;
   struct TALER_Amount auditor_amount;
   bool profitable;
   bool suppressed;
 };
 
 /**
  * Information about a coin inconsistency
  */
 struct TALER_AUDITORDB_CoinInconsistency
 {
   uint64_t row_id;
   char *operation;
   struct TALER_Amount exchange_amount;
   struct TALER_Amount auditor_amount;
   struct GNUNET_CRYPTO_EddsaPublicKey coin_pub;
   bool profitable;
 };
 
 /**
  * Information about a row inconsistency
  */
 struct TALER_AUDITORDB_RowInconsistency
 {
   uint64_t row_id;
   char *row_table;
   char *diagnostic;
   bool suppressed;
 };
 
 /**
  * Information about a bad sig loss
  */
 struct TALER_AUDITORDB_BadSigLosses
 {
   uint64_t row_id;
   uint64_t problem_row_id;
   char *operation;
   struct TALER_Amount loss;
   struct GNUNET_CRYPTO_EddsaPublicKey operation_specific_pub;
   bool suppressed;
 };
 
 /**
  * Information about a closure lags
  */
 struct TALER_AUDITORDB_ClosureLags
 {
   uint64_t row_id;
   uint64_t problem_row_id;
   struct TALER_Amount amount;
   struct GNUNET_TIME_Absolute deadline;
   struct TALER_WireTransferIdentifierRawP wtid;
   struct TALER_FullPayto account;
   bool suppressed;
 };
 
 /**
  * Information about a emergency
  */
 struct TALER_AUDITORDB_Emergency
 {
   uint64_t row_id;
   struct TALER_DenominationHashP denompub_h;
   struct TALER_Amount denom_risk;
   struct TALER_Amount denom_loss;
   struct GNUNET_TIME_Absolute deposit_start;
   struct GNUNET_TIME_Absolute deposit_end;
   struct TALER_Amount value;
   bool suppressed;
 };
 
 /**
  * Information about an emergency by count
  */
 struct TALER_AUDITORDB_EmergenciesByCount
 {
   uint64_t row_id;
   struct TALER_DenominationHashP denompub_h;
   uint64_t num_issued;
   uint64_t num_known;
   struct TALER_Amount risk;
   struct GNUNET_TIME_Absolute start;
   struct GNUNET_TIME_Absolute deposit_end;
   struct TALER_Amount value;
   bool suppressed;
 };
 
 /**
  * Information about progress of the audit.
  */
 struct TALER_AUDITORDB_Progress
 {
   char *progress_key;
   uint64_t progress_offset;
 };
 
 
 /**
  * Information about a fee time inconsistency
  */
 struct TALER_AUDITORDB_FeeTimeInconsistency
 {
   uint64_t row_id;
   uint64_t problem_row_id;
   char *type;
   struct GNUNET_TIME_Absolute time;
   char *diagnostic;
 };
 
 /**
  * Information about a denom key validity withdraw inconsistency
  */
 struct TALER_AUDITORDB_DenominationKeyValidityWithdrawInconsistency
 {
   uint64_t row_id;
   uint64_t problem_row_id;
   struct GNUNET_TIME_Absolute execution_date;
   struct TALER_ReservePublicKeyP reserve_pub;
   struct TALER_DenominationHashP denompub_h;
   bool suppressed;
 };
 
 /**
  * Information about a purse not closed inconsistencies
  */
 struct TALER_AUDITORDB_PurseNotClosedInconsistencies
 {
   uint64_t row_id;
   struct GNUNET_CRYPTO_EddsaPublicKey purse_pub;
   struct TALER_Amount amount;
   struct GNUNET_TIME_Absolute expiration_date;
   bool suppressed;
 };
 
 /**
  * Information about a reserve balance insufficient inconsistency
  */
 struct TALER_AUDITORDB_ReserveBalanceInsufficientInconsistency
 {
   uint64_t row_id;
   struct GNUNET_CRYPTO_EddsaPublicKey reserve_pub;
   bool inconsistency_gain;
   struct TALER_Amount inconsistency_amount;
   bool suppressed;
 };
 
 /**
  * Information about a reserve in inconsistency
  */
 struct TALER_AUDITORDB_ReserveInInconsistency
 {
   uint64_t serial_id;
   uint64_t bank_row_id;
   struct TALER_Amount amount_exchange_expected;
   struct TALER_Amount amount_wired;
   struct TALER_ReservePublicKeyP reserve_pub;
   struct GNUNET_TIME_Absolute timestamp;
   struct TALER_FullPayto account;
   char *diagnostic;
   bool suppressed;
 
 };
 
 /**
  * Information about a balance
  */
 struct TALER_AUDITORDB_Balances
 {
   uint64_t row_id;
   char *balance_key;
   struct TALER_Amount balance_value;
   bool suppressed;
 
 };
 
 /**
  * Function called with arithmetic inconsistencies stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_AmountArithmeticInconsistencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_AmountArithmeticInconsistency *dc);
 
 /**
  * Function called with coin inconsistencies stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param serial_id location of the @a dc in the database
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_CoinInconsistencyCallback)(
   void *cls,
   uint64_t serial_id,
   const struct TALER_AUDITORDB_CoinInconsistency *dc);
 
 /**
  * Function called with row inconsistencies stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param serial_id location of the @a dc in the database
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_RowInconsistencyCallback)(
   void *cls,
   uint64_t serial_id,
   const struct TALER_AUDITORDB_RowInconsistency *dc);
 
 /**
  * Function called with bad signature losses stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_BadSigLossesCallback)(
   void *cls,
   const struct TALER_AUDITORDB_BadSigLosses *dc);
 
 /**
  * Function called with closure lags stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_ClosureLagsCallback)(
   void *cls,
   const struct TALER_AUDITORDB_ClosureLags *dc);
 
 /**
  * Function called with emergencies stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_EmergencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_Emergency *dc);
 
 /**
  * Function called with emergencies stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_EmergenciesByCountCallback)(
   void *cls,
   const struct TALER_AUDITORDB_EmergenciesByCount *dc);
 
 
 /**
  * Function called with fee time inconsistency stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_FeeTimeInconsistencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_FeeTimeInconsistency *dc);
 
 /**
  * Function called with fee denomination key validity withdraw inconsistency stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_DenominationKeyValidityWithdrawInconsistencyCallback)(
   void *cls,
   const struct
   TALER_AUDITORDB_DenominationKeyValidityWithdrawInconsistency *dc);
 
 /**
  * Function called with purse not closed inconsistencies stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_PurseNotClosedInconsistenciesCallback)(
   void *cls,
   const struct TALER_AUDITORDB_PurseNotClosedInconsistencies *dc);
 
 /**
  * Function called with reserve balance insufficient inconsistency stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the structure itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_ReserveBalanceInsufficientInconsistencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_ReserveBalanceInsufficientInconsistency *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_BalancesCallback)(
   void *cls,
   const struct TALER_AUDITORDB_Balances *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_ProgressPointsCallback)(
   void *cls,
   const struct TALER_AUDITORDB_Progress *pp);
 
 /**
  * Balance values for a reserve (or all reserves).
  */
 struct TALER_AUDITORDB_ReserveFeeBalance
 {
   /**
    * Remaining funds.
    */
   struct TALER_Amount reserve_balance;
 
   /**
    * Losses from operations that should not have
    * happened (e.g. negative balance).
    */
   struct TALER_Amount reserve_loss;
 
   /**
    * Fees charged for withdraw.
    */
   struct TALER_Amount withdraw_fee_balance;
 
   /**
    * Fees charged for closing.
    */
   struct TALER_Amount close_fee_balance;
 
   /**
    * Fees charged for purse creation.
    */
   struct TALER_Amount purse_fee_balance;
 
   /**
    * Opening fees charged.
    */
   struct TALER_Amount open_fee_balance;
 
   /**
    * History fees charged.
    */
   struct TALER_Amount history_fee_balance;
 };
 
 
 /**
  * Balance data for denominations in circulation.
  */
 struct TALER_AUDITORDB_DenominationCirculationData
 {
   /**
    * Amount of outstanding coins in circulation.
    */
   struct TALER_Amount denom_balance;
 
   /**
    * Amount lost due coins illicitly accepted (effectively, a
    * negative @a denom_balance).
    */
   struct TALER_Amount denom_loss;
 
   /**
    * Total amount that could still be theoretically lost in the future due to
    * recoup operations.  (Total put into circulation minus @e recoup_loss).
    */
   struct TALER_Amount denom_risk;
 
   /**
    * Amount lost due to recoups.
    */
   struct TALER_Amount recoup_loss;
 
   /**
    * Number of coins of this denomination that the exchange signed into
    * existence.
    */
   uint64_t num_issued;
 };
 
 struct TALER_AUDITORDB_DenominationsWithoutSigs
 {
   uint64_t row_id;
   struct TALER_DenominationHashP denompub_h;
   struct TALER_Amount value;
   struct GNUNET_TIME_Absolute start_time;
   struct GNUNET_TIME_Absolute end_time;
   bool suppressed;
 };
 
 struct TALER_AUDITORDB_MisattributionInInconsistency
 {
   uint64_t row_id;
   struct TALER_Amount amount;
   uint64_t bank_row;
   struct TALER_ReservePublicKeyP reserve_pub;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_Reserves
 {
   uint64_t row_id;
   uint64_t auditor_reserves_rowid;
   struct TALER_ReservePublicKeyP reserve_pub;
   struct TALER_Amount reserve_balance;
   struct TALER_Amount reserve_loss;
   struct TALER_Amount withdraw_fee_balance;
   struct TALER_Amount close_fee_balance;
   struct TALER_Amount purse_fee_balance;
   struct TALER_Amount open_fee_balance;
   struct TALER_Amount history_fee_balance;
   struct GNUNET_TIME_Absolute expiration_date;
   struct TALER_FullPayto origin_account;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_Purses
 {
   uint64_t row_id;
   uint64_t auditor_purses_rowid;
   struct TALER_PurseContractPublicKeyP purse_pub;
   struct TALER_Amount balance;
   struct TALER_Amount target;
   struct GNUNET_TIME_Absolute expiration_date;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_HistoricDenominationRevenue
 {
   uint64_t row_id;
   struct TALER_DenominationHashP denom_pub_hash;
   struct GNUNET_TIME_Absolute revenue_timestamp;
   struct TALER_Amount revenue_balance;
   struct TALER_Amount loss_balance;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_DenominationPending
 {
   uint64_t row_id;
   struct TALER_DenominationHashP denom_pub_hash;
   struct TALER_Amount denom_balance;
   struct TALER_Amount denom_loss;
   uint64_t num_issued;
   struct TALER_Amount denom_risk;
   struct TALER_Amount recoup_loss;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_HistoricReserveSummary
 {
   uint64_t row_id;
   struct GNUNET_TIME_Absolute start_date;
   struct GNUNET_TIME_Absolute end_date;
   struct TALER_Amount reserve_profits;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_ExchangeSignkeys
 {
   uint64_t row_id;
   struct TALER_ExchangePublicKeyP exchange_pub;
   struct TALER_MasterSignatureP master_sig;
   struct GNUNET_TIME_Absolute ep_valid_from;
   struct GNUNET_TIME_Absolute ep_expire_sign;
   struct GNUNET_TIME_Absolute ep_expire_legal;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_WireFormatInconsistency
 {
   uint64_t row_id;
   struct TALER_Amount amount;
   uint64_t wire_offset;
   char *diagnostic;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_WireOutInconsistency
 {
   uint64_t row_id;
   struct TALER_FullPayto destination_account;
   char *diagnostic;
   uint64_t wire_out_row_id;
   struct TALER_Amount expected;
   struct TALER_Amount claimed;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_RowMinorInconsistencies
 {
   uint64_t row_id;
   char *row_table;
   uint64_t problem_row;
   char *diagnostic;
   bool suppressed;
 };
 
 
 struct TALER_AUDITORDB_ReserveBalanceSummaryWrongInconsistency
 {
   uint64_t row_id;
   struct TALER_ReservePublicKeyP reserve_pub;
   struct TALER_Amount exchange_amount;
   struct TALER_Amount auditor_amount;
   bool suppressed;
 
 };
 
 struct TALER_AUDITORDB_ReserveNotClosedInconsistency
 {
   uint64_t row_id;
   struct TALER_ReservePublicKeyP reserve_pub;
   struct TALER_Amount balance;
   struct GNUNET_TIME_Absolute expiration_time;
   char *diagnostic;
   bool suppressed;
 
 };
 
 /**
  * Function called with deposit confirmations stored in
  * the auditor's database.
  *
  * @param cls closure
  * @param dc the deposit confirmation itself
  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_DepositConfirmationCallback)(
   void *cls,
   const struct TALER_AUDITORDB_DepositConfirmation *dc);
 
 
 /**
  * Function called on deposits that are past their due date
  * and have not yet seen a wire transfer.
  *
  * @param cls closure
  * @param row_id row ID of the alert in the auditor database
  * @param batch_deposit_serial_id where in the exchange table are we
  * @param total_amount value of all missing deposits, including fees
  * @param wire_target_h_payto hash of the recipient account's payto URI
  * @param deadline what was the earliest requested wire transfer deadline
  * @param suppressed true if this report was suppressed
  */
 typedef void
 (*TALER_AUDITORDB_WireMissingCallback) (
   void *cls,
   uint64_t row_id,
   uint64_t batch_deposit_serial_id,
   const struct TALER_Amount *total_amount,
   const struct TALER_FullPaytoHashP *wire_target_h_payto,
   struct GNUNET_TIME_Timestamp deadline,
   bool suppressed);
 
 
 /**
  * Function called on expired purses.
  *
  * @param cls closure
  * @param purse_pub public key of the purse
  * @param balance amount of money in the purse
  * @param expiration_date when did the purse expire?
  * @return #GNUNET_OK to continue to iterate
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_ExpiredPurseCallback)(
   void *cls,
   const struct TALER_PurseContractPublicKeyP *purse_pub,
   const struct TALER_Amount *balance,
   struct GNUNET_TIME_Timestamp expiration_date);
 
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_ReserveInInconsistencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_ReserveInInconsistency *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_ReserveNotClosedInconsistencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_ReserveNotClosedInconsistency *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_DenominationsWithoutSigsCallback)(
   void *cls,
   const struct TALER_AUDITORDB_DenominationsWithoutSigs *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_MisattributionInInconsistencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_MisattributionInInconsistency *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_ReservesCallback)(
   void *cls,
   uint64_t serial_id,
   const struct TALER_AUDITORDB_Reserves *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_PursesCallback)(
   void *cls,
   uint64_t serial_id,
   const struct TALER_AUDITORDB_Purses *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_HistoricDenominationRevenueCallback)(
   void *cls,
   uint64_t serial_id,
   const struct TALER_AUDITORDB_HistoricDenominationRevenue *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_DenominationPendingCallback)(
   void *cls,
   uint64_t serial_id,
   const struct TALER_AUDITORDB_DenominationPending *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_HistoricReserveSummaryCallback)(
   void *cls,
   uint64_t serial_id,
   const struct TALER_AUDITORDB_HistoricReserveSummary *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_ExchangeSignkeysCallback)(
   void *cls,
   uint64_t serial_id,
   const struct TALER_AUDITORDB_ExchangeSignkeys *dc);
 
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_WireFormatInconsistencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_WireFormatInconsistency *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_WireOutInconsistencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_WireOutInconsistency *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_ReserveBalanceSummaryWrongInconsistencyCallback)(
   void *cls,
   const struct TALER_AUDITORDB_ReserveBalanceSummaryWrongInconsistency *dc);
 
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_RowMinorInconsistenciesCallback)(
   void *cls,
   const struct TALER_AUDITORDB_RowMinorInconsistencies *dc);
 
 
 /**
  * Information about an early aggregation event.
  */
 struct TALER_AUDITORDB_EarlyAggregation
 {
   /**
    * Row of the event in the auditor database.
    */
   uint64_t row_id;
 
   /**
    * Row of the batch deposit in the exchange database.
    */
   uint64_t batch_deposit_serial_id;
 
   /**
    * FIXME
    */
   uint64_t tracking_serial_id;
 
   /**
    * Total amount involved.
    */
   struct TALER_Amount total;
 
   /**
    * True if this report was previously suppressed.
    */
   bool suppressed;
 };
 
 
 /**
  * Function to call with information about early aggregations.
  *
  * @param cls closure
  * @param ea event data
  * @return #GNUNET_OK to continue to iterate
  */
 typedef enum GNUNET_GenericReturnValue
 (*TALER_AUDITORDB_EarlyAggregationsCallback)(
   void *cls,
   const struct TALER_AUDITORDB_EarlyAggregation *ea);
 
 /**
  * @brief The plugin API, returned from the plugin's "init" function.
  * The argument given to "init" is simply a configuration handle.
  *
  * Functions starting with "get_" return one result, functions starting
  * with "select_" return multiple results via callbacks.
  */
 struct TALER_AUDITORDB_Plugin
 {
 
   /**
    * Closure for all callbacks.
    */
   void *cls;
 
   /**
    * Name of the library which generated this plugin.  Set by the
    * plugin loader.
    */
   char *library_name;
 
   /**
    * Fully connect to the db if the connection does not exist yet
    * and check that there is no transaction currently running.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @return #GNUNET_OK on success
    *         #GNUNET_NO if we rolled back an earlier transaction
    *         #GNUNET_SYSERR if we have no DB connection
    */
   enum GNUNET_GenericReturnValue
   (*preflight)(void *cls);
 
 
   /**
    * Register callback to be invoked on events of type @a es.
    *
    * @param cls database context to use
    * @param es specification of the event to listen for
    * @param timeout how long to wait for the event
    * @param cb function to call when the event happens, possibly
    *         mulrewardle times (until cancel is invoked)
    * @param cb_cls closure for @a cb
    * @return handle useful to cancel the listener
    */
   struct GNUNET_DB_EventHandler *
   (*event_listen) (void *cls,
                    const struct GNUNET_DB_EventHeaderP *es,
                    struct GNUNET_TIME_Relative timeout,
                    GNUNET_DB_EventCallback cb,
                    void *cb_cls);
 
   /**
    * Stop notifications.
    *
    * @param eh handle to unregister.
    */
   void
   (*event_listen_cancel) (struct GNUNET_DB_EventHandler *eh);
 
 
   /**
    * Notify all that listen on @a es of an event.
    *
    * @param cls database context to use
    * @param es specification of the event to generate
    * @param extra additional event data provided
    * @param extra_size number of bytes in @a extra
    */
   void
   (*event_notify) (void *cls,
                    const struct GNUNET_DB_EventHeaderP *es,
                    const void *extra,
                    size_t extra_size);
 
 
   /**
    * Drop all auditor tables OR deletes recoverable auditor state.
    * This should only be used by testcases or when restarting the
    * auditor from scratch.
    *
    * @param cls the `struct PostgresClosure` with the plugin-specific state
    * @param drop_exchangelist drop all tables, including schema versioning
    *        and the exchange and deposit_confirmations table; NOT to be
    *        used when restarting the auditor
    * @return #GNUNET_OK upon success; #GNUNET_SYSERR upon failure
    */
   enum GNUNET_GenericReturnValue
   (*drop_tables)(void *cls,
                  bool drop_exchangelist);
 
 
   /**
    * Create the necessary tables if they are not present
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param support_partitions true to support partitioning
    * @param num_partitions number of partitions to use
    * @return #GNUNET_OK upon success; #GNUNET_SYSERR upon failure
    */
   enum GNUNET_GenericReturnValue
   (*create_tables)(void *cls,
                    bool support_partitions,
                    uint32_t num_partitions);
 
 
   /**
    * Start a transaction.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @return #GNUNET_OK on success
    */
   enum GNUNET_GenericReturnValue
   (*start)(void *cls);
 
 
   /**
    * Commit a transaction.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*commit)(void *cls);
 
 
   /**
    * Abort/rollback a transaction.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    */
   void
   (*rollback) (void *cls);
 
 
   /**
    * Function called to perform "garbage collection" on the
    * database, expiring records we no longer require.
    *
    * @param cls closure
    * @return #GNUNET_OK on success,
    *         #GNUNET_SYSERR on DB errors
    */
   enum GNUNET_GenericReturnValue
   (*gc)(void *cls);
 
 
   /**
    * Insert information about the auditor's progress with an exchange's
    * data.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param progress_key name of the progress indicator
    * @param progress_offset offset until which we have made progress
    * @param ... NULL terminated list of additional key-value pairs to insert
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*insert_auditor_progress)(
     void *cls,
     const char *progress_key,
     uint64_t progress_offset,
     ...);
 
   /**
    * Update information about the progress of the auditor.  There
    * must be an existing record for the exchange.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param progress_key name of the progress indicator
    * @param progress_offset offset until which we have made progress
    * @param ... NULL terminated list of additional key-value pairs to update
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*update_auditor_progress)(
     void *cls,
     const char *progress_key,
     uint64_t progress_offset,
     ...);
 
   /**
    * Get information about the progress of the auditor.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param progress_key name of the progress indicator
    * @param[out] progress_offset set to offset until which we have made progress, set to 0 if key was not found
    * @param ... NULL terminated list of additional key-value pairs to fetch
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*get_auditor_progress)(void *cls,
                           const char *progress_key,
                           uint64_t *progress_offset,
                           ...);
 
 
   /**
    * Insert information about a balance tracked by the auditor. There must not be an
    * existing record.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param balance_key key of the balance to store
    * @param balance_value value to store
    * @param ... NULL terminated list of additional key-value pairs to insert
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*insert_balance)(void *cls,
                     const char *balance_key,
                     const struct TALER_Amount *balance_value,
                     ...);
 
 
   /**
    * Insert information about a balance tracked by the auditor.  Destructively updates an
    * existing record, which must already exist.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param balance_key key of the balance to store
    * @param balance_amount value to store
    * @param ... NULL terminated list of additional key-value pairs to update
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*update_balance)(void *cls,
                     const char *balance_key,
                     const struct TALER_Amount *balance_amount,
                     ...);
 
 
   /**
    * Get summary information about balance tracked by the auditor.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param balance_key key of the balance to store
    * @param[out] balance_value set to amount stored under @a balance_key, set to invalid amount (all zero) if key was not found
    * @param ... NULL terminated list of additional key-value pairs to fetch
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*get_balance)(void *cls,
                  const char *balance_key,
                  struct TALER_Amount *balance_value,
                  ...);
 
 
   /**
    * Get information about balances from the database.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param balance_key only return this particular balance
    * @param cb function to call with results
    * @param cb_cls closure for @a cb
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*get_balances)(
     void *cls,
     const char *balance_key,
     TALER_AUDITORDB_BalancesCallback cb,
     void *cb_cls);
 
   /**
    * Get information about progress from the database.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param progress_key only return this particular progress point
    * @param cb function to call with results
    * @param cb_cls closure for @a cb
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*get_progress_points)(
     void *cls,
     const char *progress_key,
     TALER_AUDITORDB_ProgressPointsCallback cb,
     void *cb_cls);
 
   /**
    * Insert information about a signing key of the exchange.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param sk signing key information to store
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*insert_exchange_signkey)(
     void *cls,
     const struct TALER_AUDITORDB_ExchangeSigningKey *sk);
 
 
   /**
    * Insert information about a deposit confirmation into the database.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param dc deposit confirmation information to store
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*insert_deposit_confirmation)(
     void *cls,
     const struct TALER_AUDITORDB_DepositConfirmation *dc);
 
 
   /**
    * Get information about deposit confirmations from the database.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param offset row/serial ID where to start the iteration (0 from
    *                  the start, exclusive, i.e. serial_ids must start from 1)
    * @param return_suppressed should suppressed rows be returned anyway?
    * @param cb function to call with results
    * @param cb_cls closure for @a cb
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*get_deposit_confirmations)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_DepositConfirmationCallback cb,
     void *cb_cls);
 
 
   /**
    * Get information about arithmetic inconsistencies from the database.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param start_id row/serial ID where to start the iteration (0 from
    *                  the start, exclusive, i.e. serial_ids must start from 1)
    * @param return_suppressed should suppressed rows be returned anyway?
    * @param cb function to call with results
    * @param cb_cls closure for @a cb
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*get_amount_arithmetic_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_AmountArithmeticInconsistencyCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_coin_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_CoinInconsistencyCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_row_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_RowInconsistencyCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_emergency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_EmergencyCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_emergency_by_count)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_EmergenciesByCountCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_denomination_key_validity_withdraw_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_DenominationKeyValidityWithdrawInconsistencyCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_purse_not_closed_inconsistencies)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_PurseNotClosedInconsistenciesCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_reserve_balance_insufficient_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_ReserveBalanceInsufficientInconsistencyCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_bad_sig_losses)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     const struct GNUNET_CRYPTO_EddsaPublicKey *op_spec_pub,
     const char *op,
     TALER_AUDITORDB_BadSigLossesCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_auditor_closure_lags)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_ClosureLagsCallback cb,
     void *cb_cls);
 
   /**
    * A previously missing wire transfer may have been found. Remove an alert
    * (if we raised one).
    *
    * @param cls plugin closure
    * @param amount wire transfer amount
    * @param wtid wire transfer subject
    * @param credit_account_uri destination account
    * @return #GNUNET_DB_STATUS_SUCCESS_NO_RESULTS if no matching alert was
    *   found
    */
   enum GNUNET_DB_QueryStatus
   (*delete_auditor_closure_lag)(
     void *cls,
     const struct TALER_Amount *amount,
     const struct TALER_WireTransferIdentifierRawP *wtid,
     struct TALER_FullPayto credit_account_uri);
 
   /**
    * Delete information about a deposit confirmation from the database.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param row_id row to delete
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*delete_amount_arithmetic_inconsistency)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_coin_inconsistency)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_row_inconsistency)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_emergency)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_emergency_by_count)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_denomination_key_validity_withdraw_inconsistency)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_purse_not_closed_inconsistencies)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_reserve_balance_insufficient_inconsistency)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_bad_sig_losses)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_auditor_closure_lags)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*delete_progress)(
     void *cls,
     uint64_t row_id);
 
   /**
    * Insert information about a deposit confirmation into the database.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param dc deposit confirmation information to store
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*insert_amount_arithmetic_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_AmountArithmeticInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*insert_coin_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_CoinInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*insert_row_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_RowInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*insert_emergency)(
     void *cls,
     const struct TALER_AUDITORDB_Emergency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*insert_emergency_by_count)(
     void *cls,
     const struct TALER_AUDITORDB_EmergenciesByCount *dc);
 
   enum GNUNET_DB_QueryStatus
   (*insert_denomination_key_validity_withdraw_inconsistency)(
     void *cls,
     const struct
     TALER_AUDITORDB_DenominationKeyValidityWithdrawInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*insert_purse_not_closed_inconsistencies)(
     void *cls,
     const struct TALER_AUDITORDB_PurseNotClosedInconsistencies *dc);
 
   enum GNUNET_DB_QueryStatus
   (*insert_reserve_balance_insufficient_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_ReserveBalanceInsufficientInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*insert_bad_sig_losses)(
     void *cls,
     const struct TALER_AUDITORDB_BadSigLosses *dc);
 
   enum GNUNET_DB_QueryStatus
   (*insert_auditor_closure_lags)(
     void *cls,
     const struct TALER_AUDITORDB_ClosureLags *dc);
 
   enum GNUNET_DB_QueryStatus
   (*update_generic_suppressed)(
     void *cls,
     enum TALER_AUDITORDB_DeletableSuppressableTables table,
     uint64_t row_id,
     bool suppressed);
 
   enum GNUNET_DB_QueryStatus
   (*delete_generic)(
     void *cls,
     enum TALER_AUDITORDB_DeletableSuppressableTables table,
     uint64_t row_id);
 
   /**
    * Lookup information about reserve-in-inconsistency from the database.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param bank_row_id row of the transaction at the bank
    * @param[out] dc set to the transaction details
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*lookup_reserve_in_inconsistency) (
     void *cls,
     uint64_t bank_row_id,
     struct TALER_AUDITORDB_ReserveInInconsistency *dc);
 
 
   enum GNUNET_DB_QueryStatus
   (*get_reserve_in_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_ReserveInInconsistencyCallback cb,
     void *cb_cls);
 
 
   /**
    * Delete information about an reserve-in-inconsistency from the database.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param row_id row of the inconsistency in our table
    * @return query result status
    */
   enum GNUNET_DB_QueryStatus
   (*delete_reserve_in_inconsistency)(
     void *cls,
     uint64_t row_id);
 
 
   enum GNUNET_DB_QueryStatus
   (*insert_reserve_in_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_ReserveInInconsistency *dc);
 
 
   /**
    * Return any reserve incoming inconsistency associated with the
    * given @a bank_row_id.
    *
    * @param cls closure
    * @param bank_row_id row to select by
    * @param[out] dc details to return
    */
   enum GNUNET_DB_QueryStatus
   (*select_reserve_in_inconsistency)(
     void *cls,
     uint64_t bank_row_id,
     struct TALER_AUDITORDB_ReserveInInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*get_reserve_not_closed_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_ReserveNotClosedInconsistencyCallback cb,
     void *cb_cls);
 
   /**
    * Returns all aggregations that were found that were done
    * too early.
    *
    * @param cls closure
    * @param limit number of rows to return, negative to iterate backwards
    * @param offset starting offset, exclusive
    * @param return_suppressed true to also return suppressed events
    * @param cb function to call with results
    * @param cb_cls closure for @a cb
    * @return transaction status
    */
   enum GNUNET_DB_QueryStatus
   (*select_early_aggregations)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_EarlyAggregationsCallback cb,
     void *cb_cls);
 
 
   enum GNUNET_DB_QueryStatus
   (*delete_reserve_not_closed_inconsistency)(
     void *cls,
     uint64_t row_id);
 
 
   enum GNUNET_DB_QueryStatus
   (*insert_reserve_not_closed_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_ReserveNotClosedInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*get_denominations_without_sigs)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_DenominationsWithoutSigsCallback cb,
     void *cb_cls);
 
 
   enum GNUNET_DB_QueryStatus
   (*delete_denominations_without_sigs)(
     void *cls,
     uint64_t row_id);
 
 
   enum GNUNET_DB_QueryStatus
   (*insert_denominations_without_sigs)(
     void *cls,
     const struct TALER_AUDITORDB_DenominationsWithoutSigs *dc);
 
   enum GNUNET_DB_QueryStatus
   (*get_misattribution_in_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_MisattributionInInconsistencyCallback cb,
     void *cb_cls);
 
 
   enum GNUNET_DB_QueryStatus
   (*delete_misattribution_in_inconsistency)(
     void *cls,
     uint64_t row_id);
 
 
   enum GNUNET_DB_QueryStatus
   (*insert_misattribution_in_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_MisattributionInInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*get_reserves)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     TALER_AUDITORDB_ReservesCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_purses)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     TALER_AUDITORDB_PursesCallback cb,
     void *cb_cls);
 
 
   enum GNUNET_DB_QueryStatus
   (*delete_purses)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*get_denomination_pending)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     TALER_AUDITORDB_DenominationPendingCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*delete_denomination_pending)(
     void *cls,
     uint64_t row_id);
 
   enum GNUNET_DB_QueryStatus
   (*insert_denomination_pending)(
     void *cls,
     const struct TALER_AUDITORDB_DenominationPending *dc);
 
   enum GNUNET_DB_QueryStatus
   (*get_exchange_signkeys)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_ExchangeSignkeysCallback cb,
     void *cb_cls);
 
   enum GNUNET_DB_QueryStatus
   (*get_wire_format_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_WireFormatInconsistencyCallback cb,
     void *cb_cls);
 
 
   enum GNUNET_DB_QueryStatus
   (*delete_wire_format_inconsistency)(
     void *cls,
     uint64_t row_id);
 
 
   enum GNUNET_DB_QueryStatus
   (*insert_wire_format_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_WireFormatInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*get_wire_out_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_WireOutInconsistencyCallback cb,
     void *cb_cls);
 
 
   enum GNUNET_DB_QueryStatus
   (*delete_wire_out_inconsistency)(
     void *cls,
     uint64_t row_id);
 
 
   enum GNUNET_DB_QueryStatus
   (*insert_wire_out_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_WireOutInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*delete_wire_out_inconsistency_if_matching)(
     void *cls,
     const struct TALER_AUDITORDB_WireOutInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*get_reserve_balance_summary_wrong_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_ReserveBalanceSummaryWrongInconsistencyCallback cb,
     void *cb_cls);
 
 
   enum GNUNET_DB_QueryStatus
   (*delete_reserve_balance_summary_wrong_inconsistency)(
     void *cls,
     uint64_t row_id);
 
 
   enum GNUNET_DB_QueryStatus
   (*insert_reserve_balance_summary_wrong_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_ReserveBalanceSummaryWrongInconsistency *dc);
 
   enum GNUNET_DB_QueryStatus
   (*get_row_minor_inconsistencies)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_RowMinorInconsistenciesCallback cb,
     void *cb_cls);
 
 
   enum GNUNET_DB_QueryStatus
   (*delete_row_minor_inconsistencies)(
     void *cls,
     uint64_t row_id);
 
 
   enum GNUNET_DB_QueryStatus
   (*insert_row_minor_inconsistencies)(
     void *cls,
     const struct TALER_AUDITORDB_RowMinorInconsistencies *dc);
 
   enum GNUNET_DB_QueryStatus
   (*get_fee_time_inconsistency)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_FeeTimeInconsistencyCallback cb,
     void *cb_cls);
 
 
   enum GNUNET_DB_QueryStatus
   (*delete_fee_time_inconsistency)(
     void *cls,
     uint64_t row_id);
 
 
   enum GNUNET_DB_QueryStatus
   (*insert_fee_time_inconsistency)(
     void *cls,
     const struct TALER_AUDITORDB_FeeTimeInconsistency *dc);
 
   /**
  * Insert information about a reserve.  There must not be an
  * existing record for the reserve.
  *
  * @param cls the @e cls of this struct with the plugin-specific state
  * @param reserve_pub public key of the reserve
  * @param rfb balance amounts for the reserve
  * @param expiration_date expiration date of the reserve
  * @param origin_account where did the money in the reserve originally come from
  * @return transaction status code
  */
   enum GNUNET_DB_QueryStatus
   (*insert_reserve_info)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     const struct TALER_AUDITORDB_ReserveFeeBalance *rfb,
     struct GNUNET_TIME_Timestamp expiration_date,
     const struct TALER_FullPayto origin_account);
 
 
   /**
    * Update information about a reserve.  Destructively updates an
    * existing record, which must already exist.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param reserve_pub public key of the reserve
    * @param rfb balance amounts for the reserve
    * @param expiration_date expiration date of the reserve
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*update_reserve_info)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     const struct TALER_AUDITORDB_ReserveFeeBalance *rfb,
     struct GNUNET_TIME_Timestamp expiration_date);
 
 
   /**
    * Get information about a reserve.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param reserve_pub public key of the reserve
    * @param[out] rowid which row did we get the information from
    * @param[out] rfb set to balances associated with the reserve
    * @param[out] expiration_date expiration date of the reserve
    * @param[out] sender_account from where did the money in the reserve originally come from
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*get_reserve_info)(
     void *cls,
     const struct TALER_ReservePublicKeyP *reserve_pub,
     uint64_t *rowid,
     struct TALER_AUDITORDB_ReserveFeeBalance *rfb,
     struct GNUNET_TIME_Timestamp *expiration_date,
     struct TALER_FullPayto *sender_account);
 
 
   /**
    * Delete information about a reserve.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param reserve_pub public key of the reserve
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*del_reserve_info)(void *cls,
                       const struct TALER_ReservePublicKeyP *reserve_pub);
 
 
   /**
    * Insert new row into the early aggregation table.  This can happen simply
    * because of when the taler-helper-auditor-transfer looks at which of the
    * two tables. If it is cleared in the next iteration, this is perfectly
    * expected.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param batch_deposit_serial_id where in the batch deposit table are we
    * @param tracking_serial_id where in the tracking table are we
    * @param total_amount value of all missing deposits, including fees
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*insert_early_aggregation)(
     void *cls,
     uint64_t batch_deposit_serial_id,
     uint64_t tracking_serial_id,
     const struct TALER_Amount *total_amount);
 
 
   /**
    * Delete a row from the early aggregation table.
    * Usually done when the expected aggregation
    * was finally detected.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param batch_deposit_serial_id which entry to delete
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*delete_early_aggregation)(
     void *cls,
     uint64_t batch_deposit_serial_id);
 
 
   /**
    * Insert new row into the pending deposits table.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param batch_deposit_serial_id where in the table are we
    * @param total_amount value of all missing deposits, including fees
    * @param wire_target_h_payto hash of the recipient account's payto URI
    * @param deadline what was the requested wire transfer deadline
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*insert_pending_deposit)(
     void *cls,
     uint64_t batch_deposit_serial_id,
     const struct TALER_FullPaytoHashP *wire_target_h_payto,
     const struct TALER_Amount *total_amount,
     struct GNUNET_TIME_Timestamp deadline);
 
 
   /**
    * Delete a row from the pending deposit table.
    * Usually done when the respective wire transfer
    * was finally detected.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param batch_deposit_serial_id which entry to delete
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*delete_pending_deposit)(
     void *cls,
     uint64_t batch_deposit_serial_id);
 
 
   /**
    * Return (batch) deposits for which we have not yet
    * seen the required wire transfer.
    *
    * @param deadline only return up to this deadline
    * @param limit number of rows to return, negative to iterate backwards
    * @param offset starting offset, exclusive
    * @param return_suppressed true to also return suppressed events
    * @param cb function to call on each entry
    * @param cb_cls closure for @a cb
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*select_pending_deposits)(
     void *cls,
     struct GNUNET_TIME_Absolute deadline,
     int64_t limit,
     uint64_t offset,
     bool return_suppressed,
     TALER_AUDITORDB_WireMissingCallback cb,
     void *cb_cls);
 
 
   /**
    * Insert information about a purse.  There must not be an
    * existing record for the purse.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param purse_pub public key of the purse
    * @param balance balance of the purse
    * @param expiration_date expiration date of the purse
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*insert_purse_info)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     const struct TALER_Amount *balance,
     struct GNUNET_TIME_Timestamp expiration_date);
 
 
   /**
    * Update information about a purse.  Destructively updates an
    * existing record, which must already exist.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param purse_pub public key of the purse
    * @param balance new balance for the purse
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*update_purse_info)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     const struct TALER_Amount *balance);
 
 
   /**
    * Get information about a purse.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param purse_pub public key of the purse
    * @param[out] rowid which row did we get the information from
    * @param[out] balance set to balance of the purse
    * @param[out] expiration_date expiration date of the purse
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*get_purse_info)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub,
     uint64_t *rowid,
     struct TALER_Amount *balance,
     struct GNUNET_TIME_Timestamp *expiration_date);
 
 
   /**
    * Delete information about a purse.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param purse_pub public key of the reserve
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*delete_purse_info)(
     void *cls,
     const struct TALER_PurseContractPublicKeyP *purse_pub);
 
 
   /**
    * Get information about expired purses.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param cb function to call on expired purses
    * @param cb_cls closure for @a cb
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*select_purse_expired)(
     void *cls,
     TALER_AUDITORDB_ExpiredPurseCallback cb,
     void *cb_cls);
 
 
   /**
    * Insert information about a denomination key's balances.  There
    * must not be an existing record for the denomination key.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param denom_pub_hash hash of the denomination public key
    * @param dcd denomination circulation data to store
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*insert_denomination_balance)(
     void *cls,
     const struct TALER_DenominationHashP *denom_pub_hash,
     const struct TALER_AUDITORDB_DenominationCirculationData *dcd);
 
 
   /**
    * Update information about a denomination key's balances.  There
    * must be an existing record for the denomination key.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param denom_pub_hash hash of the denomination public key
    * @param dcd denomination circulation data to store
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*update_denomination_balance)(
     void *cls,
     const struct TALER_DenominationHashP *denom_pub_hash,
     const struct TALER_AUDITORDB_DenominationCirculationData *dcd);
 
   /**
    * Delete information about a denomination key's balances.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param denom_pub_hash hash of the denomination public key
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*del_denomination_balance)(
     void *cls,
     const struct TALER_DenominationHashP *denom_pub_hash);
 
 
   /**
    * Get information about a denomination key's balances.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param denom_pub_hash hash of the denomination public key
    * @param[out] dcd denomination circulation data to initialize
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*get_denomination_balance)(
     void *cls,
     const struct TALER_DenominationHashP *denom_pub_hash,
     struct TALER_AUDITORDB_DenominationCirculationData *dcd);
 
 
   /**
    * Insert information about an exchange's historic
    * revenue about a denomination key.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param denom_pub_hash hash of the denomination key
    * @param revenue_timestamp when did this profit get realized
    * @param revenue_balance what was the total profit made from
    *                        deposit fees, melting fees, refresh fees
    *                        and coins that were never returned?
    * @param recoup_loss_balance total losses from recoups of revoked denominations
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*insert_historic_denom_revenue)(
     void *cls,
     const struct TALER_DenominationHashP *denom_pub_hash,
     struct GNUNET_TIME_Timestamp revenue_timestamp,
     const struct TALER_Amount *revenue_balance,
     const struct TALER_Amount *recoup_loss_balance);
 
 
   /**
    * Obtain all of the historic denomination key revenue.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param cb function to call with the results
    * @param cb_cls closure for @a cb
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*select_historic_denom_revenue)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     TALER_AUDITORDB_HistoricDenominationRevenueDataCallback cb,
     void *cb_cls);
 
 
   /**
    * Insert information about an exchange's historic revenue from reserves.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param start_time beginning of aggregated time interval
    * @param end_time end of aggregated time interval
    * @param reserve_profits total profits made
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*insert_historic_reserve_revenue)(
     void *cls,
     struct GNUNET_TIME_Timestamp start_time,
     struct GNUNET_TIME_Timestamp end_time,
     const struct TALER_Amount *reserve_profits);
 
 
   /**
    * Return information about an exchange's historic revenue from reserves.
    *
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param limit number of rows to return, negative to iterate backwards
    * @param offset starting offset, exclusive
    * @param cb function to call with results
    * @param cb_cls closure for @a cb
    * @return transaction status code
    */
   enum GNUNET_DB_QueryStatus
   (*select_historic_reserve_revenue)(
     void *cls,
     int64_t limit,
     uint64_t offset,
     TALER_AUDITORDB_HistoricReserveRevenueDataCallback cb,
     void *cb_cls);
 
 };
 
 
 #endif /* _TALER_AUDITOR_DB_H */