1 files changed, 43 insertions, 5 deletions

diff --git a/src/backend/taler-merchant-httpd_post-orders-ID-paid.c b/src/backend/taler-merchant-httpd_post-orders-ID-paid.c
index c821ed32..d274c1f6 100644
--- a/src/backend/taler-merchant-httpd_post-orders-ID-paid.c
+++ b/src/backend/taler-merchant-httpd_post-orders-ID-paid.c
@@ -1,6 +1,6 @@
 /*
   This file is part of TALER
-  (C) 2014-2020 Taler Systems SA
+  (C) 2014-2021 Taler Systems SA
 
   TALER is free software; you can redistribute it and/or modify
   it under the terms of the GNU Affero General Public License as
@@ -29,6 +29,38 @@
 #include "taler-merchant-httpd_post-orders-ID-paid.h"
 
 
+/**
+ * Use database to notify other clients about the
+ * session being captured.
+ *
+ * @param session_id the captured session
+ * @param fulfillment_url the URL that is now paid for by @a session_id
+ */
+static void
+trigger_session_notification (const char *session_id,
+                              const char *fulfillment_url)
+{
+#ifndef TALER_API_VERSION
+#define TALER_DBEVENT_MERCHANT_SESSION_CAPTURED 1103
+#endif
+  struct TMH_SessionEvent session_eh = {
+    .header.size = htons (sizeof (session_eh)),
+    .header.type = htons (TALER_DBEVENT_MERCHANT_SESSION_CAPTURED)
+  };
+
+  GNUNET_CRYPTO_hash (session_id,
+                      strlen (session_id),
+                      &session_eh.h_session_id);
+  GNUNET_CRYPTO_hash (fulfillment_url,
+                      strlen (fulfillment_url),
+                      &session_eh.h_fulfillment_url);
+  TMH_db->event_notify (TMH_db->cls,
+                        &session_eh.header,
+                        NULL,
+                        0);
+}
+
+
 MHD_RESULT
 TMH_post_orders_ID_paid (const struct TMH_RequestHandler *rh,
                          struct MHD_Connection *connection,
@@ -145,7 +177,7 @@ TMH_post_orders_ID_paid (const struct TMH_RequestHandler *rh,
 
   fulfillment_url
     = json_string_value (json_object_get (contract_terms,
-                                            "fulfillment_url"));
+                                          "fulfillment_url"));
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Marking contract %s with %s/%s as paid\n",
               order_id,
@@ -165,15 +197,21 @@ TMH_post_orders_ID_paid (const struct TMH_RequestHandler *rh,
                                        TALER_EC_GENERIC_DB_STORE_FAILED,
                                        "mark_contract_paid");
   }
- 
-  /* Wake everybody up who waits for this fulfillment_url and session_id */ 
+
+  /* Wake everybody up who waits for this fulfillment_url and session_id */
+  if ( (NULL != fulfillment_url) &&
+       (NULL != session_id) )
+    trigger_session_notification (session_id,
+                                  fulfillment_url);
   if (NULL != fulfillment_url)
     TMH_long_poll_resume2 (session_id,
                            fulfillment_url);
 
   /* fulfillment_url is part of the contract_terms */
   json_decref (contract_terms);
-  /* Resume clients waiting on the order */
+  /* Resume clients waiting on the order
+     (NOTE: should never be needed, as /pay
+     would have triggered those, right?) */
   TMH_long_poll_resume (order_id,
                         hc->instance,
                         NULL,