summaryrefslogtreecommitdiff
path: root/src/exchange/taler-exchange-aggregator.c
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2020-01-15 15:17:02 +0100
committerFlorian Dold <florian.dold@gmail.com>2020-01-15 15:17:25 +0100
commitda5b3ba8aeb9d47e4f99cd22847c9b539ff8ee2b (patch)
tree6e67e1d08fd941144f464dfe55b8835db65687e6 /src/exchange/taler-exchange-aggregator.c
parentb37fff0d5b08926169633ce8822de7ac616ae169 (diff)
downloadexchange-da5b3ba8aeb9d47e4f99cd22847c9b539ff8ee2b.tar.gz
exchange-da5b3ba8aeb9d47e4f99cd22847c9b539ff8ee2b.tar.bz2
exchange-da5b3ba8aeb9d47e4f99cd22847c9b539ff8ee2b.zip
round amounts based on config, do unit test for rounding
Diffstat (limited to 'src/exchange/taler-exchange-aggregator.c')
-rw-r--r--src/exchange/taler-exchange-aggregator.c35
1 files changed, 33 insertions, 2 deletions
diff --git a/src/exchange/taler-exchange-aggregator.c b/src/exchange/taler-exchange-aggregator.c
index fe3ef39c..f1abbe2b 100644
--- a/src/exchange/taler-exchange-aggregator.c
+++ b/src/exchange/taler-exchange-aggregator.c
@@ -227,6 +227,11 @@ static struct CloseTransferContext *ctc;
static char *exchange_currency_string;
/**
+ * How many fractional digits does the currency use?
+ */
+static uint8_t currency_rounding_fractional_digits;
+
+/**
* What is the base URL of this exchange?
*/
static char *exchange_base_url;
@@ -614,6 +619,30 @@ exchange_serve_process_config ()
return GNUNET_SYSERR;
}
+ {
+ unsigned long long num;
+ if (GNUNET_OK !=
+ GNUNET_CONFIGURATION_get_value_number (cfg,
+ "taler",
+ "CURRENCY_ROUNDING_FRACTIONAL_DIGITS",
+ &num))
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+ "No [taler]/CURRENCY_ROUNDING_FRACTIONAL_DIGITS specified, defaulting to 2 digits.\n");
+ currency_rounding_fractional_digits = 2;
+ }
+ else if (num > TALER_AMOUNT_FRAC_LEN)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Value of CURRENCY_ROUNDING_FRACTIONAL_DIGITS too big.\n");
+ return GNUNET_SYSERR;
+ }
+ else
+ {
+ currency_rounding_fractional_digits = (uint8_t) num;
+ }
+ }
+
if (NULL ==
(db_plugin = TALER_EXCHANGEDB_plugin_load (cfg)))
{
@@ -1116,7 +1145,8 @@ expired_reserve_cb (void *cls,
}
/* round down to enable transfer */
if (GNUNET_SYSERR ==
- TALER_amount_round (&amount_without_fee))
+ TALER_amount_round_down (&amount_without_fee,
+ currency_rounding_fractional_digits))
{
GNUNET_break (0);
global_ret = GNUNET_SYSERR;
@@ -1447,7 +1477,8 @@ run_aggregation (void *cls)
&au->total_amount,
&au->wire_fee)) ||
(GNUNET_SYSERR ==
- TALER_amount_round (&au->final_amount)) ||
+ TALER_amount_round_down (&au->final_amount,
+ currency_rounding_fractional_digits)) ||
( (0 == au->final_amount.value) &&
(0 == au->final_amount.fraction) ) )
{