diff options
| author | Bohdan Potuzhnyi <potub1@bfh.ch> | 2024-11-04 20:52:37 +0000 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2024-11-15 13:50:49 +0100 |
| commit | c3bb01e7360d218d3fbf60ef83be094a834be57c (patch) | |
| tree | b85d816d6d2bbb1363c233418faf29b961c2d879 | |
| parent | cb9c060e5e12ea767603d7883be7b2919221ee4b (diff) | |
small change
| -rw-r--r-- | src/backend/taler-merchant-httpd_private-post-orders.c | 69 |
1 files changed, 34 insertions, 35 deletions
diff --git a/src/backend/taler-merchant-httpd_private-post-orders.c b/src/backend/taler-merchant-httpd_private-post-orders.c index 3d8b89df..498c51f7 100644 --- a/src/backend/taler-merchant-httpd_private-post-orders.c +++ b/src/backend/taler-merchant-httpd_private-post-orders.c @@ -885,6 +885,40 @@ execute_transaction (struct OrderContext *oc) return qs; } + { + enum GNUNET_DB_QueryStatus qs; + json_t *jhook; + + jhook = GNUNET_JSON_PACK( + GNUNET_JSON_pack_string("order_id", + oc->parse_order.order_id), + GNUNET_JSON_pack_object_incref("contract", + oc->serialize_order.contract), + GNUNET_JSON_pack_string("instance_id", + oc->hc->instance->settings.id) + ); + GNUNET_assert(NULL != jhook); + + qs = TMH_trigger_webhook(oc->hc->instance->settings.id, + "order_created", + jhook); + + json_decref(jhook); + + if (0 >= qs) + { + TMH_db->rollback (TMH_db->cls); + if (GNUNET_DB_STATUS_SOFT_ERROR == qs) + return qs; + GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); + reply_with_error (oc, + MHD_HTTP_INTERNAL_SERVER_ERROR, + TALER_EC_GENERIC_DB_STORE_FAILED, + "failed to trigger webhooks"); + return qs; + } + } + TMH_notify_order_change (oc->hc->instance, TMH_OSF_NONE, timestamp, @@ -1080,41 +1114,6 @@ execute_order (struct OrderContext *oc) "Order creation succeeded\n"); { - enum GNUNET_DB_QueryStatus qs; - json_t *jhook; - - jhook = GNUNET_JSON_PACK( - GNUNET_JSON_pack_string("order_id", - oc->parse_order.order_id), - GNUNET_JSON_pack_object_incref("contract", - oc->serialize_order.contract), - GNUNET_JSON_pack_string("instance_id", - oc->hc->instance->settings.id) - ); - GNUNET_assert(NULL != jhook); - -// webhook_qs = TMH_trigger_webhook(oc->hc->instance->settings.id, -// "order_created", -// jhook); - -// json_decref(jhook); -// -// if (0 >= webhook_qs) -// { -// TMH_db->rollback (TMH_db->cls); -// if (GNUNET_DB_STATUS_SOFT_ERROR == webhook_qs) -// return webhook_qs; /* do it again */ -// /* Always report on hard error as well to enable diagnostics */ -// GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == webhook_qs); -// reply_with_error (oc, -// MHD_HTTP_INTERNAL_SERVER_ERROR, -// TALER_EC_GENERIC_DB_STORE_FAILED, -// "failed to trigger webhooks"); -// return webhook_qs; -// } - } - - { MHD_RESULT ret; ret = TALER_MHD_REPLY_JSON_PACK ( |