exchange

testing_api_cmd_wire.c (6308B)

---

 /*
   This file is part of TALER
   Copyright (C) 2018, 2023 Taler Systems SA
 
   TALER is free software; you can redistribute it and/or modify it
   under the terms of the GNU 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 testing/testing_api_cmd_wire.c
  * @brief command for testing /wire.
  * @author Marcello Stanisci
  */
 #include "taler/taler_json_lib.h"
 #include <gnunet/gnunet_curl_lib.h>
 #include "taler/taler_testing_lib.h"
 
 
 /**
  * State for a "wire" CMD.
  */
 struct WireState
 {
 
   /**
    * Handle to the /wire operation.
    */
   struct TALER_EXCHANGE_WireHandle *wh;
 
   /**
    * Our command.
    */
   const struct TALER_TESTING_Command *cmd;
 
   /**
    * Which wire-method we expect is offered by the exchange.
    */
   const char *expected_method;
 
   /**
    * Flag indicating if the expected method is actually
    * offered.
    */
   unsigned int method_found;
 
   /**
    * Fee we expect is charged for this wire-transfer method.
    */
   const char *expected_fee;
 
   /**
    * Expected HTTP response code.
    */
   unsigned int expected_response_code;
 
   /**
    * Interpreter state.
    */
   struct TALER_TESTING_Interpreter *is;
 };
 
 
 /**
  * Check whether the HTTP response code is acceptable, that
  * the expected wire method is offered by the exchange, and
  * that the wire fee is acceptable too.
  *
  * @param cls closure.
  * @param wr response details
  */
 static void
 wire_cb (void *cls,
          const struct TALER_EXCHANGE_WireResponse *wr)
 {
   struct WireState *ws = cls;
   const struct TALER_EXCHANGE_HttpResponse *hr = &wr->hr;
   struct TALER_Amount expected_fee;
 
   TALER_LOG_DEBUG ("Checking parsed /wire response\n");
   ws->wh = NULL;
   if (ws->expected_response_code != hr->http_status)
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Received unexpected status code %u\n",
                 hr->http_status);
     TALER_TESTING_interpreter_fail (ws->is);
     return;
   }
 
   if (MHD_HTTP_OK == hr->http_status)
   {
     unsigned int accounts_len
       = wr->details.ok.accounts_len;
     unsigned int fees_len
       = wr->details.ok.fees_len;
     const struct TALER_EXCHANGE_WireAccount *accounts
       = wr->details.ok.accounts;
     const struct TALER_EXCHANGE_WireFeesByMethod *fees
       = wr->details.ok.fees;
 
     for (unsigned int i = 0; i<accounts_len; i++)
     {
       char *method;
 
       method = TALER_payto_get_method (accounts[i].payto_uri);
       if (NULL == method)
       {
         GNUNET_break (0);
         TALER_TESTING_interpreter_fail (ws->is);
         return;
       }
       if (0 == strcmp (ws->expected_method,
                        method))
       {
         ws->method_found = GNUNET_OK;
       }
       GNUNET_free (method);
     }
     if (NULL != ws->expected_fee)
     {
       bool fee_found = false;
 
       GNUNET_assert (GNUNET_OK ==
                      TALER_string_to_amount (ws->expected_fee,
                                              &expected_fee));
       for (unsigned int i = 0; i<fees_len; i++)
       {
         if (0 != strcmp (fees[i].method,
                          ws->expected_method))
           continue;
         for (const struct TALER_EXCHANGE_WireAggregateFees *waf
                = fees[i].fees_head;
              NULL != waf;
              waf = waf->next)
         {
           if (0 != TALER_amount_cmp (&waf->fees.wire,
                                      &expected_fee))
           {
             GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                         "Wire fee mismatch to command %s\n",
                         ws->cmd->label);
             TALER_TESTING_interpreter_fail (ws->is);
             return;
           }
           fee_found = true;
         }
       }
       if (! fee_found)
       {
         GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                     "/wire does not contain expected fee '%s'\n",
                     ws->expected_fee);
         TALER_TESTING_interpreter_fail (ws->is);
         return;
       }
     }
     if (GNUNET_OK != ws->method_found)
     {
       GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                   "/wire does not offer method '%s'\n",
                   ws->expected_method);
       TALER_TESTING_interpreter_fail (ws->is);
       return;
     }
   }
   TALER_TESTING_interpreter_next (ws->is);
 }
 
 
 /**
  * Run the command.
  *
  * @param cls closure.
  * @param cmd the command to execute.
  * @param is the interpreter state.
  */
 static void
 wire_run (void *cls,
           const struct TALER_TESTING_Command *cmd,
           struct TALER_TESTING_Interpreter *is)
 {
   struct WireState *ws = cls;
 
   ws->cmd = cmd;
   ws->is = is;
   ws->wh = TALER_EXCHANGE_wire (
     TALER_TESTING_interpreter_get_context (is),
     TALER_TESTING_get_exchange_url (is),
     TALER_TESTING_get_keys (is),
     &wire_cb,
     ws);
 }
 
 
 /**
  * Cleanup the state of a "wire" CMD, and possibly cancel a
  * pending operation thereof.
  *
  * @param cls closure.
  * @param cmd the command which is being cleaned up.
  */
 static void
 wire_cleanup (void *cls,
               const struct TALER_TESTING_Command *cmd)
 {
   struct WireState *ws = cls;
 
   if (NULL != ws->wh)
   {
     TALER_TESTING_command_incomplete (ws->is,
                                       cmd->label);
     TALER_EXCHANGE_wire_cancel (ws->wh);
     ws->wh = NULL;
   }
   GNUNET_free (ws);
 }
 
 
 struct TALER_TESTING_Command
 TALER_TESTING_cmd_wire (const char *label,
                         const char *expected_method,
                         const char *expected_fee,
                         unsigned int expected_response_code)
 {
   struct WireState *ws;
 
   ws = GNUNET_new (struct WireState);
   ws->expected_method = expected_method;
   ws->expected_fee = expected_fee;
   ws->expected_response_code = expected_response_code;
   {
     struct TALER_TESTING_Command cmd = {
       .cls = ws,
       .label = label,
       .run = &wire_run,
       .cleanup = &wire_cleanup
     };
 
     return cmd;
   }
 }