merchant_api_get_transfers.c (9703B)
1 /* 2 This file is part of TALER 3 Copyright (C) 2014-2023 Taler Systems SA 4 5 TALER is free software; you can redistribute it and/or modify it under the 6 terms of the GNU Lesser General Public License as published by the Free Software 7 Foundation; either version 2.1, or (at your option) any later version. 8 9 TALER is distributed in the hope that it will be useful, but WITHOUT ANY 10 WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR 11 A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. 12 13 You should have received a copy of the GNU Lesser General Public License along with 14 TALER; see the file COPYING.LGPL. If not, see 15 <http://www.gnu.org/licenses/> 16 */ 17 /** 18 * @file merchant_api_get_transfers.c 19 * @brief Implementation of the GET /transfers request of the merchant's HTTP API 20 * @author Marcello Stanisci 21 * @author Christian Grothoff 22 */ 23 #include "platform.h" 24 #include <curl/curl.h> 25 #include <jansson.h> 26 #include <microhttpd.h> /* just for HTTP status codes */ 27 #include <gnunet/gnunet_util_lib.h> 28 #include <gnunet/gnunet_curl_lib.h> 29 #include "taler_merchant_service.h" 30 #include "merchant_api_common.h" 31 #include "merchant_api_curl_defaults.h" 32 #include <taler/taler_json_lib.h> 33 #include <taler/taler_signatures.h> 34 35 36 /** 37 * @brief A Handle for tracking wire transfers. 38 */ 39 struct TALER_MERCHANT_GetTransfersHandle 40 { 41 42 /** 43 * The url for this request. 44 */ 45 char *url; 46 47 /** 48 * Handle for the request. 49 */ 50 struct GNUNET_CURL_Job *job; 51 52 /** 53 * Function to call with the result. 54 */ 55 TALER_MERCHANT_GetTransfersCallback cb; 56 57 /** 58 * Closure for @a cb. 59 */ 60 void *cb_cls; 61 62 /** 63 * Reference to the execution context. 64 */ 65 struct GNUNET_CURL_Context *ctx; 66 }; 67 68 69 /** 70 * Function called when we're done processing the 71 * HTTP GET /transfers request. 72 * 73 * @param cls the `struct TALER_MERCHANT_GetTransfersHandle` 74 * @param response_code HTTP response code, 0 on error 75 * @param response response body, NULL if not in JSON 76 */ 77 static void 78 handle_transfers_get_finished (void *cls, 79 long response_code, 80 const void *response) 81 { 82 struct TALER_MERCHANT_GetTransfersHandle *gth = cls; 83 const json_t *json = response; 84 struct TALER_MERCHANT_GetTransfersResponse gtr = { 85 .hr.http_status = (unsigned int) response_code, 86 .hr.reply = json 87 }; 88 89 gth->job = NULL; 90 switch (response_code) 91 { 92 case 0: 93 gtr.hr.ec = TALER_EC_GENERIC_INVALID_RESPONSE; 94 break; 95 case MHD_HTTP_OK: 96 { 97 const json_t *transfers; 98 struct GNUNET_JSON_Specification spec[] = { 99 GNUNET_JSON_spec_array_const ("transfers", 100 &transfers), 101 GNUNET_JSON_spec_end () 102 }; 103 104 if (GNUNET_OK != 105 GNUNET_JSON_parse (json, 106 spec, 107 NULL, NULL)) 108 { 109 GNUNET_break_op (0); 110 gtr.hr.http_status = 0; 111 gtr.hr.ec = TALER_EC_GENERIC_INVALID_RESPONSE; 112 break; 113 } 114 115 { 116 size_t tds_length; 117 struct TALER_MERCHANT_TransferData *tds; 118 json_t *transfer; 119 size_t i; 120 bool ok; 121 122 tds_length = json_array_size (transfers); 123 tds = GNUNET_new_array (tds_length, 124 struct TALER_MERCHANT_TransferData); 125 ok = true; 126 json_array_foreach (transfers, i, transfer) { 127 struct TALER_MERCHANT_TransferData *td = &tds[i]; 128 struct GNUNET_JSON_Specification ispec[] = { 129 TALER_JSON_spec_amount_any ("credit_amount", 130 &td->credit_amount), 131 GNUNET_JSON_spec_fixed_auto ("wtid", 132 &td->wtid), 133 TALER_JSON_spec_full_payto_uri ("payto_uri", 134 &td->payto_uri), 135 TALER_JSON_spec_web_url ("exchange_url", 136 &td->exchange_url), 137 GNUNET_JSON_spec_uint64 ("transfer_serial_id", 138 &td->credit_serial), 139 GNUNET_JSON_spec_timestamp ("execution_time", 140 &td->execution_time), 141 GNUNET_JSON_spec_bool ("expected", 142 &td->expected), 143 GNUNET_JSON_spec_end () 144 }; 145 146 if (GNUNET_OK != 147 GNUNET_JSON_parse (transfer, 148 ispec, 149 NULL, NULL)) 150 { 151 GNUNET_break_op (0); 152 ok = false; 153 break; 154 } 155 } 156 157 if (! ok) 158 { 159 GNUNET_break_op (0); 160 GNUNET_free (tds); 161 gtr.hr.http_status = 0; 162 gtr.hr.ec = TALER_EC_GENERIC_INVALID_RESPONSE; 163 break; 164 } 165 gtr.details.ok.transfers = tds; 166 gtr.details.ok.transfers_length = tds_length; 167 gth->cb (gth->cb_cls, 168 >r); 169 GNUNET_free (tds); 170 TALER_MERCHANT_transfers_get_cancel (gth); 171 return; 172 } 173 } 174 case MHD_HTTP_UNAUTHORIZED: 175 gtr.hr.ec = TALER_JSON_get_error_code (json); 176 gtr.hr.hint = TALER_JSON_get_error_hint (json); 177 /* Nothing really to verify, merchant says we need to authenticate. */ 178 break; 179 case MHD_HTTP_NOT_FOUND: 180 /* Nothing really to verify, this should never 181 happen, we should pass the JSON reply to the application */ 182 gtr.hr.ec = TALER_JSON_get_error_code (json); 183 gtr.hr.hint = TALER_JSON_get_error_hint (json); 184 break; 185 case MHD_HTTP_INTERNAL_SERVER_ERROR: 186 /* Server had an internal issue; we should retry, but this API 187 leaves this to the application */ 188 gtr.hr.ec = TALER_JSON_get_error_code (json); 189 gtr.hr.hint = TALER_JSON_get_error_hint (json); 190 break; 191 default: 192 /* unexpected response code */ 193 GNUNET_break_op (0); 194 TALER_MERCHANT_parse_error_details_ (json, 195 response_code, 196 >r.hr); 197 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, 198 "Unexpected response code %u/%d\n", 199 (unsigned int) response_code, 200 (int) gtr.hr.ec); 201 gtr.hr.http_status = 0; 202 break; 203 } 204 gth->cb (gth->cb_cls, 205 >r); 206 TALER_MERCHANT_transfers_get_cancel (gth); 207 } 208 209 210 struct TALER_MERCHANT_GetTransfersHandle * 211 TALER_MERCHANT_transfers_get ( 212 struct GNUNET_CURL_Context *ctx, 213 const char *backend_url, 214 struct TALER_FullPayto payto_uri, 215 const struct GNUNET_TIME_Timestamp before, 216 const struct GNUNET_TIME_Timestamp after, 217 int64_t limit, 218 uint64_t offset, 219 enum TALER_EXCHANGE_YesNoAll expected, 220 TALER_MERCHANT_GetTransfersCallback cb, 221 void *cb_cls) 222 { 223 struct TALER_MERCHANT_GetTransfersHandle *gth; 224 CURL *eh; 225 const char *expected_s = NULL; 226 char limit_s[30]; 227 char offset_s[30]; 228 char before_s[30]; 229 char after_s[30]; 230 231 gth = GNUNET_new (struct TALER_MERCHANT_GetTransfersHandle); 232 gth->ctx = ctx; 233 gth->cb = cb; 234 gth->cb_cls = cb_cls; 235 expected_s = TALER_yna_to_string (expected); 236 GNUNET_snprintf (limit_s, 237 sizeof (limit_s), 238 "%lld", 239 (long long) limit); 240 GNUNET_snprintf (offset_s, 241 sizeof (offset_s), 242 "%lld", 243 (unsigned long long) offset); 244 GNUNET_snprintf (before_s, 245 sizeof (before_s), 246 "%llu", 247 (unsigned long long) GNUNET_TIME_timestamp_to_s (before)); 248 GNUNET_snprintf (after_s, 249 sizeof (after_s), 250 "%llu", 251 (unsigned long long) GNUNET_TIME_timestamp_to_s (after)); 252 { 253 char *enc_payto = TALER_urlencode (payto_uri.full_payto); 254 255 gth->url = TALER_url_join (backend_url, 256 "private/transfers", 257 "payto_uri", 258 enc_payto, 259 "expected", 260 (TALER_EXCHANGE_YNA_ALL != expected) 261 ? expected_s 262 : NULL, 263 "limit", 264 0 != limit 265 ? limit_s 266 : NULL, 267 "offset", 268 ((0 != offset) && (UINT64_MAX != offset)) 269 ? offset_s 270 : NULL, 271 "before", 272 GNUNET_TIME_absolute_is_never (before.abs_time) 273 ? NULL 274 : before_s, 275 "after", 276 GNUNET_TIME_absolute_is_zero (after.abs_time) 277 ? NULL 278 : after_s, 279 NULL); 280 GNUNET_free (enc_payto); 281 } 282 if (NULL == gth->url) 283 { 284 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, 285 "Could not construct request URL.\n"); 286 GNUNET_free (gth); 287 return NULL; 288 } 289 eh = TALER_MERCHANT_curl_easy_get_ (gth->url); 290 gth->job = GNUNET_CURL_job_add (ctx, 291 eh, 292 &handle_transfers_get_finished, 293 gth); 294 return gth; 295 } 296 297 298 void 299 TALER_MERCHANT_transfers_get_cancel ( 300 struct TALER_MERCHANT_GetTransfersHandle *gth) 301 { 302 if (NULL != gth->job) 303 { 304 GNUNET_CURL_job_cancel (gth->job); 305 gth->job = NULL; 306 } 307 GNUNET_free (gth->url); 308 GNUNET_free (gth); 309 } 310 311 312 /* end of merchant_api_get_transfers.c */