/*
This file is part of TALER
(C) 2020-2024 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-products.c
* @brief implementing POST /products request handling
* @author Christian Grothoff
*/
#include "platform.h"
#include "taler-merchant-httpd_private-post-products.h"
#include "taler-merchant-httpd_helper.h"
#include
MHD_RESULT
TMH_private_post_products (const struct TMH_RequestHandler *rh,
struct MHD_Connection *connection,
struct TMH_HandlerContext *hc)
{
struct TMH_MerchantInstance *mi = hc->instance;
struct TALER_MERCHANTDB_ProductDetails pd = { 0 };
const json_t *categories = NULL;
const char *product_id;
int64_t total_stock;
struct GNUNET_JSON_Specification spec[] = {
GNUNET_JSON_spec_string ("product_id",
&product_id),
GNUNET_JSON_spec_string ("description",
(const char **) &pd.description),
GNUNET_JSON_spec_mark_optional (
GNUNET_JSON_spec_json ("description_i18n",
&pd.description_i18n),
NULL),
GNUNET_JSON_spec_string ("unit",
(const char **) &pd.unit),
TALER_JSON_spec_amount_any ("price",
&pd.price),
GNUNET_JSON_spec_mark_optional (
GNUNET_JSON_spec_string ("image",
(const char **) &pd.image),
NULL),
GNUNET_JSON_spec_mark_optional (
GNUNET_JSON_spec_json ("taxes",
&pd.taxes),
NULL),
GNUNET_JSON_spec_mark_optional (
GNUNET_JSON_spec_array_const ("categories",
&categories),
NULL),
GNUNET_JSON_spec_int64 ("total_stock",
&total_stock),
GNUNET_JSON_spec_mark_optional (
GNUNET_JSON_spec_json ("address",
&pd.address),
NULL),
GNUNET_JSON_spec_mark_optional (
GNUNET_JSON_spec_timestamp ("next_restock",
&pd.next_restock),
NULL),
GNUNET_JSON_spec_mark_optional (
GNUNET_JSON_spec_uint32 ("minimum_age",
&pd.minimum_age),
NULL),
GNUNET_JSON_spec_end ()
};
size_t num_cats = 0;
uint64_t *cats = NULL;
bool conflict;
bool no_instance;
ssize_t no_cat;
enum GNUNET_DB_QueryStatus qs;
MHD_RESULT ret;
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 (total_stock < -1)
{
GNUNET_break_op (0);
ret = TALER_MHD_reply_with_error (connection,
MHD_HTTP_BAD_REQUEST,
TALER_EC_GENERIC_PARAMETER_MALFORMED,
"total_stock");
goto cleanup;
}
num_cats = json_array_size (categories);
cats = GNUNET_new_array (num_cats,
uint64_t);
{
size_t idx;
json_t *val;
json_array_foreach (categories, idx, val)
{
if (! json_is_integer (val))
{
GNUNET_break_op (0);
ret = TALER_MHD_reply_with_error (connection,
MHD_HTTP_BAD_REQUEST,
TALER_EC_GENERIC_PARAMETER_MALFORMED,
"categories");
goto cleanup;
}
cats[idx] = json_integer_value (val);
}
}
if (-1 == total_stock)
pd.total_stock = INT64_MAX;
else
pd.total_stock = (uint64_t) total_stock;
if (NULL == pd.address)
pd.address = json_object ();
if (NULL == pd.description_i18n)
pd.description_i18n = json_object ();
if (NULL == pd.taxes)
pd.taxes = json_array ();
/* check taxes is well-formed */
if (! TMH_taxes_array_valid (pd.taxes))
{
GNUNET_break_op (0);
ret = TALER_MHD_reply_with_error (connection,
MHD_HTTP_BAD_REQUEST,
TALER_EC_GENERIC_PARAMETER_MALFORMED,
"taxes");
goto cleanup;
}
if (! TMH_location_object_valid (pd.address))
{
GNUNET_break_op (0);
ret = TALER_MHD_reply_with_error (connection,
MHD_HTTP_BAD_REQUEST,
TALER_EC_GENERIC_PARAMETER_MALFORMED,
"address");
goto cleanup;
}
if (! TALER_JSON_check_i18n (pd.description_i18n))
{
GNUNET_break_op (0);
ret = TALER_MHD_reply_with_error (connection,
MHD_HTTP_BAD_REQUEST,
TALER_EC_GENERIC_PARAMETER_MALFORMED,
"description_i18n");
goto cleanup;
}
if (NULL == pd.image)
pd.image = (char *) "";
if (! TMH_image_data_url_valid (pd.image))
{
GNUNET_break_op (0);
ret = TALER_MHD_reply_with_error (connection,
MHD_HTTP_BAD_REQUEST,
TALER_EC_GENERIC_PARAMETER_MALFORMED,
"image");
goto cleanup;
}
qs = TMH_db->insert_product (TMH_db->cls,
mi->settings.id,
product_id,
&pd,
num_cats,
cats,
&no_instance,
&conflict,
&no_cat);
switch (qs)
{
case GNUNET_DB_STATUS_HARD_ERROR:
case GNUNET_DB_STATUS_SOFT_ERROR:
ret = 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);
goto cleanup;
case GNUNET_DB_STATUS_SUCCESS_NO_RESULTS:
ret = TALER_MHD_reply_with_error (
connection,
MHD_HTTP_INTERNAL_SERVER_ERROR,
TALER_EC_GENERIC_DB_INVARIANT_FAILURE,
NULL);
goto cleanup;
case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT:
break;
}
if (no_instance)
{
ret = TALER_MHD_reply_with_error (
connection,
MHD_HTTP_NOT_FOUND,
TALER_EC_MERCHANT_GENERIC_INSTANCE_UNKNOWN,
mi->settings.id);
goto cleanup;
}
if (conflict)
{
ret = TALER_MHD_reply_with_error (
connection,
MHD_HTTP_CONFLICT,
TALER_EC_MERCHANT_PRIVATE_POST_PRODUCTS_CONFLICT_PRODUCT_EXISTS,
product_id);
goto cleanup;
}
if (-1 != no_cat)
{
char nocats[24];
GNUNET_break_op (0);
TMH_db->rollback (TMH_db->cls);
GNUNET_snprintf (nocats,
sizeof (nocats),
"%llu",
(unsigned long long) no_cat);
ret = TALER_MHD_reply_with_error (
connection,
MHD_HTTP_NOT_FOUND,
TALER_EC_MERCHANT_GENERIC_CATEGORY_UNKNOWN,
nocats);
goto cleanup;
}
ret = TALER_MHD_reply_static (connection,
MHD_HTTP_NO_CONTENT,
NULL,
NULL,
0);
cleanup:
GNUNET_JSON_parse_free (spec);
GNUNET_free (cats);
return ret;
}
/* end of taler-merchant-httpd_private-post-products.c */