diff options
author | Christian Blättler <blatc2@bfh.ch> | 2023-11-21 08:06:00 +0100 |
---|---|---|
committer | Christian Grothoff <grothoff@gnunet.org> | 2023-12-23 00:08:57 +0800 |
commit | 094327bc906cdeced19a52c86dc0725aad773997 (patch) | |
tree | b459428305452298749cb90438c7a734a64230d1 /src/backend/taler-merchant-httpd_private-post-token-families.c | |
parent | 20632c6a2e293a9799114497d63180a105b37065 (diff) | |
download | merchant-094327bc906cdeced19a52c86dc0725aad773997.tar.gz merchant-094327bc906cdeced19a52c86dc0725aad773997.tar.bz2 merchant-094327bc906cdeced19a52c86dc0725aad773997.zip |
POST /tokenfamilies endpoint
Diffstat (limited to 'src/backend/taler-merchant-httpd_private-post-token-families.c')
-rw-r--r-- | src/backend/taler-merchant-httpd_private-post-token-families.c | 229 |
1 files changed, 229 insertions, 0 deletions
diff --git a/src/backend/taler-merchant-httpd_private-post-token-families.c b/src/backend/taler-merchant-httpd_private-post-token-families.c new file mode 100644 index 00000000..6ff25942 --- /dev/null +++ b/src/backend/taler-merchant-httpd_private-post-token-families.c @@ -0,0 +1,229 @@ +/* + 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 <http://www.gnu.org/licenses/> +*/ + +/** + * @file taler-merchant-httpd_private-post-token-families.c + * @brief implementing POST /tokenfamilies request handling + * @author Christian Blättler + */ +#include "platform.h" +#include "taler-merchant-httpd_private-post-token-families.h" +#include "taler-merchant-httpd_helper.h" +#include <taler/taler_json_lib.h> + + +/** + * How often do we retry the simple INSERT database transaction? + */ +#define MAX_RETRIES 3 + + +/** + * Check if the two token families are identical. + * + * @param tf1 token family to compare + * @param tf2 other token family to compare + * @return true if they are 'equal', false if not + */ +static bool +token_families_equal (const struct TALER_MERCHANTDB_TokenFamilyDetails *tf1, + const struct TALER_MERCHANTDB_TokenFamilyDetails *tf2) +{ + return ( (0 == strcmp (tf1->slug, + tf2->slug)) && + (0 == strcmp (tf1->name, + tf2->name)) && + (0 == strcmp (tf1->description, + tf2->description)) && + (1 == json_equal (tf1->description_i18n, + tf2->description_i18n)) && + (GNUNET_TIME_timestamp_cmp (tf1->valid_after, + ==, + tf2->valid_after)) && + (GNUNET_TIME_timestamp_cmp (tf1->valid_before, + ==, + tf2->valid_before)) && + (GNUNET_TIME_relative_cmp (tf1->duration, + ==, + tf2->duration)) && + (tf1->kind == tf2->kind) ); +} + + +MHD_RESULT +TMH_private_post_token_families (const struct TMH_RequestHandler *rh, + struct MHD_Connection *connection, + struct TMH_HandlerContext *hc) +{ + struct TMH_MerchantInstance *mi = hc->instance; + struct TALER_MERCHANTDB_TokenFamilyDetails details = { 0 }; + enum GNUNET_DB_QueryStatus qs; + struct GNUNET_JSON_Specification spec[] = { + GNUNET_JSON_spec_string ("slug", + (const char **) &details.slug), + GNUNET_JSON_spec_string ("name", + (const char **) &details.name), + GNUNET_JSON_spec_string ("description", + (const char **) &details.description), + GNUNET_JSON_spec_mark_optional ( + GNUNET_JSON_spec_json ("description_i18n", + &details.description_i18n), + NULL), + GNUNET_JSON_spec_uint32("kind", &details.kind), + GNUNET_JSON_spec_timestamp ("valid_after", + &details.valid_after), + GNUNET_JSON_spec_timestamp ("valid_before", + &details.valid_before), + GNUNET_JSON_spec_relative_time ("duration", + &details.duration), + 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; + } + } + + if (NULL == details.description_i18n) + details.description_i18n = json_object (); + + if (! TALER_JSON_check_i18n (details.description_i18n)) + { + GNUNET_break_op (0); + GNUNET_JSON_parse_free (spec); + return TALER_MHD_reply_with_error (connection, + MHD_HTTP_BAD_REQUEST, + TALER_EC_GENERIC_PARAMETER_MALFORMED, + "description_i18n"); + } + + + /* finally, interact with DB until no serialization error */ + for (unsigned int i = 0; i<MAX_RETRIES; i++) + { + /* Test if a token family of this id is known */ + struct TALER_MERCHANTDB_TokenFamilyDetails existing; + + if (GNUNET_OK != + TMH_db->start (TMH_db->cls, + "/post tokenfamilies")) + { + 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_token_family (TMH_db->cls, + mi->settings.id, + details.slug, + &existing); + 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 existing == details? */ + { + bool eq; + + eq = token_families_equal (&details, + &existing); + TALER_MERCHANTDB_token_family_details_free (&existing); + 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) + // TODO: Use proper error code + : TALER_MHD_reply_with_error (connection, + MHD_HTTP_CONFLICT, + 0, + details.slug); + } + } /* end switch (qs) */ + + qs = TMH_db->insert_token_family (TMH_db->cls, + mi->settings.id, + details.slug, + &details); + 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-token-families.c */ |