diff options
Diffstat (limited to 'src/include')
| -rw-r--r-- | src/include/taler_auditordb_plugin.h | 12 | ||||
| -rw-r--r-- | src/include/taler_exchangedb_plugin.h | 50 |
2 files changed, 52 insertions, 10 deletions
diff --git a/src/include/taler_auditordb_plugin.h b/src/include/taler_auditordb_plugin.h index 031df58cb..170a68fdd 100644 --- a/src/include/taler_auditordb_plugin.h +++ b/src/include/taler_auditordb_plugin.h @@ -122,6 +122,18 @@ struct TALER_AUDITORDB_ProgressPoint uint64_t last_reserve_out_serial_id; /** + * last_payback_serial_id serial ID of the last payback entry the auditor processed when + * considering reserves. + */ + uint64_t last_reserve_payback_serial_id; + + /** + * last_reserve_close_serial_id serial ID of the last reserve_close + * entry the auditor processed. + */ + uint64_t last_reserve_close_serial_id; + + /** * last_reserve_out_serial_id serial ID of the last withdraw the auditor processed */ uint64_t last_withdraw_serial_id; diff --git a/src/include/taler_exchangedb_plugin.h b/src/include/taler_exchangedb_plugin.h index 322a30524..f6d78aba9 100644 --- a/src/include/taler_exchangedb_plugin.h +++ b/src/include/taler_exchangedb_plugin.h @@ -875,8 +875,9 @@ typedef void * @param wtid wire transfer subject * @param wire wire transfer details of the receiver * @param amount amount that was wired + * @return #GNUNET_OK to continue, #GNUNET_SYSERR to stop iteration */ -typedef void +typedef int (*TALER_EXCHANGEDB_WireTransferOutCallback)(void *cls, uint64_t rowid, struct GNUNET_TIME_Absolute date, @@ -894,8 +895,9 @@ typedef void * @param buf transaction data that was persisted, NULL on error * @param buf_size number of bytes in @a buf, 0 on error * @param finished did we complete the transfer yet? + * @return #GNUNET_OK to continue, #GNUNET_SYSERR to stop iteration */ -typedef void +typedef int (*TALER_EXCHANGEDB_WirePreparationCallback)(void *cls, uint64_t rowid, const char *wire_method, @@ -909,18 +911,25 @@ typedef void * * @param cls closure * @param rowid row identifier used to uniquely identify the payback operation - * @param deadline by when did we promise the payment - * @param receiver_account_details to whom do we need to send the funds - * @param amount how much should be transferred - * @param wire_subject what should be the wire subject + * @param timestamp when did we receive the payback request + * @param amount how much should be added back to the reserve + * @param reserve_pub public key of the reserve + * @param coin_pub public key of the coin + * @param coin_sig signature with @e coin_pub of type #TALER_SIGNATURE_WALLET_COIN_PAYBACK + * @param h_denom_pub hash of the denomination key of the coin + * @param coin_blind blinding factor used to blind the coin + * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop */ -typedef void +typedef int (*TALER_EXCHANGEDB_PaybackCallback)(void *cls, uint64_t rowid, - struct GNUNET_TIME_Absolute deadline, - const json_t *receiver_account_details, + struct GNUNET_TIME_Absolute timestamp, const struct TALER_Amount *amount, - const struct TALER_WireTransferIdentifierRawP *wtid); + const struct TALER_ReservePublicKeyP *reserve_pub, + const struct TALER_CoinSpendPublicKeyP *coin_pub, + const struct TALER_CoinSpendSignatureP *coin_sig, + const struct GNUNET_HashCode *h_denom_pub, + const struct TALER_DenominationBlindingKeyP *coin_blind); /** @@ -1940,6 +1949,27 @@ struct TALER_EXCHANGEDB_Plugin /** + * Function called to select payback requests the exchange + * received, ordered by serial ID (monotonically increasing). + * + * @param cls closure + * @param session database connection + * @param serial_id lowest serial ID to include (select larger or equal) + * @param cb function to call for ONE unfinished item + * @param cb_cls closure for @a cb + * @return #GNUNET_OK on success, + * #GNUNET_NO if there are no entries, + * #GNUNET_SYSERR on DB errors + */ + int + (*select_payback_above_serial_id)(void *cls, + struct TALER_EXCHANGEDB_Session *session, + uint64_t serial_id, + TALER_EXCHANGEDB_PaybackCallback cb, + void *cb_cls); + + + /** * Function called to add a request for an emergency payback for a * coin. The funds are to be added back to the reserve. The * function should return the @a deadline by which the exchange will |