Line data    Source code 
       1              : /*
       2              :   This file is part of TALER
       3              :   Copyright (C) 2022 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_patch_account.c
      21              :  * @brief Implementation of the PATCH /accounts/$ID request
      22              :  *        of the merchant's HTTP API
      23              :  * @author Priscilla HUANG
      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 PATCH /accounts/$ID operation.
      39              :  */
      40              : struct TALER_MERCHANT_AccountPatchHandle
      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_AccountPatchCallback 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 PATCH /accounts/$ID request.
      79              :  *
      80              :  * @param cls the `struct TALER_MERCHANT_AccountPatchHandle`
      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            0 : handle_patch_account_finished (void *cls,
      86              :                                 long response_code,
      87              :                                 const void *response)
      88              : {
      89            0 :   struct TALER_MERCHANT_AccountPatchHandle *tph = cls;
      90            0 :   const json_t *json = response;
      91            0 :   struct TALER_MERCHANT_HttpResponse hr = {
      92            0 :     .http_status = (unsigned int) response_code,
      93              :     .reply = json
      94              :   };
      95              : 
      96            0 :   tph->job = NULL;
      97            0 :   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
      98              :               "PATCH /accounts/$ID completed with response code %u\n",
      99              :               (unsigned int) response_code);
     100            0 :   switch (response_code)
     101              :   {
     102            0 :   case 0:
     103            0 :     hr.ec = TALER_EC_GENERIC_INVALID_RESPONSE;
     104            0 :     break;
     105            0 :   case MHD_HTTP_NO_CONTENT:
     106            0 :     break;
     107            0 :   case MHD_HTTP_BAD_REQUEST:
     108            0 :     hr.ec = TALER_JSON_get_error_code (json);
     109            0 :     hr.hint = TALER_JSON_get_error_hint (json);
     110            0 :     GNUNET_break_op (0);
     111              :     /* This should never happen, either us
     112              :      * or the merchant is buggy (or API version conflict);
     113              :      * just pass JSON reply to the application */
     114            0 :     break;
     115            0 :   case MHD_HTTP_UNAUTHORIZED:
     116            0 :     hr.ec = TALER_JSON_get_error_code (json);
     117            0 :     hr.hint = TALER_JSON_get_error_hint (json);
     118              :     /* Nothing really to verify, merchant says we need to authenticate. */
     119            0 :     break;
     120            0 :   case MHD_HTTP_FORBIDDEN:
     121            0 :     hr.ec = TALER_JSON_get_error_code (json);
     122            0 :     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            0 :     break;
     127            0 :   case MHD_HTTP_NOT_FOUND:
     128            0 :     hr.ec = TALER_JSON_get_error_code (json);
     129            0 :     hr.hint = TALER_JSON_get_error_hint (json);
     130            0 :     break;
     131            0 :   case MHD_HTTP_CONFLICT:
     132            0 :     hr.ec = TALER_JSON_get_error_code (json);
     133            0 :     hr.hint = TALER_JSON_get_error_hint (json);
     134            0 :     break;
     135            0 :   case MHD_HTTP_INTERNAL_SERVER_ERROR:
     136            0 :     hr.ec = TALER_JSON_get_error_code (json);
     137            0 :     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            0 :     break;
     141            0 :   default:
     142            0 :     TALER_MERCHANT_parse_error_details_ (json,
     143              :                                          response_code,
     144              :                                          &hr);
     145              :     /* unexpected response code */
     146            0 :     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
     147              :                 "Unexpected response code %u/%d\n",
     148              :                 (unsigned int) response_code,
     149              :                 (int) hr.ec);
     150            0 :     GNUNET_break_op (0);
     151            0 :     break;
     152              :   }
     153            0 :   tph->cb (tph->cb_cls,
     154              :            &hr);
     155            0 :   TALER_MERCHANT_account_patch_cancel (tph);
     156            0 : }
     157              : 
     158              : 
     159              : struct TALER_MERCHANT_AccountPatchHandle *
     160            0 : TALER_MERCHANT_account_patch (
     161              :   struct GNUNET_CURL_Context *ctx,
     162              :   const char *backend_url,
     163              :   const struct TALER_MerchantWireHashP *h_wire,
     164              :   const char *credit_facade_url,
     165              :   const json_t *credit_facade_credentials,
     166              :   TALER_MERCHANT_AccountPatchCallback cb,
     167              :   void *cb_cls)
     168              : {
     169              :   struct TALER_MERCHANT_AccountPatchHandle *tph;
     170              :   json_t *req_obj;
     171              : 
     172            0 :   req_obj = GNUNET_JSON_PACK (
     173              :     GNUNET_JSON_pack_allow_null (
     174              :       GNUNET_JSON_pack_string ("credit_facade_url",
     175              :                                credit_facade_url)),
     176              :     GNUNET_JSON_pack_allow_null (
     177              :       GNUNET_JSON_pack_object_incref ("credit_facade_credentials",
     178              :                                       (json_t *) credit_facade_credentials)));
     179            0 :   tph = GNUNET_new (struct TALER_MERCHANT_AccountPatchHandle);
     180            0 :   tph->ctx = ctx;
     181            0 :   tph->cb = cb;
     182            0 :   tph->cb_cls = cb_cls;
     183              :   {
     184              :     char w_str[sizeof (*h_wire) * 2];
     185              :     char *path;
     186              :     char *end;
     187              : 
     188            0 :     end = GNUNET_STRINGS_data_to_string (h_wire,
     189              :                                          sizeof (*h_wire),
     190              :                                          w_str,
     191              :                                          sizeof (w_str));
     192            0 :     *end = '\0';
     193            0 :     GNUNET_asprintf (&path,
     194              :                      "private/accounts/%s",
     195              :                      w_str);
     196            0 :     tph->url = TALER_url_join (backend_url,
     197              :                                path,
     198              :                                NULL);
     199            0 :     GNUNET_free (path);
     200              :   }
     201            0 :   if (NULL == tph->url)
     202              :   {
     203            0 :     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
     204              :                 "Could not construct request URL.\n");
     205            0 :     json_decref (req_obj);
     206            0 :     GNUNET_free (tph);
     207            0 :     return NULL;
     208              :   }
     209              :   {
     210              :     CURL *eh;
     211              : 
     212            0 :     eh = TALER_MERCHANT_curl_easy_get_ (tph->url);
     213            0 :     if (GNUNET_OK !=
     214            0 :         TALER_curl_easy_post (&tph->post_ctx,
     215              :                               eh,
     216              :                               req_obj))
     217              :     {
     218            0 :       GNUNET_break (0);
     219            0 :       curl_easy_cleanup (eh);
     220            0 :       json_decref (req_obj);
     221            0 :       GNUNET_free (tph);
     222            0 :       return NULL;
     223              :     }
     224            0 :     json_decref (req_obj);
     225            0 :     GNUNET_assert (CURLE_OK ==
     226              :                    curl_easy_setopt (eh,
     227              :                                      CURLOPT_CUSTOMREQUEST,
     228              :                                      MHD_HTTP_METHOD_PATCH));
     229            0 :     tph->job = GNUNET_CURL_job_add2 (ctx,
     230              :                                      eh,
     231            0 :                                      tph->post_ctx.headers,
     232              :                                      &handle_patch_account_finished,
     233              :                                      tph);
     234              :   }
     235            0 :   return tph;
     236              : }
     237              : 
     238              : 
     239              : void
     240            0 : TALER_MERCHANT_account_patch_cancel (
     241              :   struct TALER_MERCHANT_AccountPatchHandle *tph)
     242              : {
     243            0 :   if (NULL != tph->job)
     244              :   {
     245            0 :     GNUNET_CURL_job_cancel (tph->job);
     246            0 :     tph->job = NULL;
     247              :   }
     248            0 :   TALER_curl_easy_post_finished (&tph->post_ctx);
     249            0 :   GNUNET_free (tph->url);
     250            0 :   GNUNET_free (tph);
     251            0 : }
     252              : 
     253              : 
     254              : /* end of merchant_api_patch_account.c */
        
               |