add missing notifications to private-get-orders long poller

1 files changed, 28 insertions, 0 deletions

diff --git a/src/backend/taler-merchant-httpd_private-get-orders-ID.c b/src/backend/taler-merchant-httpd_private-get-orders-ID.c
index d413f71b..e983273a 100644
--- a/src/backend/taler-merchant-httpd_private-get-orders-ID.c
+++ b/src/backend/taler-merchant-httpd_private-get-orders-ID.c
@@ -25,6 +25,8 @@
 #include <taler/taler_json_lib.h>
 #include "taler-merchant-httpd_mhd.h"
 #include "taler-merchant-httpd_exchanges.h"
+#include "taler-merchant-httpd_private-get-orders.h"
+
 
 /**
  * How long do we wait on the exchange?
@@ -1084,11 +1086,37 @@ TMH_private_get_orders_ID (const struct TMH_RequestHandler *rh,
           TALER_amount_cmp (&expect_total,
                             &gorc->deposits_total))
       {
+        struct GNUNET_TIME_Absolute timestamp;
+
         /* expect_total <= gorc->deposits_total: good: we got paid */
         wired = true;
         qs = TMH_db->mark_order_wired (TMH_db->cls,
                                        gorc->order_serial);
         GNUNET_break (qs >= 0); /* just warn if transaction failed */
+        {
+          struct GNUNET_JSON_Specification spec[] = {
+            GNUNET_JSON_spec_absolute_time ("timestamp",
+                                            &timestamp),
+            GNUNET_JSON_spec_end ()
+          };
+          enum GNUNET_GenericReturnValue res;
+
+          res = TALER_MHD_parse_internal_json_data (connection,
+                                                    gorc->contract_terms,
+                                                    spec);
+          if (GNUNET_YES != res)
+          {
+            GNUNET_break (0);
+            return res;
+          }
+        }
+        TMH_notify_order_change (hc->instance,
+                                 hc->infix,
+                                 true, /* paid */
+                                 false, /* technically unknown, but OK here */
+                                 true, /* wired */
+                                 timestamp,
+                                 gorc->order_serial);
       }
     }