exchange/src/auditordb/test_auditordb.c

718 lines
25 KiB
C
Raw Normal View History

2016-11-04 00:37:47 +01:00
/*
This file is part of TALER
2020-01-19 19:21:58 +01:00
Copyright (C) 2016 Taler Systems SA
2016-11-04 00:37:47 +01:00
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 auditordb/test_auditordb.c
* @brief test cases for DB interaction functions
* @author Gabor X Toth
2016-11-04 00:37:47 +01:00
*/
#include "platform.h"
2017-06-15 22:10:12 +02:00
#include <gnunet/gnunet_db_lib.h>
2016-11-04 00:37:47 +01:00
#include "taler_auditordb_lib.h"
#include "taler_auditordb_plugin.h"
/**
* Global result from the testcase.
*/
static int result = -1;
/**
* Report line of error if @a cond is true, and jump to label "drop".
*/
#define FAILIF(cond) \
2019-08-25 16:18:24 +02:00
do { \
if (! (cond)) { break;} \
GNUNET_break (0); \
goto drop; \
2016-11-04 00:37:47 +01:00
} while (0)
/**
* Initializes @a ptr with random data.
*/
#define RND_BLK(ptr) \
GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK, ptr, sizeof (*ptr))
/**
* Initializes @a ptr with zeros.
*/
#define ZR_BLK(ptr) \
memset (ptr, 0, sizeof (*ptr))
/**
2019-08-17 21:35:21 +02:00
* Currency we use, must match CURRENCY in "test-auditor-db-postgres.conf".
2016-11-04 00:37:47 +01:00
*/
#define CURRENCY "EUR"
/**
* Database plugin under test.
*/
static struct TALER_AUDITORDB_Plugin *plugin;
/**
* Main function that will be run by the scheduler.
*
* @param cls closure with config
*/
static void
run (void *cls)
{
struct GNUNET_CONFIGURATION_Handle *cfg = cls;
2017-03-15 13:36:47 +01:00
uint64_t rowid;
2016-11-04 00:37:47 +01:00
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"loading database plugin\n");
2016-11-04 00:37:47 +01:00
if (NULL ==
(plugin = TALER_AUDITORDB_plugin_load (cfg)))
{
result = 77;
return;
}
2019-02-14 21:22:29 +01:00
(void) plugin->drop_tables (plugin->cls,
GNUNET_YES);
2016-11-04 00:37:47 +01:00
if (GNUNET_OK !=
plugin->create_tables (plugin->cls))
{
result = 77;
goto unload;
2016-11-04 00:37:47 +01:00
}
2021-08-23 08:24:59 +02:00
if (GNUNET_SYSERR ==
plugin->preflight (plugin->cls))
2016-11-04 00:37:47 +01:00
{
result = 77;
goto drop;
}
FAILIF (GNUNET_OK !=
2021-08-23 08:24:59 +02:00
plugin->start (plugin->cls));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"initializing\n");
struct TALER_Amount value;
struct TALER_Amount fee_withdraw;
struct TALER_Amount fee_deposit;
struct TALER_Amount fee_refresh;
struct TALER_Amount fee_refund;
2016-11-04 00:37:47 +01:00
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":1.000010",
&value));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":0.000011",
&fee_withdraw));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":0.000012",
&fee_deposit));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":0.000013",
&fee_refresh));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":0.000014",
&fee_refund));
struct TALER_MasterPublicKeyP master_pub;
struct TALER_ReservePublicKeyP reserve_pub;
2021-10-27 23:35:14 +02:00
struct TALER_DenominationHash rnd_hash;
2016-11-04 00:37:47 +01:00
struct TALER_DenominationPrivateKey denom_priv;
struct TALER_DenominationPublicKey denom_pub;
2021-10-27 23:35:14 +02:00
struct TALER_DenominationHash denom_pub_hash;
2021-12-15 11:38:57 +01:00
struct GNUNET_TIME_Timestamp now;
struct GNUNET_TIME_Timestamp past;
struct GNUNET_TIME_Timestamp future;
struct GNUNET_TIME_Timestamp date;
2019-09-15 11:25:35 +02:00
2021-10-27 23:35:14 +02:00
RND_BLK (&master_pub);
RND_BLK (&reserve_pub);
RND_BLK (&rnd_hash);
2021-11-05 14:00:10 +01:00
GNUNET_assert (GNUNET_OK ==
TALER_denom_priv_create (&denom_priv,
&denom_pub,
TALER_DENOMINATION_RSA,
1024));
2021-10-27 23:35:14 +02:00
TALER_denom_pub_hash (&denom_pub,
&denom_pub_hash);
TALER_denom_priv_free (&denom_priv);
TALER_denom_pub_free (&denom_pub);
2016-11-04 00:37:47 +01:00
2021-12-15 11:38:57 +01:00
now = GNUNET_TIME_timestamp_get ();
past = GNUNET_TIME_absolute_to_timestamp (
GNUNET_TIME_absolute_subtract (now.abs_time,
GNUNET_TIME_relative_multiply (
GNUNET_TIME_UNIT_HOURS,
4)));
future = GNUNET_TIME_absolute_to_timestamp (
GNUNET_TIME_absolute_add (now.abs_time,
GNUNET_TIME_relative_multiply (
GNUNET_TIME_UNIT_HOURS,
4)));
2016-11-04 00:37:47 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: auditor_insert_exchange\n");
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2019-08-25 16:18:24 +02:00
plugin->insert_exchange (plugin->cls,
&master_pub,
"https://exchange/"));
2018-11-18 13:56:41 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: insert_auditor_progress\n");
struct TALER_AUDITORDB_ProgressPointCoin ppc = {
.last_deposit_serial_id = 123,
.last_melt_serial_id = 456,
.last_refund_serial_id = 789,
.last_withdraw_serial_id = 555
};
struct TALER_AUDITORDB_ProgressPointCoin ppc2 = {
.last_deposit_serial_id = 0,
.last_melt_serial_id = 0,
.last_refund_serial_id = 0,
.last_withdraw_serial_id = 0
};
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->insert_auditor_progress_coin (plugin->cls,
&master_pub,
&ppc));
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: update_auditor_progress\n");
ppc.last_deposit_serial_id++;
ppc.last_melt_serial_id++;
ppc.last_refund_serial_id++;
ppc.last_withdraw_serial_id++;
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->update_auditor_progress_coin (plugin->cls,
&master_pub,
&ppc));
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: get_auditor_progress\n");
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->get_auditor_progress_coin (plugin->cls,
&master_pub,
&ppc2));
FAILIF ( (ppc.last_deposit_serial_id != ppc2.last_deposit_serial_id) ||
(ppc.last_melt_serial_id != ppc2.last_melt_serial_id) ||
(ppc.last_refund_serial_id != ppc2.last_refund_serial_id) ||
(ppc.last_withdraw_serial_id != ppc2.last_withdraw_serial_id) );
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: insert_reserve_info\n");
struct TALER_Amount reserve_balance, withdraw_fee_balance;
struct TALER_Amount reserve_balance2 = {}, withdraw_fee_balance2 = {};
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":12.345678",
&reserve_balance));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":23.456789",
&withdraw_fee_balance));
2019-10-05 15:12:11 +02:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->insert_reserve_info (plugin->cls,
&reserve_pub,
&master_pub,
&reserve_balance,
&withdraw_fee_balance,
2019-10-05 15:12:11 +02:00
past,
"payto://bla/blub"));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: update_reserve_info\n");
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->update_reserve_info (plugin->cls,
&reserve_pub,
&master_pub,
&reserve_balance,
&withdraw_fee_balance,
2017-03-18 22:38:31 +01:00
future));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: get_reserve_info\n");
2019-10-05 15:12:11 +02:00
char *payto;
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->get_reserve_info (plugin->cls,
&reserve_pub,
&master_pub,
2017-03-15 13:36:47 +01:00
&rowid,
2016-11-04 20:38:21 +01:00
&reserve_balance2,
&withdraw_fee_balance2,
2019-10-05 15:12:11 +02:00
&date,
&payto));
FAILIF (0 != strcmp (payto,
"payto://bla/blub"));
GNUNET_free (payto);
FAILIF (0 != GNUNET_memcmp (&date, &future)
|| 0 != GNUNET_memcmp (&reserve_balance2, &reserve_balance)
2019-08-25 16:18:24 +02:00
|| 0 != GNUNET_memcmp (&withdraw_fee_balance2,
&withdraw_fee_balance));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: insert_reserve_summary\n");
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->insert_reserve_summary (plugin->cls,
&master_pub,
&withdraw_fee_balance,
&reserve_balance));
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: update_reserve_summary\n");
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->update_reserve_summary (plugin->cls,
&master_pub,
&reserve_balance,
&withdraw_fee_balance));
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: get_reserve_summary\n");
ZR_BLK (&reserve_balance2);
ZR_BLK (&withdraw_fee_balance2);
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->get_reserve_summary (plugin->cls,
&master_pub,
&reserve_balance2,
&withdraw_fee_balance2));
FAILIF ( (0 != GNUNET_memcmp (&reserve_balance2,
&reserve_balance) ||
2019-08-25 16:18:24 +02:00
(0 != GNUNET_memcmp (&withdraw_fee_balance2,
&withdraw_fee_balance)) ) );
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: insert_denomination_balance\n");
struct TALER_Amount denom_balance;
2019-09-02 08:01:55 +02:00
struct TALER_Amount denom_loss;
struct TALER_Amount denom_loss2;
struct TALER_Amount deposit_fee_balance;
struct TALER_Amount melt_fee_balance;
struct TALER_Amount refund_fee_balance;
struct TALER_Amount denom_balance2;
struct TALER_Amount deposit_fee_balance2;
struct TALER_Amount melt_fee_balance2;
struct TALER_Amount refund_fee_balance2;
struct TALER_Amount rbalance;
struct TALER_Amount rbalance2;
struct TALER_Amount loss;
struct TALER_Amount loss2;
struct TALER_Amount iirp;
struct TALER_Amount iirp2;
uint64_t nissued;
2016-11-04 20:38:21 +01:00
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":12.345678",
&denom_balance));
2019-09-02 08:01:55 +02:00
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":0.1",
&denom_loss));
2016-11-04 20:38:21 +01:00
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":23.456789",
&deposit_fee_balance));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":34.567890",
&melt_fee_balance));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":45.678901",
&refund_fee_balance));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":13.57986",
&rbalance));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":1.6",
&loss));
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":1.1",
&iirp));
2016-11-04 20:38:21 +01:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->insert_denomination_balance (plugin->cls,
&denom_pub_hash,
&denom_balance,
2019-09-02 08:01:55 +02:00
&denom_loss,
&rbalance,
&loss,
42));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: update_denomination_balance\n");
ppc.last_withdraw_serial_id++;
ppc.last_deposit_serial_id++;
ppc.last_melt_serial_id++;
ppc.last_refund_serial_id++;
2016-11-04 20:38:21 +01:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->update_denomination_balance (plugin->cls,
&denom_pub_hash,
&denom_balance,
2019-09-02 08:01:55 +02:00
&denom_loss,
&rbalance,
&loss,
62));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: get_denomination_balance\n");
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->get_denomination_balance (plugin->cls,
&denom_pub_hash,
&denom_balance2,
2019-09-02 08:01:55 +02:00
&denom_loss2,
&rbalance2,
&loss2,
&nissued));
FAILIF (0 != GNUNET_memcmp (&denom_balance2, &denom_balance));
2019-09-02 08:01:55 +02:00
FAILIF (0 != GNUNET_memcmp (&denom_loss2, &denom_loss));
FAILIF (0 != GNUNET_memcmp (&rbalance2, &rbalance));
FAILIF (62 != nissued);
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: insert_balance_summary\n");
2016-11-04 20:38:21 +01:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->insert_balance_summary (plugin->cls,
&master_pub,
&refund_fee_balance,
&melt_fee_balance,
&deposit_fee_balance,
&denom_balance,
&rbalance,
&loss,
&iirp));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: update_balance_summary\n");
2016-11-04 20:38:21 +01:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->update_balance_summary (plugin->cls,
&master_pub,
&denom_balance,
&deposit_fee_balance,
&melt_fee_balance,
&refund_fee_balance,
&rbalance,
&loss,
&iirp));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: get_balance_summary\n");
2016-11-04 20:38:21 +01:00
ZR_BLK (&denom_balance2);
ZR_BLK (&deposit_fee_balance2);
ZR_BLK (&melt_fee_balance2);
ZR_BLK (&refund_fee_balance2);
ZR_BLK (&rbalance2);
ZR_BLK (&loss2);
ZR_BLK (&iirp2);
2016-11-04 20:38:21 +01:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->get_balance_summary (plugin->cls,
2019-08-25 16:18:24 +02:00
&master_pub,
&denom_balance2,
&deposit_fee_balance2,
&melt_fee_balance2,
&refund_fee_balance2,
&rbalance2,
&loss2,
&iirp2));
2016-11-04 20:38:21 +01:00
FAILIF ( (0 != GNUNET_memcmp (&denom_balance2,
&denom_balance) ) ||
2019-08-25 16:18:24 +02:00
(0 != GNUNET_memcmp (&deposit_fee_balance2,
&deposit_fee_balance) ) ||
(0 != GNUNET_memcmp (&melt_fee_balance2,
&melt_fee_balance) ) ||
(0 != GNUNET_memcmp (&refund_fee_balance2,
&refund_fee_balance)) );
FAILIF (0 != GNUNET_memcmp (&rbalance2,
&rbalance));
FAILIF (0 != GNUNET_memcmp (&loss2,
&loss));
FAILIF (0 != GNUNET_memcmp (&iirp2,
&iirp));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: insert_historic_denom_revenue\n");
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->insert_historic_denom_revenue (plugin->cls,
&master_pub,
&denom_pub_hash,
past,
&rbalance,
&loss));
2016-11-04 20:38:21 +01:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->insert_historic_denom_revenue (plugin->cls,
&master_pub,
&rnd_hash,
now,
&rbalance,
&loss));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: select_historic_denom_revenue\n");
int
2021-10-27 23:35:14 +02:00
select_historic_denom_revenue_result (
void *cls,
const struct TALER_DenominationHash *denom_pub_hash2,
2021-12-15 11:38:57 +01:00
struct GNUNET_TIME_Timestamp revenue_timestamp2,
2021-10-27 23:35:14 +02:00
const struct TALER_Amount *revenue_balance2,
const struct TALER_Amount *loss2)
2016-11-04 20:38:21 +01:00
{
static int n = 0;
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"select_historic_denom_revenue_result: row %u\n", n);
2019-08-25 16:18:24 +02:00
if ((2 <= n++)
|| (cls != NULL)
|| ((0 != GNUNET_memcmp (&revenue_timestamp2, &past))
&& (0 != GNUNET_memcmp (&revenue_timestamp2, &now)))
|| ((0 != GNUNET_memcmp (denom_pub_hash2, &denom_pub_hash))
&& (0 != GNUNET_memcmp (denom_pub_hash2, &rnd_hash)))
|| (0 != GNUNET_memcmp (revenue_balance2, &rbalance))
|| (0 != GNUNET_memcmp (loss2, &loss)))
2016-11-04 20:38:21 +01:00
{
2019-08-25 16:18:24 +02:00
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"select_historic_denom_revenue_result: result does not match\n");
GNUNET_break (0);
return GNUNET_SYSERR;
2016-11-04 20:38:21 +01:00
}
return GNUNET_OK;
}
2019-10-31 12:59:50 +01:00
FAILIF (0 >=
2016-11-04 20:38:21 +01:00
plugin->select_historic_denom_revenue (plugin->cls,
&master_pub,
2019-08-25 16:18:24 +02:00
&
select_historic_denom_revenue_result,
2016-11-04 20:38:21 +01:00
NULL));
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: insert_historic_reserve_revenue\n");
struct TALER_Amount reserve_profits;
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":56.789012",
&reserve_profits));
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->insert_historic_reserve_revenue (plugin->cls,
&master_pub,
past,
future,
&reserve_profits));
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->insert_historic_reserve_revenue (plugin->cls,
&master_pub,
now,
future,
&reserve_profits));
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: select_historic_reserve_revenue\n");
int
2021-12-15 11:38:57 +01:00
select_historic_reserve_revenue_result (
void *cls,
struct GNUNET_TIME_Timestamp start_time2,
struct GNUNET_TIME_Timestamp end_time2,
const struct TALER_Amount *reserve_profits2)
2016-11-04 20:38:21 +01:00
{
static int n = 0;
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"select_historic_reserve_revenue_result: row %u\n", n);
2019-08-25 16:18:24 +02:00
if ((2 <= n++)
|| (cls != NULL)
|| ((0 != GNUNET_memcmp (&start_time2, &past))
&& (0 != GNUNET_memcmp (&start_time2, &now)))
|| (0 != GNUNET_memcmp (&end_time2, &future))
|| (0 != GNUNET_memcmp (reserve_profits2, &reserve_profits)))
2016-11-04 20:38:21 +01:00
{
2019-08-25 16:18:24 +02:00
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"select_historic_reserve_revenue_result: result does not match\n");
GNUNET_break (0);
return GNUNET_SYSERR;
2016-11-04 20:38:21 +01:00
}
return GNUNET_OK;
}
2019-10-31 12:59:50 +01:00
FAILIF (0 >=
2016-11-04 20:38:21 +01:00
plugin->select_historic_reserve_revenue (plugin->cls,
&master_pub,
select_historic_reserve_revenue_result,
NULL));
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: insert_predicted_result\n");
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->insert_predicted_result (plugin->cls,
&master_pub,
&rbalance));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: update_predicted_result\n");
GNUNET_assert (GNUNET_OK ==
TALER_string_to_amount (CURRENCY ":78.901234",
&rbalance));
2016-11-04 20:38:21 +01:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->update_predicted_result (plugin->cls,
&master_pub,
&rbalance));
2016-11-04 20:38:21 +01:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->insert_wire_fee_summary (plugin->cls,
&master_pub,
&rbalance));
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->update_wire_fee_summary (plugin->cls,
&master_pub,
&reserve_profits));
{
struct TALER_Amount rprof;
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->get_wire_fee_summary (plugin->cls,
&master_pub,
&rprof));
FAILIF (0 !=
TALER_amount_cmp (&rprof,
&reserve_profits));
}
FAILIF (0 >
2021-08-23 08:24:59 +02:00
plugin->commit (plugin->cls));
FAILIF (GNUNET_OK !=
2021-08-23 08:24:59 +02:00
plugin->start (plugin->cls));
2016-11-04 20:38:21 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: get_predicted_balance\n");
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
2016-11-04 20:38:21 +01:00
plugin->get_predicted_balance (plugin->cls,
&master_pub,
&rbalance2));
2016-11-04 20:38:21 +01:00
FAILIF (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
plugin->del_reserve_info (plugin->cls,
&reserve_pub,
&master_pub));
FAILIF (0 != TALER_amount_cmp (&rbalance2,
&rbalance));
2021-08-23 08:24:59 +02:00
plugin->rollback (plugin->cls);
#if GC_IMPLEMENTED
FAILIF (GNUNET_OK !=
plugin->gc (plugin->cls));
#endif
2016-11-04 20:38:21 +01:00
2016-11-04 00:37:47 +01:00
result = 0;
2019-10-05 15:12:11 +02:00
drop:
2018-11-18 13:56:41 +01:00
{
2021-08-23 08:24:59 +02:00
plugin->rollback (plugin->cls);
2018-11-18 13:56:41 +01:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Test: auditor_delete_exchange\n");
GNUNET_break (GNUNET_OK ==
2021-08-23 08:24:59 +02:00
plugin->start (plugin->cls));
GNUNET_break (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT ==
plugin->delete_exchange (plugin->cls,
&master_pub));
GNUNET_break (0 <=
2021-08-23 08:24:59 +02:00
plugin->commit (plugin->cls));
2018-11-18 13:56:41 +01:00
}
2016-11-04 00:37:47 +01:00
GNUNET_break (GNUNET_OK ==
2019-02-14 21:22:29 +01:00
plugin->drop_tables (plugin->cls,
GNUNET_YES));
2019-10-05 15:12:11 +02:00
unload:
2016-11-04 00:37:47 +01:00
TALER_AUDITORDB_plugin_unload (plugin);
plugin = NULL;
}
int
main (int argc,
char *const argv[])
{
const char *plugin_name;
char *config_filename;
char *testname;
struct GNUNET_CONFIGURATION_Handle *cfg;
2020-03-27 17:28:33 +01:00
(void) argc;
2016-11-04 00:37:47 +01:00
result = -1;
if (NULL == (plugin_name = strrchr (argv[0], (int) '-')))
{
GNUNET_break (0);
return -1;
}
GNUNET_log_setup (argv[0],
"WARNING",
NULL);
plugin_name++;
(void) GNUNET_asprintf (&testname,
"test-auditor-db-%s", plugin_name);
(void) GNUNET_asprintf (&config_filename,
"%s.conf", testname);
cfg = GNUNET_CONFIGURATION_create ();
if (GNUNET_OK !=
GNUNET_CONFIGURATION_parse (cfg,
config_filename))
{
GNUNET_break (0);
GNUNET_free (config_filename);
GNUNET_free (testname);
return 2;
}
GNUNET_SCHEDULER_run (&run, cfg);
GNUNET_CONFIGURATION_destroy (cfg);
GNUNET_free (config_filename);
GNUNET_free (testname);
return result;
}