summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2021-11-17 11:01:19 +0100
committerChristian Grothoff <christian@grothoff.org>2021-11-17 11:01:19 +0100
commited1db63a48840c417fb49dc5f0711544d50faee6 (patch)
tree268b2262fd73c69fd24fcbe444b4e9be5f7e1178
parent422b0ffd4cefb4717bbc9fbb7be442aff3a13c76 (diff)
downloadexchange-ed1db63a48840c417fb49dc5f0711544d50faee6.tar.gz
exchange-ed1db63a48840c417fb49dc5f0711544d50faee6.tar.bz2
exchange-ed1db63a48840c417fb49dc5f0711544d50faee6.zip
fix DB query and error handling
-rw-r--r--src/exchange/taler-exchange-httpd_kyc-proof.c15
-rw-r--r--src/exchangedb/plugin_exchangedb_postgres.c6
-rw-r--r--src/testing/testing_api_cmd_exec_aggregator.c1
3 files changed, 18 insertions, 4 deletions
diff --git a/src/exchange/taler-exchange-httpd_kyc-proof.c b/src/exchange/taler-exchange-httpd_kyc-proof.c
index 7bd9fdaa6..6bd98abfe 100644
--- a/src/exchange/taler-exchange-httpd_kyc-proof.c
+++ b/src/exchange/taler-exchange-httpd_kyc-proof.c
@@ -168,10 +168,19 @@ persist_kyc_ok (void *cls,
MHD_RESULT *mhd_ret)
{
struct KycProofContext *kpc = cls;
+ enum GNUNET_DB_QueryStatus qs;
- return TEH_plugin->set_kyc_ok (TEH_plugin->cls,
- kpc->payment_target_uuid,
- kpc->id);
+ qs = TEH_plugin->set_kyc_ok (TEH_plugin->cls,
+ kpc->payment_target_uuid,
+ kpc->id);
+ if (GNUNET_DB_STATUS_HARD_ERROR == qs)
+ {
+ GNUNET_break (0);
+ *mhd_ret = TALER_MHD_reply_with_ec (connection,
+ TALER_EC_GENERIC_DB_STORE_FAILED,
+ "set_kyc_ok");
+ }
+ return qs;
}
diff --git a/src/exchangedb/plugin_exchangedb_postgres.c b/src/exchangedb/plugin_exchangedb_postgres.c
index a5066e883..9bfe777f4 100644
--- a/src/exchangedb/plugin_exchangedb_postgres.c
+++ b/src/exchangedb/plugin_exchangedb_postgres.c
@@ -3811,6 +3811,10 @@ postgres_set_kyc_ok (void *cls,
struct PostgresClosure *pg = cls;
struct GNUNET_PQ_QueryParam params[] = {
GNUNET_PQ_query_param_uint64 (&payment_target_uuid),
+ GNUNET_PQ_query_param_end
+ };
+ struct GNUNET_PQ_QueryParam params2[] = {
+ GNUNET_PQ_query_param_uint64 (&payment_target_uuid),
GNUNET_PQ_query_param_string (id),
GNUNET_PQ_query_param_end
};
@@ -3827,7 +3831,7 @@ postgres_set_kyc_ok (void *cls,
qs = GNUNET_PQ_eval_prepared_non_select (pg->conn,
"set_kyc_ok",
- params);
+ params2);
if (qs <= 0)
return qs;
qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
diff --git a/src/testing/testing_api_cmd_exec_aggregator.c b/src/testing/testing_api_cmd_exec_aggregator.c
index 1f05576ff..0f3cc1e14 100644
--- a/src/testing/testing_api_cmd_exec_aggregator.c
+++ b/src/testing/testing_api_cmd_exec_aggregator.c
@@ -72,6 +72,7 @@ aggregator_run (void *cls,
"taler-exchange-aggregator",
"taler-exchange-aggregator",
"-c", as->config_filename,
+ "-L", "INFO",
"-t", /* exit when done */
(as->kyc_on)
? NULL