diff options
| author | Christian Grothoff <christian@grothoff.org> | 2024-01-10 15:48:16 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2024-01-10 15:48:16 +0100 |
| commit | 715f38ee2fcfcafab081ce98fc698178edf3a5b1 (patch) | |
| tree | a6e17c0ebb5b62592a04cb18d9d660705f523e47 /src/backend | |
| parent | be24c4b9fd68cca3e5b330642183a3b3d6d24b8c (diff) | |
| download | merchant-715f38ee2fcfcafab081ce98fc698178edf3a5b1.tar.gz merchant-715f38ee2fcfcafab081ce98fc698178edf3a5b1.tar.bz2 merchant-715f38ee2fcfcafab081ce98fc698178edf3a5b1.zip | |
convert insert_transfer_details into stored procedure, may still need some debugging, but tests (still) pass
Diffstat (limited to 'src/backend')
| -rw-r--r-- | src/backend/taler-merchant-wirewatch.c | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/src/backend/taler-merchant-wirewatch.c b/src/backend/taler-merchant-wirewatch.c index 23e5b4de..ab49d8f5 100644 --- a/src/backend/taler-merchant-wirewatch.c +++ b/src/backend/taler-merchant-wirewatch.c @@ -341,6 +341,9 @@ credit_cb ( w->start_row = serial_id; return GNUNET_OK; } + /* FIXME: consider grouping multiple inserts + into one bigger transaction with just one + notify! */ qs = db_plugin->insert_transfer (db_plugin->cls, w->instance_id, exchange_url, @@ -362,6 +365,17 @@ credit_cb ( GNUNET_SCHEDULER_shutdown (); return GNUNET_SYSERR; } + { + struct GNUNET_DB_EventHeaderP es = { + .size = htons (sizeof (es)), + .type = htons (TALER_DBEVENT_MERCHANT_WIRE_TRANSFER_CONFIRMED) + }; + + db_plugin->event_notify (db_plugin->cls, + &es, + NULL, + 0); + } } w->start_row = serial_id; return GNUNET_OK; |