/*
This file is part of TALER
(C) 2023 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
published by the Free Software Foundation; either version 3,
or (at your option) any later version.
TALER is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public
License along with TALER; see the file COPYING. If not,
see
*/
/**
* @file taler-merchant-httpd_private-post-pending-webhooks.c
* @brief implementing POST /pending webhooks request handling
* @author Priscilla HUANG
*/
#include "platform.h"
#include "taler-merchant-httpd_private-post-webhooks.h"
#include "taler-merchant-httpd_helper.h"
#include
/**
* How often do we retry the simple INSERT database transaction?
*/
#define MAX_RETRIES 3
/**
* Check if the two pending webhooks are identical.
*
* @param pw1 pending webhook to compare
* @param pw2 other pending webhook to compare
* @return true if they are 'equal', false if not or of payto_uris is not an array
*/
static bool
pending_webhooks_equal (const struct TALER_MERCHANTDB_PendingWebhookDetails *pw1,
const struct TALER_MERCHANTDB_PendingWebhookDetails *pw2)
{
return ( (GNUNET_TIME_absolute_cmp (pw1->next_attempt,
==,
pw2->next_attempt)) &&
(pw1->retries == pw2->retries) &&
(0 == strcmp (pw1->url,
pw2->url)) &&
(0 == strcmp (pw1->http_method,
pw2->http_method)) &&
(0 == strcmp (pw1->header,
pw2->heade)) &&
(0 == strcmp (pw1->body,
pw2->body)));
}
MHD_RESULT
TMH_private_post_pending_webhooks (const struct TMH_RequestHandler *rh,
struct MHD_Connection *connection,
struct TMH_HandlerContext *hc)
{
struct TMH_MerchantInstance *mi = hc->instance;
struct TALER_MERCHANTDB_PendingWebhookDetails pwb = { 0 };
uint64_t *webhook_serial;
enum GNUNET_DB_QueryStatus qs;
struct GNUNET_JSON_Specification spec[] = {
GNUNET_JSON_spec_uint64 ("webhook_serial",
&webhook_serial),
GNUNET_JSON_spec_absolute ("next_attempt",
&pwb.next_attempt),
GNUNET_JSON_spec_uint64 ("retries",
&pwb.retries),
GNUNET_JSON_spec_string ("url",
(const char **) &wb.url),
GNUNET_JSON_spec_string ("http_method",
(const char **) &wb.http_method),
GNUNET_JSON_spec_string ("header",
(const char **) &wb.header),
GNUNET_JSON_spec_string ("body",
(const char **) &wb.body),
GNUNET_JSON_spec_end ()
};
GNUNET_assert (NULL != mi);
{
enum GNUNET_GenericReturnValue res;
res = TALER_MHD_parse_json_data (connection,
hc->request_body,
spec);
if (GNUNET_OK != res)
{
GNUNET_break_op (0);
return (GNUNET_NO == res)
? MHD_YES
: MHD_NO;
}
}
/* finally, interact with DB until no serialization error */
for (unsigned int i = 0; istart (TMH_db->cls,
"/post pending webhooks"))
{
GNUNET_break (0);
GNUNET_JSON_parse_free (spec);
return TALER_MHD_reply_with_error (connection,
MHD_HTTP_INTERNAL_SERVER_ERROR,
TALER_EC_GENERIC_DB_START_FAILED,
NULL);
}
qs = TMH_db->lookup_pending_webhook (TMH_db->cls,
mi->settings.id,
webhook_serial,
&ewb);
switch (qs)
{
case GNUNET_DB_STATUS_HARD_ERROR:
/* Clean up and fail hard */
GNUNET_break (0);
TMH_db->rollback (TMH_db->cls);
GNUNET_JSON_parse_free (spec);
return TALER_MHD_reply_with_error (connection,
MHD_HTTP_INTERNAL_SERVER_ERROR,
TALER_EC_GENERIC_DB_FETCH_FAILED,
NULL);
case GNUNET_DB_STATUS_SOFT_ERROR:
/* restart transaction */
goto retry;
case GNUNET_DB_STATUS_SUCCESS_NO_RESULTS:
/* Good, we can proceed! */
break;
case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT:
/* idempotency check: is ewb == wb? */
{
bool eq;
eq = pending_webhooks_equal (&pwb,
&epwb);
TALER_MERCHANTDB_pending_webhook_details_free(&epwb);
TMH_db->rollback (TMH_db->cls);
GNUNET_JSON_parse_free (spec);
return eq
? TALER_MHD_reply_static (connection,
MHD_HTTP_NO_CONTENT,
NULL,
NULL,
0)
: TALER_MHD_reply_with_error (connection,
MHD_HTTP_CONFLICT,
TALER_EC_MERCHANT_PRIVATE_POST_PENDING_WEBHOOKS_CONFLICT_PENDING_WEBHOOKS_EXISTS,
webhook_serial
}
} /* end switch (qs) */
qs = TMH_db->insert_pending_webhook (TMH_db->cls,
mi->settings.id,
webhook_serial,
&pwb);
if (GNUNET_DB_STATUS_HARD_ERROR == qs)
{
TMH_db->rollback (TMH_db->cls);
break;
}
if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT == qs)
{
qs = TMH_db->commit (TMH_db->cls);
if (GNUNET_DB_STATUS_SOFT_ERROR != qs)
break;
}
retry:
GNUNET_assert (GNUNET_DB_STATUS_SOFT_ERROR == qs);
TMH_db->rollback (TMH_db->cls);
} /* for RETRIES loop */
GNUNET_JSON_parse_free (spec);
if (qs < 0)
{
GNUNET_break (0);
return TALER_MHD_reply_with_error (
connection,
MHD_HTTP_INTERNAL_SERVER_ERROR,
(GNUNET_DB_STATUS_SOFT_ERROR == qs)
? TALER_EC_GENERIC_DB_SOFT_FAILURE
: TALER_EC_GENERIC_DB_COMMIT_FAILED,
NULL);
}
return TALER_MHD_reply_static (connection,
MHD_HTTP_NO_CONTENT,
NULL,
NULL,
0);
}
/* end of taler-merchant-httpd_private-post-pending-webhooks.c */