[taler-exchange] branch master updated: aggregator: store requirement row and subsequently notify

[gnunet]

This is an automated email from the git hooks/post-receive script.

dold pushed a commit to branch master
in repository exchange.

The following commit(s) were added to refs/heads/master by this push:
     new 850c105f2 aggregator: store requirement row and subsequently notify
850c105f2 is described below

commit 850c105f2b2bdd29bc833fdb6f954af50a9e88ed
Author: Florian Dold <florian@dold.me>
AuthorDate: Wed Dec 11 13:33:04 2024 +0100

    aggregator: store requirement row and subsequently notify
---
 src/exchange/taler-exchange-aggregator.c | 32 ++++++++++++++++++++++++++++++++
 1 file changed, 32 insertions(+)

diff --git a/src/exchange/taler-exchange-aggregator.c 
b/src/exchange/taler-exchange-aggregator.c
index 9e2a38896..b67d002e9 100644
--- a/src/exchange/taler-exchange-aggregator.c
+++ b/src/exchange/taler-exchange-aggregator.c
@@ -891,6 +891,38 @@ evaluate_rules (
               "Legitimization process %llu started\n",
               (unsigned long long) au->requirement_row);
   TALER_KYCLOGIC_rules_free (lrs);
+
+  qs = db_plugin->update_aggregation_transient (db_plugin->cls,
+                                                &au->h_full_payto,
+                                                &au->wtid,
+                                                au->requirement_row,
+                                                &au->total_amount);
+
+
+  if (qs < 0)
+  {
+    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+                "Failed to persist updated transient in in DB!\n");
+    GNUNET_break (GNUNET_DB_STATUS_SOFT_ERROR == qs);
+    if (GNUNET_DB_STATUS_HARD_ERROR == qs)
+      global_ret = EXIT_FAILURE;
+    cleanup_and_next (au);
+    return;
+  }
+
+  {
+    struct TALER_CoinDepositEventP rep = {
+      .header.size = htons (sizeof (rep)),
+      .header.type = htons (TALER_DBEVENT_EXCHANGE_DEPOSIT_STATUS_CHANGED),
+      .merchant_pub = au->merchant_pub
+    };
+
+    db_plugin->event_notify (db_plugin->cls,
+                             &rep.header,
+                             NULL,
+                             0);
+  }
+
   /* First commit, turns the rollback in cleanup into a NOP! */
   commit_or_warn ();
   cleanup_and_next (au);

-- 
To stop receiving notification emails like this one, please contact
gnunet@gnunet.org.