merchant_api_lock_product.c (8038B)
1 /* 2 This file is part of TALER 3 Copyright (C) 2020 Taler Systems SA 4 5 TALER is free software; you can redistribute it and/or modify 6 it under the terms of the GNU Lesser General Public License as 7 published by the Free Software Foundation; either version 2.1, 8 or (at your option) any later version. 9 10 TALER is distributed in the hope that it will be useful, 11 but WITHOUT ANY WARRANTY; without even the implied warranty of 12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 13 GNU Lesser General Public License for more details. 14 15 You should have received a copy of the GNU Lesser General 16 Public License along with TALER; see the file COPYING.LGPL. 17 If not, see <http://www.gnu.org/licenses/> 18 */ 19 /** 20 * @file merchant_api_lock_product.c 21 * @brief Implementation of the POST /products/$ID/lock request 22 * of the merchant's HTTP API 23 * @author Christian Grothoff 24 */ 25 #include "platform.h" 26 #include <curl/curl.h> 27 #include <jansson.h> 28 #include <microhttpd.h> /* just for HTTP status codes */ 29 #include <gnunet/gnunet_util_lib.h> 30 #include "taler_merchant_service.h" 31 #include "merchant_api_common.h" 32 #include "merchant_api_curl_defaults.h" 33 #include <taler/taler_json_lib.h> 34 #include <taler/taler_curl_lib.h> 35 36 37 /** 38 * Handle for a POST /products/$ID/lock operation. 39 */ 40 struct TALER_MERCHANT_ProductLockHandle 41 { 42 43 /** 44 * The url for this request. 45 */ 46 char *url; 47 48 /** 49 * Handle for the request. 50 */ 51 struct GNUNET_CURL_Job *job; 52 53 /** 54 * Function to call with the result. 55 */ 56 TALER_MERCHANT_ProductLockCallback cb; 57 58 /** 59 * Closure for @a cb. 60 */ 61 void *cb_cls; 62 63 /** 64 * Reference to the execution context. 65 */ 66 struct GNUNET_CURL_Context *ctx; 67 68 /** 69 * Minor context that holds body and headers. 70 */ 71 struct TALER_CURL_PostContext post_ctx; 72 73 }; 74 75 76 /** 77 * Function called when we're done processing the 78 * HTTP POST /products/$ID/lock request. 79 * 80 * @param cls the `struct TALER_MERCHANT_ProductLockHandle` 81 * @param response_code HTTP response code, 0 on error 82 * @param response response body, NULL if not in JSON 83 */ 84 static void 85 handle_lock_product_finished (void *cls, 86 long response_code, 87 const void *response) 88 { 89 struct TALER_MERCHANT_ProductLockHandle *plh = cls; 90 const json_t *json = response; 91 struct TALER_MERCHANT_HttpResponse hr = { 92 .http_status = (unsigned int) response_code, 93 .reply = json 94 }; 95 96 plh->job = NULL; 97 GNUNET_log (GNUNET_ERROR_TYPE_INFO, 98 "LOCK /products/$ID completed with response code %u\n", 99 (unsigned int) response_code); 100 switch (response_code) 101 { 102 case 0: 103 hr.ec = TALER_EC_GENERIC_INVALID_RESPONSE; 104 break; 105 case MHD_HTTP_NO_CONTENT: 106 break; 107 case MHD_HTTP_UNAUTHORIZED: 108 hr.ec = TALER_JSON_get_error_code (json); 109 hr.hint = TALER_JSON_get_error_hint (json); 110 /* Nothing really to verify, merchant says we need to authenticate. */ 111 break; 112 case MHD_HTTP_BAD_REQUEST: 113 hr.ec = TALER_JSON_get_error_code (json); 114 hr.hint = TALER_JSON_get_error_hint (json); 115 GNUNET_break_op (0); 116 /* This should never happen, either us 117 * or the merchant is buggy (or API version conflict); 118 * just pass JSON reply to the application */ 119 break; 120 case MHD_HTTP_FORBIDDEN: 121 hr.ec = TALER_JSON_get_error_code (json); 122 hr.hint = TALER_JSON_get_error_hint (json); 123 /* Nothing really to verify, merchant says we tried to abort the payment 124 * after it was successful. We should pass the JSON reply to the 125 * application */ 126 break; 127 case MHD_HTTP_NOT_FOUND: 128 hr.ec = TALER_JSON_get_error_code (json); 129 hr.hint = TALER_JSON_get_error_hint (json); 130 break; 131 case MHD_HTTP_GONE: 132 hr.ec = TALER_JSON_get_error_code (json); 133 hr.hint = TALER_JSON_get_error_hint (json); 134 break; 135 case MHD_HTTP_INTERNAL_SERVER_ERROR: 136 hr.ec = TALER_JSON_get_error_code (json); 137 hr.hint = TALER_JSON_get_error_hint (json); 138 /* Server had an internal issue; we should retry, 139 but this API leaves this to the application */ 140 break; 141 default: 142 TALER_MERCHANT_parse_error_details_ (json, 143 response_code, 144 &hr); 145 /* unexpected response code */ 146 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, 147 "Unexpected response code %u/%d\n", 148 (unsigned int) response_code, 149 (int) hr.ec); 150 GNUNET_break_op (0); 151 break; 152 } 153 plh->cb (plh->cb_cls, 154 &hr); 155 TALER_MERCHANT_product_lock_cancel (plh); 156 } 157 158 159 struct TALER_MERCHANT_ProductLockHandle * 160 TALER_MERCHANT_product_lock2 ( 161 struct GNUNET_CURL_Context *ctx, 162 const char *backend_url, 163 const char *product_id, 164 const char *uuid, 165 struct GNUNET_TIME_Relative duration, 166 uint64_t quantity, 167 uint32_t quantity_frac, 168 bool use_fractional_quantity, 169 TALER_MERCHANT_ProductLockCallback cb, 170 void *cb_cls) 171 { 172 struct TALER_MERCHANT_ProductLockHandle *plh; 173 json_t *req_obj; 174 char unit_quantity_buf[64]; 175 176 TALER_MERCHANT_format_quantity_string (quantity, 177 quantity_frac, 178 unit_quantity_buf, 179 sizeof (unit_quantity_buf)); 180 181 req_obj = GNUNET_JSON_PACK ( 182 GNUNET_JSON_pack_string ("lock_uuid", 183 uuid), 184 GNUNET_JSON_pack_time_rel ("duration", 185 duration), 186 GNUNET_JSON_pack_string ("unit_quantity", 187 unit_quantity_buf)); 188 (void) use_fractional_quantity; 189 GNUNET_assert ( (0 == quantity_frac) || use_fractional_quantity); 190 plh = GNUNET_new (struct TALER_MERCHANT_ProductLockHandle); 191 plh->ctx = ctx; 192 plh->cb = cb; 193 plh->cb_cls = cb_cls; 194 { 195 char *path; 196 197 GNUNET_asprintf (&path, 198 "private/products/%s/lock", 199 product_id); 200 plh->url = TALER_url_join (backend_url, 201 path, 202 NULL); 203 GNUNET_free (path); 204 } 205 if (NULL == plh->url) 206 { 207 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, 208 "Could not construct request URL.\n"); 209 json_decref (req_obj); 210 GNUNET_free (plh); 211 return NULL; 212 } 213 { 214 CURL *eh; 215 216 eh = TALER_MERCHANT_curl_easy_get_ (plh->url); 217 if (GNUNET_OK != 218 TALER_curl_easy_post (&plh->post_ctx, 219 eh, 220 req_obj)) 221 { 222 GNUNET_break (0); 223 curl_easy_cleanup (eh); 224 json_decref (req_obj); 225 GNUNET_free (plh->url); 226 GNUNET_free (plh); 227 return NULL; 228 } 229 json_decref (req_obj); 230 plh->job = GNUNET_CURL_job_add2 (ctx, 231 eh, 232 plh->post_ctx.headers, 233 &handle_lock_product_finished, 234 plh); 235 } 236 return plh; 237 } 238 239 240 void 241 TALER_MERCHANT_product_lock_cancel ( 242 struct TALER_MERCHANT_ProductLockHandle *plh) 243 { 244 if (NULL != plh->job) 245 { 246 GNUNET_CURL_job_cancel (plh->job); 247 plh->job = NULL; 248 } 249 TALER_curl_easy_post_finished (&plh->post_ctx); 250 GNUNET_free (plh->url); 251 GNUNET_free (plh); 252 } 253 254 255 struct TALER_MERCHANT_ProductLockHandle * 256 TALER_MERCHANT_product_lock ( 257 struct GNUNET_CURL_Context *ctx, 258 const char *backend_url, 259 const char *product_id, 260 const char *uuid, 261 struct GNUNET_TIME_Relative duration, 262 uint32_t quantity, 263 TALER_MERCHANT_ProductLockCallback cb, 264 void *cb_cls) 265 { 266 return TALER_MERCHANT_product_lock2 (ctx, 267 backend_url, 268 product_id, 269 uuid, 270 duration, 271 quantity, 272 0, 273 false, 274 cb, 275 cb_cls); 276 } 277 278 279 /* end of merchant_api_lock_product.c */