[taler-exchange] branch master updated: -add notifications for inbound reserve transactions

[gnunet]

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

grothoff pushed a commit to branch master
in repository exchange.

The following commit(s) were added to refs/heads/master by this push:
     new 1cc87bf9 -add notifications for inbound reserve transactions
1cc87bf9 is described below

commit 1cc87bf9fe868b10ba7ddc93a9bbac7407107b6a
Author: Christian Grothoff <christian@grothoff.org>
AuthorDate: Sun Aug 22 12:25:48 2021 +0200

    -add notifications for inbound reserve transactions
---
 src/exchangedb/plugin_exchangedb_postgres.c | 44 +++++++++++++++++++++++++----
 1 file changed, 39 insertions(+), 5 deletions(-)

diff --git a/src/exchangedb/plugin_exchangedb_postgres.c 
b/src/exchangedb/plugin_exchangedb_postgres.c
index 98bd6de3..8b805f6b 100644
--- a/src/exchangedb/plugin_exchangedb_postgres.c
+++ b/src/exchangedb/plugin_exchangedb_postgres.c
@@ -24,6 +24,7 @@
  */
 #include "platform.h"
 #include "taler_error_codes.h"
+#include "taler_dbevents.h"
 #include "taler_pq_lib.h"
 #include "taler_json_lib.h"
 #include "taler_exchangedb_plugin.h"
@@ -3071,10 +3072,10 @@ postgres_event_notify (void *cls,
   struct PostgresClosure *pg = cls;
 
   (void) pg;
-  return GNUNET_PQ_event_notify (session->conn,
-                                 es,
-                                 extra,
-                                 extra_size);
+  GNUNET_PQ_event_notify (session->conn,
+                          es,
+                          extra,
+                          extra_size);
 }
 
 
@@ -3839,6 +3840,32 @@ reserves_update (void *cls,
 }
 
 
+/**
+ * Generate event notification for the reserve
+ * change.
+ *
+ * @param session database session to use
+ * @param reserve_pub reserve to notfiy on
+ */
+static void
+notify_on_reserve (struct PostgresClosure *pg,
+                   struct TALER_EXCHANGEDB_Session *session,
+                   const struct TALER_ReservePublicKeyP *reserve_pub)
+{
+  struct TALER_ReserveEventP rep = {
+    .header.size = htons (sizeof (rep)),
+    .header.type = htons (TALER_DBEVENT_EXCHANGE_RESERVE_INCOMING),
+    .reserve_pub = *reserve_pub
+  };
+
+  postgres_event_notify (pg,
+                         session,
+                         &rep.header,
+                         NULL,
+                         0);
+}
+
+
 /**
  * Insert an incoming transaction into reserves.  New reserves are also created
  * through this function.
@@ -3973,7 +4000,12 @@ postgres_reserves_in_insert (void *cls,
     }
   }
   if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT == qs1)
+  {
+    notify_on_reserve (pg,
+                       session,
+                       reserve_pub);
     return GNUNET_DB_STATUS_SUCCESS_ONE_RESULT; /* new reserve, we are 
finished */
+  }
 
   /* we were wrong with our optimistic assumption:
      reserve does exist, need to do an update instead */
@@ -4061,7 +4093,9 @@ postgres_reserves_in_insert (void *cls,
       break;
     }
   }
-
+  notify_on_reserve (pg,
+                     session,
+                     reserve_pub);
   /* Go back to original transaction mode */
   {
     enum GNUNET_DB_QueryStatus cs;

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