aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/wire-plugins/test_wire_plugin_legacy_taler-bank.c101
1 files changed, 70 insertions, 31 deletions
diff --git a/src/wire-plugins/test_wire_plugin_legacy_taler-bank.c b/src/wire-plugins/test_wire_plugin_legacy_taler-bank.c
index 9c7c917f1..690666f87 100644
--- a/src/wire-plugins/test_wire_plugin_legacy_taler-bank.c
+++ b/src/wire-plugins/test_wire_plugin_legacy_taler-bank.c
@@ -2,17 +2,21 @@
This file is part of TALER
(C) 2015-2018 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/>
+ 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 wire/test_wire_plugin_legacy_taler-bank.c
* @brief Tests legacy history-range API against the Fakebank.
@@ -87,7 +91,14 @@ static struct TALER_WireTransferIdentifierRawP wtid;
/**
* Number of total transaction to make it happen in the test.
*/
+static int Ntransactions = NTRANSACTIONS;
static int ntransactions = NTRANSACTIONS;
+static int ztransactions = 0;
+
+/**
+ * Timestamp used as the oldest extreme in the query range.
+ */
+static struct GNUNET_TIME_Absolute first_timestamp;
/**
* Function called on shutdown (regular, error or CTRL-C).
@@ -119,7 +130,6 @@ do_shutdown (void *cls)
hhr = NULL;
}
-
TALER_WIRE_plugin_unload (plugin);
}
@@ -141,12 +151,13 @@ do_shutdown (void *cls)
static int
history_result_cb
(void *cls,
- enum TALER_ErrorCode ec,
- enum TALER_BANK_Direction dir,
- const void *row_off,
- size_t row_off_size,
- const struct TALER_WIRE_TransferDetails *details)
+ enum TALER_ErrorCode ec,
+ enum TALER_BANK_Direction dir,
+ const void *row_off,
+ size_t row_off_size,
+ const struct TALER_WIRE_TransferDetails *details)
{
+ int *expected_number = cls;
static int accumulator = 0;
if ( (TALER_BANK_DIRECTION_NONE == dir) &&
@@ -155,16 +166,42 @@ history_result_cb
/* End-of-list, check all the transactions got accounted
* into the history. */
- if (NTRANSACTIONS != accumulator)
+ if (*expected_number != accumulator)
{
GNUNET_break (0);
TALER_LOG_ERROR
("Unexpected # of transactions: %d, %d were expected.\n",
accumulator,
- NTRANSACTIONS);
+ *expected_number);
global_ret = GNUNET_NO;
}
+ if (ztransactions != *expected_number)
+ {
+ /* Call the second test, under the assumption that after
+ * running the test with ztransactions expected entries,
+ * we shut the test down. */
+
+ accumulator = 0;
+ GNUNET_assert
+ (NULL != (hhr = plugin->get_history_range
+ (plugin->cls,
+ my_account,
+ TALER_BANK_DIRECTION_BOTH,
+ GNUNET_TIME_UNIT_ZERO_ABS,
+ GNUNET_TIME_absolute_subtract
+ (first_timestamp,
+ GNUNET_TIME_UNIT_HOURS),
+ &history_result_cb,
+
+ /**
+ * Zero results are expected from 1970 up to 1 hour ago.
+ */
+ &ztransactions)));
+
+ return GNUNET_OK;
+ }
+
GNUNET_SCHEDULER_shutdown ();
return GNUNET_OK;
}
@@ -191,7 +228,6 @@ confirmation_cb (void *cls,
size_t row_id_size,
const char *emsg);
-
/**
* Callback with prepared transaction.
*
@@ -247,7 +283,7 @@ confirmation_cb (void *cls,
return;
}
- if (0 >= --ntransactions)
+ if (0 >= --Ntransactions)
{
GNUNET_assert
(NULL != (hhr = plugin->get_history_range
@@ -257,14 +293,15 @@ confirmation_cb (void *cls,
GNUNET_TIME_UNIT_ZERO_ABS,
GNUNET_TIME_UNIT_FOREVER_ABS,
&history_result_cb,
- NULL)));
+ &ntransactions)));
return;
}
/* Issue a new wire transfer! */
- GNUNET_assert (GNUNET_OK ==
- TALER_string_to_amount ("KUDOS:5.01",
- &amount));
+ GNUNET_assert
+ (GNUNET_OK == TALER_string_to_amount ("KUDOS:5.01",
+ &amount));
+
ph = plugin->prepare_wire_transfer (plugin->cls,
my_account,
dest_account,
@@ -291,11 +328,13 @@ run (void *cls)
GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK,
&wtid,
sizeof (wtid));
- GNUNET_assert (GNUNET_OK ==
- TALER_string_to_amount ("KUDOS:5.01",
- &amount));
+ GNUNET_assert
+ (GNUNET_OK == TALER_string_to_amount ("KUDOS:5.01",
+ &amount));
fb = TALER_FAKEBANK_start (8088);
+
+ first_timestamp = GNUNET_TIME_absolute_get ();
ph = plugin->prepare_wire_transfer (plugin->cls,
my_account,
dest_account,
@@ -311,14 +350,14 @@ int
main (int argc,
const char *const argv[])
{
-
GNUNET_log_setup ("test-wire-plugin-legacy-test",
"WARNING",
NULL);
cfg = GNUNET_CONFIGURATION_create ();
- GNUNET_assert (GNUNET_OK ==
- GNUNET_CONFIGURATION_load (cfg,
- "test_wire_plugin_legacy_taler-bank.conf"));
+ GNUNET_assert
+ (GNUNET_OK == GNUNET_CONFIGURATION_load
+ (cfg,
+ "test_wire_plugin_legacy_taler-bank.conf"));
global_ret = GNUNET_OK;
plugin = TALER_WIRE_plugin_load (cfg,
"taler_bank");