diff options
| author | Christian Grothoff <christian@grothoff.org> | 2024-01-08 15:28:25 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2024-01-08 15:28:25 +0100 |
| commit | bc1e8787e5954ca2d433f495bee336e7b57c1654 (patch) | |
| tree | e1a806851cbb7eb7ccbe688942329fc0691dfe97 /src/exchangedb | |
| parent | b26bab5ed8069ac79dda032a5167363ebb4727e7 (diff) | |
fix long-polling on purses GET with purse refund event
Diffstat (limited to 'src/exchangedb')
| -rw-r--r-- | src/exchangedb/exchange_do_expire_purse.sql | 3 | ||||
| -rw-r--r-- | src/exchangedb/pg_insert_aml_decision.c | 2 | ||||
| -rw-r--r-- | src/exchangedb/pg_insert_kyc_attributes.c | 2 | ||||
| -rw-r--r-- | src/exchangedb/pg_reserves_in_insert.c | 2 |
4 files changed, 6 insertions, 3 deletions
diff --git a/src/exchangedb/exchange_do_expire_purse.sql b/src/exchangedb/exchange_do_expire_purse.sql index 1a17869ad..ee9757f03 100644 --- a/src/exchangedb/exchange_do_expire_purse.sql +++ b/src/exchangedb/exchange_do_expire_purse.sql @@ -56,6 +56,9 @@ VALUES ,in_now ,TRUE); +-- Code for 'TALER_DBEVENT_EXCHANGE_PURSE_REFUNDED' +NOTIFY X8DJSPNYJMNZDAP7GN6YQ4EZVSQXMF3HRP4VAR347WP9SZYP1C200; + IF (my_in_reserve_quota) THEN UPDATE reserves diff --git a/src/exchangedb/pg_insert_aml_decision.c b/src/exchangedb/pg_insert_aml_decision.c index a3653824c..39419be59 100644 --- a/src/exchangedb/pg_insert_aml_decision.c +++ b/src/exchangedb/pg_insert_aml_decision.c @@ -49,7 +49,7 @@ TEH_PG_insert_aml_decision ( .header.type = htons (TALER_DBEVENT_EXCHANGE_KYC_COMPLETED), .h_payto = *h_payto }; - char *notify_s = GNUNET_PG_get_event_notify_channel (&rep.header); + char *notify_s = GNUNET_PQ_get_event_notify_channel (&rep.header); char *kyc_s = (NULL != kyc_requirements) ? json_dumps (kyc_requirements, JSON_COMPACT) : NULL; diff --git a/src/exchangedb/pg_insert_kyc_attributes.c b/src/exchangedb/pg_insert_kyc_attributes.c index 8b3cf84c6..3c94abb85 100644 --- a/src/exchangedb/pg_insert_kyc_attributes.c +++ b/src/exchangedb/pg_insert_kyc_attributes.c @@ -53,7 +53,7 @@ TEH_PG_insert_kyc_attributes ( .h_payto = *h_payto }; char *kyc_completed_notify_s - = GNUNET_PG_get_event_notify_channel (&rep.header); + = GNUNET_PQ_get_event_notify_channel (&rep.header); struct GNUNET_PQ_QueryParam params[] = { GNUNET_PQ_query_param_uint64 (&process_row), GNUNET_PQ_query_param_auto_from_type (h_payto), diff --git a/src/exchangedb/pg_reserves_in_insert.c b/src/exchangedb/pg_reserves_in_insert.c index 17cb496bf..21734942a 100644 --- a/src/exchangedb/pg_reserves_in_insert.c +++ b/src/exchangedb/pg_reserves_in_insert.c @@ -51,7 +51,7 @@ compute_notify_on_reserve (const struct TALER_ReservePublicKeyP *reserve_pub) .reserve_pub = *reserve_pub }; - return GNUNET_PG_get_event_notify_channel (&rep.header); + return GNUNET_PQ_get_event_notify_channel (&rep.header); } |