diff options
Diffstat (limited to 'src/exchange-lib/testing_api_cmd_wire.c')
-rw-r--r-- | src/exchange-lib/testing_api_cmd_wire.c | 267 |
1 files changed, 267 insertions, 0 deletions
diff --git a/src/exchange-lib/testing_api_cmd_wire.c b/src/exchange-lib/testing_api_cmd_wire.c new file mode 100644 index 000000000..f65daec00 --- /dev/null +++ b/src/exchange-lib/testing_api_cmd_wire.c @@ -0,0 +1,267 @@ +/* + This file is part of TALER + Copyright (C) 2018 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 exchange-lib/testing_api_cmd_wire.c + * @brief command for testing /wire. + * @author Marcello Stanisci + */ + +#include "platform.h" +#include "taler_json_lib.h" +#include <gnunet/gnunet_curl_lib.h> +#include "exchange_api_handle.h" +#include "taler_testing_lib.h" + +struct WireState +{ + + /** + * Handle to the /wire operation. + */ + struct TALER_EXCHANGE_WireHandle *wh; + + /** + * Which wire-method we expect are 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; + + /** + * Connection to the exchange. + */ + struct TALER_EXCHANGE_Handle *exchange; +}; + + +/** + * Check all the expected values have been returned by /wire. + * + * @param cls closure + * @param wire_method name of the wire method (i.e. "sepa") + * @param fees fee structure for this method + */ +static void +check_method_and_fee_cb + (void *cls, + const char *wire_method, + const struct TALER_EXCHANGE_WireAggregateFees *fees); + +/** + * Callbacks called with the result(s) of a wire format inquiry + * request to the exchange. + * + * @param cls closure with the interpreter state + * @param http_status HTTP response code, #MHD_HTTP_OK (200) + * for successful request; 0 if the exchange's + * reply is bogus (fails to follow the protocol) + * @param ec taler-specific error code, #TALER_EC_NONE on success + * @param obj the received JSON reply, if successful this should + * be the wire format details as provided by /wire. + */ +static void +wire_cb (void *cls, + unsigned int http_status, + enum TALER_ErrorCode ec, + const json_t *obj) +{ + struct WireState *ws = cls; + struct TALER_TESTING_Command *cmd + = &ws->is->commands[ws->is->ip]; + + /** + * The handle has been free'd by GNUnet curl-lib. FIXME: + * shouldn't GNUnet nullify it once it frees it? + */ + ws->wh = NULL; + if (ws->expected_response_code != http_status) + { + GNUNET_break (0); + TALER_TESTING_interpreter_fail (ws->is); + return; + } + + if (GNUNET_OK != TALER_EXCHANGE_wire_get_fees + (&TALER_EXCHANGE_get_keys (ws->exchange)->master_pub, + obj, + // will check synchronously. + &check_method_and_fee_cb, + ws)) + { + GNUNET_log (GNUNET_ERROR_TYPE_ERROR, + "Wire fee extraction in command %s failed\n", + cmd->label); + json_dumpf (obj, stderr, 0); + TALER_TESTING_interpreter_fail (ws->is); + return; + } + + if (ws->method_found != GNUNET_OK) + { + 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); +} + +/** + * Check all the expected values have been returned by /wire. + * + * @param cls closure + * @param wire_method name of the wire method (i.e. "sepa") + * @param fees fee structure for this method + */ +static void +check_method_and_fee_cb + (void *cls, + const char *wire_method, + const struct TALER_EXCHANGE_WireAggregateFees *fees) +{ + struct WireState *ws = cls; + struct TALER_TESTING_Command *cmd + = &ws->is->commands[ws->is->ip]; // ugly? + struct TALER_Amount expected_fee; + + if (0 == strcmp (ws->expected_method, wire_method)) + ws->method_found = GNUNET_OK; + + if ( ws->expected_fee && (ws->method_found == GNUNET_OK) ) + { + GNUNET_assert (GNUNET_OK == TALER_string_to_amount + (ws->expected_fee, + &expected_fee)); + while (NULL != fees) + { + if (0 != TALER_amount_cmp (&fees->wire_fee, + &expected_fee)) + { + GNUNET_log (GNUNET_ERROR_TYPE_ERROR, + "Wire fee missmatch to command %s\n", + cmd->label); + TALER_TESTING_interpreter_fail (ws->is); + return; + } + fees = fees->next; + } + } +} + +/** + * Run the command. + * + * @param cls closure, typically a #struct WireState. + * @param cmd the command to execute, a /wire one. + * @param i the interpreter state. + */ +void +wire_run (void *cls, + const struct TALER_TESTING_Command *cmd, + struct TALER_TESTING_Interpreter *i) +{ + struct WireState *ws = cls; + ws->is = i; + ws->wh = TALER_EXCHANGE_wire (ws->exchange, + &wire_cb, + ws); +} + + +/** + * Cleanup the state. + * + * @param cls closure, typically a #struct WireState. + * @param cmd the command which is being cleaned up. + */ +void +wire_cleanup (void *cls, + const struct TALER_TESTING_Command *cmd) +{ + struct WireState *ws = cls; + + if (NULL != ws->wh) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Command %u (%s) did not complete\n", + ws->is->ip, + cmd->label); + TALER_EXCHANGE_wire_cancel (ws->wh); + ws->wh = NULL; + } + GNUNET_free (ws); +} + +/** + * Create a /wire command. + * + * @param label the command label. + * @param exchange the exchange to connect to. + * @param expected_method which wire-transfer method is expected + * to be offered by the exchange. + * @param expected_fee the fee the exchange should charge. + * @param expected_response_code the HTTP response the exchange + * should return. + * + * @return the command to be executed by the interpreter. + */ +struct TALER_TESTING_Command +TALER_TESTING_cmd_wire (const char *label, + struct TALER_EXCHANGE_Handle *exchange, + const char *expected_method, + const char *expected_fee, + unsigned int expected_response_code) +{ + struct TALER_TESTING_Command cmd; + struct WireState *ws; + + ws = GNUNET_new (struct WireState); + ws->exchange = exchange; + ws->expected_method = expected_method; + ws->expected_fee = expected_fee; + ws->expected_response_code = expected_response_code; + + cmd.cls = ws; + cmd.label = label; + cmd.run = &wire_run; + cmd.cleanup = &wire_cleanup; + + return cmd; +} |