summaryrefslogtreecommitdiff
path: root/src/bank-lib/taler-wire-gateway-client.c
diff options
context:
space:
mode:
authorMS <ms@taler.net>2020-07-29 16:07:57 +0200
committerMS <ms@taler.net>2020-07-29 16:07:57 +0200
commit799822220eb22e82f4af561c9c26723e3715385f (patch)
tree28f276ee019bac58ea747154cf81f733afc1350c /src/bank-lib/taler-wire-gateway-client.c
parent67ee9a9ec08fa2c70c196b19a560f202ac6b2bba (diff)
downloadexchange-799822220eb22e82f4af561c9c26723e3715385f.tar.gz
exchange-799822220eb22e82f4af561c9c26723e3715385f.tar.bz2
exchange-799822220eb22e82f4af561c9c26723e3715385f.zip
rename tool
Diffstat (limited to 'src/bank-lib/taler-wire-gateway-client.c')
-rw-r--r--src/bank-lib/taler-wire-gateway-client.c740
1 files changed, 740 insertions, 0 deletions
diff --git a/src/bank-lib/taler-wire-gateway-client.c b/src/bank-lib/taler-wire-gateway-client.c
new file mode 100644
index 000000000..58fd57c79
--- /dev/null
+++ b/src/bank-lib/taler-wire-gateway-client.c
@@ -0,0 +1,740 @@
+/*
+ This file is part of TALER
+ Copyright (C) 2017-2020 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 taler-bank-transfer.c
+ * @brief Execute wire transfer.
+ * @author Christian Grothoff
+ */
+#include "platform.h"
+#include <gnunet/gnunet_util_lib.h>
+#include <gnunet/gnunet_json_lib.h>
+#include <jansson.h>
+#include "taler_bank_service.h"
+
+/**
+ * If set to #GNUNET_YES, then we'll ask the bank for a list
+ * of incoming transactions from the account.
+ */
+static int incoming_history;
+
+/**
+ * If set to #GNUNET_YES, then we'll ask the bank for a list
+ * of outgoing transactions from the account.
+ */
+static int outgoing_history;
+
+/**
+ * Amount to transfer.
+ */
+static struct TALER_Amount amount;
+
+/**
+ * Credit account payto://-URI.
+ */
+static char *credit_account;
+
+/**
+ * Debit account payto://-URI.
+ */
+static char *debit_account;
+
+/**
+ * Wire transfer subject.
+ */
+static char *subject;
+
+/**
+ * Which config section has the credentials to access the bank.
+ */
+static char *account_section;
+
+/**
+ * Starting row.
+ */
+static unsigned long long start_row;
+
+/**
+ * Authentication data.
+ */
+static struct TALER_BANK_AuthenticationData auth;
+
+/**
+ * Return value from main().
+ */
+static int global_ret = 1;
+
+/**
+ * Main execution context for the main loop.
+ */
+static struct GNUNET_CURL_Context *ctx;
+
+/**
+ * Handle to ongoing credit history operation.
+ */
+static struct TALER_BANK_CreditHistoryHandle *chh;
+
+/**
+ * Handle to ongoing debit history operation.
+ */
+static struct TALER_BANK_DebitHistoryHandle *dhh;
+
+/**
+ * Handle for executing the wire transfer.
+ */
+static struct TALER_BANK_TransferHandle *eh;
+
+/**
+ * Handle to access the exchange.
+ */
+static struct TALER_BANK_AdminAddIncomingHandle *op;
+
+/**
+ * Context for running the CURL event loop.
+ */
+static struct GNUNET_CURL_RescheduleContext *rc;
+
+
+/**
+ * Function run when the test terminates (good or bad).
+ * Cleans up our state.
+ *
+ * @param cls NULL
+ */
+static void
+do_shutdown (void *cls)
+{
+ (void) cls;
+ if (NULL != op)
+ {
+ TALER_BANK_admin_add_incoming_cancel (op);
+ op = NULL;
+ }
+ if (NULL != chh)
+ {
+ TALER_BANK_credit_history_cancel (chh);
+ chh = NULL;
+ }
+ if (NULL != dhh)
+ {
+ TALER_BANK_debit_history_cancel (dhh);
+ dhh = NULL;
+ }
+ if (NULL != eh)
+ {
+ TALER_BANK_transfer_cancel (eh);
+ eh = NULL;
+ }
+ if (NULL != ctx)
+ {
+ GNUNET_CURL_fini (ctx);
+ ctx = NULL;
+ }
+ if (NULL != rc)
+ {
+ GNUNET_CURL_gnunet_rc_destroy (rc);
+ rc = NULL;
+ }
+ TALER_BANK_auth_free (&auth);
+}
+
+
+/**
+ * Callback used to process ONE entry in the transaction
+ * history returned by the bank.
+ *
+ * @param cls closure
+ * @param http_status HTTP status code from server
+ * @param ec taler error code
+ * @param serial_id identification of the position at
+ * which we are returning data
+ * @param details details about the wire transfer
+ * @param json original full response from server
+ * @return #GNUNET_OK to continue, #GNUNET_SYSERR to
+ * abort iteration
+ */
+static int
+credit_history_cb (void *cls,
+ unsigned int http_status,
+ enum TALER_ErrorCode ec,
+ uint64_t serial_id,
+ const struct TALER_BANK_CreditDetails *details,
+ const json_t *json)
+{
+ (void) cls;
+
+ if (MHD_HTTP_OK != http_status)
+ {
+ if ( (MHD_HTTP_NO_CONTENT != http_status) ||
+ (TALER_EC_NONE != ec) ||
+ (NULL == details) )
+ {
+ fprintf (stderr,
+ "Failed to obtain credit history: %u/%d\n",
+ http_status,
+ ec);
+ if (NULL != json)
+ json_dumpf (json,
+ stderr,
+ JSON_INDENT (2));
+ global_ret = 2;
+ GNUNET_SCHEDULER_shutdown ();
+ return GNUNET_NO;
+ }
+ fprintf (stdout,
+ "End of transactions list.\n");
+ global_ret = 0;
+ GNUNET_SCHEDULER_shutdown ();
+ return GNUNET_NO;
+ }
+
+ /* If credit/debit accounts were specified, use as a filter */
+ if ( (NULL != credit_account) &&
+ (0 != strcasecmp (credit_account,
+ details->credit_account_url) ) )
+ return GNUNET_OK;
+ if ( (NULL != debit_account) &&
+ (0 != strcasecmp (debit_account,
+ details->debit_account_url) ) )
+ return GNUNET_OK;
+
+ fprintf (stdout,
+ "%llu: %s->%s (%s) over %s at %s\n",
+ (unsigned long long) serial_id,
+ details->debit_account_url,
+ details->credit_account_url,
+ TALER_B2S (&details->reserve_pub),
+ TALER_amount2s (&details->amount),
+ GNUNET_STRINGS_absolute_time_to_string (details->execution_date));
+ return GNUNET_OK;
+}
+
+
+/**
+ * Ask the bank the list of transactions for the bank account
+ * mentioned in the config section given by the user.
+ */
+static void
+execute_credit_history ()
+{
+ if (NULL != subject)
+ {
+ fprintf (stderr,
+ "Specifying subject is not supported when inspecting credit history\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+ chh = TALER_BANK_credit_history (ctx,
+ &auth,
+ start_row,
+ -10,
+ &credit_history_cb,
+ NULL);
+ if (NULL == chh)
+ {
+ fprintf (stderr,
+ "Could not request the credit transaction history.\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+}
+
+
+/**
+ * Function with the debit debit transaction history.
+ *
+ * @param cls closure
+ * @param http_status HTTP response code, #MHD_HTTP_OK (200) for successful status request
+ * 0 if the bank's reply is bogus (fails to follow the protocol),
+ * #MHD_HTTP_NO_CONTENT if there are no more results; on success the
+ * last callback is always of this status (even if `abs(num_results)` were
+ * already returned).
+ * @param ec detailed error code
+ * @param serial_id monotonically increasing counter corresponding to the transaction
+ * @param details details about the wire transfer
+ * @param json detailed response from the HTTPD, or NULL if reply was not in JSON
+ * @return #GNUNET_OK to continue, #GNUNET_SYSERR to abort iteration
+ */
+static int
+debit_history_cb (void *cls,
+ unsigned int http_status,
+ enum TALER_ErrorCode ec,
+ uint64_t serial_id,
+ const struct TALER_BANK_DebitDetails *details,
+ const json_t *json)
+{
+ (void) cls;
+
+ if (MHD_HTTP_OK != http_status)
+ {
+ if ( (MHD_HTTP_NO_CONTENT != http_status) ||
+ (TALER_EC_NONE != ec) ||
+ (NULL == details) )
+ {
+ fprintf (stderr,
+ "Failed to obtain debit history: %u/%d\n",
+ http_status,
+ ec);
+ if (NULL != json)
+ json_dumpf (json,
+ stderr,
+ JSON_INDENT (2));
+ global_ret = 2;
+ GNUNET_SCHEDULER_shutdown ();
+ return GNUNET_NO;
+ }
+ fprintf (stdout,
+ "End of transactions list.\n");
+ global_ret = 0;
+ GNUNET_SCHEDULER_shutdown ();
+ return GNUNET_NO;
+ }
+
+ /* If credit/debit accounts were specified, use as a filter */
+ if ( (NULL != credit_account) &&
+ (0 != strcasecmp (credit_account,
+ details->credit_account_url) ) )
+ return GNUNET_OK;
+ if ( (NULL != debit_account) &&
+ (0 != strcasecmp (debit_account,
+ details->debit_account_url) ) )
+ return GNUNET_OK;
+
+ fprintf (stdout,
+ "%llu: %s->%s (%s) over %s at %s\n",
+ (unsigned long long) serial_id,
+ details->debit_account_url,
+ details->credit_account_url,
+ TALER_B2S (&details->wtid),
+ TALER_amount2s (&details->amount),
+ GNUNET_STRINGS_absolute_time_to_string (details->execution_date));
+ return GNUNET_OK;
+}
+
+
+/**
+ * Ask the bank the list of transactions for the bank account
+ * mentioned in the config section given by the user.
+ */
+static void
+execute_debit_history ()
+{
+ if (NULL != subject)
+ {
+ fprintf (stderr,
+ "Specifying subject is not supported when inspecting debit history\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+ dhh = TALER_BANK_debit_history (ctx,
+ &auth,
+ start_row,
+ -10,
+ &debit_history_cb,
+ NULL);
+ if (NULL == dhh)
+ {
+ fprintf (stderr,
+ "Could not request the debit transaction history.\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+}
+
+
+/**
+ * Callback that processes the outcome of a wire transfer
+ * execution.
+ *
+ * @param cls closure
+ * @param response_code HTTP status code
+ * @param ec taler error code
+ * @param row_id unique ID of the wire transfer in the bank's records
+ * @param timestamp when did the transaction go into effect
+ */
+static void
+confirmation_cb (void *cls,
+ unsigned int response_code,
+ enum TALER_ErrorCode ec,
+ uint64_t row_id,
+ struct GNUNET_TIME_Absolute timestamp)
+{
+ (void) cls;
+ eh = NULL;
+ if (MHD_HTTP_OK != response_code)
+ {
+ fprintf (stderr,
+ "The wire transfer didn't execute correctly (%u/%d).\n",
+ response_code,
+ ec);
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+
+ fprintf (stdout,
+ "Wire transfer #%llu executed successfully at %s.\n",
+ (unsigned long long) row_id,
+ GNUNET_STRINGS_absolute_time_to_string (timestamp));
+ global_ret = 0;
+ GNUNET_SCHEDULER_shutdown ();
+}
+
+
+/**
+ * Ask the bank to execute a wire transfer.
+ */
+static void
+execute_wire_transfer ()
+{
+ struct TALER_WireTransferIdentifierRawP wtid;
+ void *buf;
+ size_t buf_size;
+ char *params;
+
+ if (NULL != debit_account)
+ {
+ fprintf (stderr,
+ "Invalid option -C specified, conflicts with -D\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+
+ // See if subject was given as a payto-parameter.
+ if (NULL == subject)
+ subject = TALER_payto_get_subject (credit_account);
+ if (NULL != subject)
+ {
+ if (GNUNET_OK !=
+ GNUNET_STRINGS_string_to_data (subject,
+ strlen (subject),
+ &wtid,
+ sizeof (wtid)))
+ {
+ fprintf (stderr,
+ "Error: wire transfer subject must be a WTID\n");
+ return;
+ }
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+ else
+ {
+ /* pick one at random */
+ GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_NONCE,
+ &wtid,
+ sizeof (wtid));
+ }
+ params = strchr (credit_account,
+ (unsigned char) '&');
+ if (NULL != params)
+ *params = '\0';
+ TALER_BANK_prepare_transfer (credit_account,
+ &amount,
+ "http://exchange.example.com/",
+ &wtid,
+ &buf,
+ &buf_size);
+ eh = TALER_BANK_transfer (ctx,
+ &auth,
+ buf,
+ buf_size,
+ &confirmation_cb,
+ NULL);
+ if (NULL == eh)
+ {
+ fprintf (stderr,
+ "Could not execute the wire transfer\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+}
+
+
+/**
+ * Function called with the result of the operation.
+ *
+ * @param cls closure
+ * @param http_status HTTP response code, #MHD_HTTP_OK (200) for successful status request
+ * 0 if the bank's reply is bogus (fails to follow the protocol)
+ * @param ec detailed error code
+ * @param serial_id unique ID of the wire transfer in the bank's records; UINT64_MAX on error
+ * @param timestamp timestamp when the transaction got settled at the bank.
+ * @param json detailed response from the HTTPD, or NULL if reply was not in JSON
+ */
+static void
+res_cb (void *cls,
+ unsigned int http_status,
+ enum TALER_ErrorCode ec,
+ uint64_t serial_id,
+ struct GNUNET_TIME_Absolute timestamp,
+ const json_t *json)
+{
+ (void) cls;
+ (void) timestamp;
+ op = NULL;
+ switch (ec)
+ {
+ case TALER_EC_NONE:
+ global_ret = 0;
+ fprintf (stdout,
+ "%llu\n",
+ (unsigned long long) serial_id);
+ break;
+ default:
+ fprintf (stderr,
+ "Operation failed with status code %u/%u\n",
+ (unsigned int) ec,
+ http_status);
+ if (NULL != json)
+ json_dumpf (json,
+ stderr,
+ JSON_INDENT (2));
+ break;
+ }
+ GNUNET_SCHEDULER_shutdown ();
+}
+
+
+/**
+ * Ask the bank to execute a wire transfer to the exchange.
+ */
+static void
+execute_admin_transfer ()
+{
+ struct TALER_ReservePublicKeyP reserve_pub;
+
+ if (NULL != subject)
+ {
+ if (GNUNET_OK !=
+ GNUNET_STRINGS_string_to_data (subject,
+ strlen (subject),
+ &reserve_pub,
+ sizeof (reserve_pub)))
+ {
+ fprintf (stderr,
+ "Error: wire transfer subject must be a reserve public key\n");
+ return;
+ }
+ }
+ else
+ {
+ /* pick one that is kind-of well-formed at random */
+ GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_NONCE,
+ &reserve_pub,
+ sizeof (reserve_pub));
+ }
+ op = TALER_BANK_admin_add_incoming (ctx,
+ &auth,
+ &reserve_pub,
+ &amount,
+ credit_account,
+ &res_cb,
+ NULL);
+ if (NULL == op)
+ {
+ fprintf (stderr,
+ "Could not execute the wire transfer to the exchange\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+}
+
+
+/**
+ * Main function that will be run.
+ *
+ * @param cls closure
+ * @param args remaining command-line arguments
+ * @param cfgfile name of the configuration file used (for saving, can be NULL!)
+ * @param cfg configuration
+ */
+static void
+run (void *cls,
+ char *const *args,
+ const char *cfgfile,
+ const struct GNUNET_CONFIGURATION_Handle *cfg)
+{
+ (void) cls;
+ (void) args;
+ (void) cfgfile;
+ (void) cfg;
+
+ GNUNET_SCHEDULER_add_shutdown (&do_shutdown,
+ NULL);
+ ctx = GNUNET_CURL_init (&GNUNET_CURL_gnunet_scheduler_reschedule,
+ &rc);
+ GNUNET_assert (NULL != ctx);
+ rc = GNUNET_CURL_gnunet_rc_create (ctx);
+ if (NULL != account_section)
+ {
+ if ( (NULL != auth.wire_gateway_url) ||
+ (NULL != auth.details.basic.username) ||
+ (NULL != auth.details.basic.password) )
+ {
+ fprintf (stderr,
+ "Conflicting authentication options provided. Please only use one method.\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+ if (GNUNET_OK !=
+ TALER_BANK_auth_parse_cfg (cfg,
+ account_section,
+ &auth))
+ {
+ fprintf (stderr,
+ "Authentication information not found in configuration section `%s'\n",
+ account_section);
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+ }
+ else
+ {
+ if ( (NULL != auth.wire_gateway_url) &&
+ (NULL != auth.details.basic.username) &&
+ (NULL != auth.details.basic.password) )
+ {
+ auth.method = TALER_BANK_AUTH_BASIC;
+ }
+ else if (NULL == auth.wire_gateway_url)
+ {
+ fprintf (stderr,
+ "No account specified (use -b or -s options).\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+ }
+ if ( (GNUNET_YES == incoming_history) &&
+ (GNUNET_YES == incoming_history) )
+ {
+ fprintf (stderr,
+ "Please specify only -i or -o, but not both.\n");
+ GNUNET_SCHEDULER_shutdown ();
+ return;
+ }
+ if (GNUNET_YES == incoming_history)
+ {
+ execute_credit_history ();
+ return;
+ }
+ if (GNUNET_YES == outgoing_history)
+ {
+ execute_debit_history ();
+ return;
+ }
+ if (NULL != credit_account)
+ {
+ execute_wire_transfer ();
+ return;
+ }
+ if (NULL != debit_account)
+ {
+ execute_admin_transfer ();
+ return;
+ }
+
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+ "No operation specified.\n");
+ global_ret = 0;
+ GNUNET_SCHEDULER_shutdown ();
+}
+
+
+/**
+ * The main function of the taler-bank-transfer tool
+ *
+ * @param argc number of arguments from the command line
+ * @param argv command line arguments
+ * @return 0 ok, 1 on error
+ */
+int
+main (int argc,
+ char *const *argv)
+{
+ const struct GNUNET_GETOPT_CommandLineOption options[] = {
+ TALER_getopt_get_amount ('a',
+ "amount",
+ "VALUE",
+ "value to transfer",
+ &amount),
+ GNUNET_GETOPT_option_string ('b',
+ "bank",
+ "URL",
+ "Wire gateway URL to use to talk to the bank",
+ &auth.wire_gateway_url),
+ GNUNET_GETOPT_option_help ("Deposit funds into a Taler reserve"),
+ GNUNET_GETOPT_option_string ('C',
+ "credit",
+ "ACCOUNT",
+ "payto URI of the bank account to credit (when making outgoing transfers)",
+ &credit_account),
+ GNUNET_GETOPT_option_string ('D',
+ "debit",
+ "PAYTO-URL",
+ "payto URI of the bank account to debit (when making incoming transfers)",
+ &debit_account),
+ GNUNET_GETOPT_option_flag ('i',
+ "credit-history",
+ "Ask to get a list of 10 incoming transactions.",
+ &incoming_history),
+ GNUNET_GETOPT_option_flag ('o',
+ "debit-history",
+ "Ask to get a list of 10 outgoing transactions.",
+ &outgoing_history),
+ GNUNET_GETOPT_option_string ('p',
+ "pass",
+ "PASSPHRASE",
+ "passphrase to use for authentication",
+ &auth.details.basic.password),
+ GNUNET_GETOPT_option_string ('s',
+ "section",
+ "ACCOUNT-SECTION",
+ "Which config section has the credentials to access the bank. Conflicts with -b -u and -p options.\n",
+ &account_section),
+ GNUNET_GETOPT_option_string ('S',
+ "subject",
+ "SUBJECT",
+ "specifies the wire transfer subject",
+ &subject),
+ GNUNET_GETOPT_option_string ('u',
+ "user",
+ "USERNAME",
+ "username to use for authentication",
+ &auth.details.basic.username),
+ GNUNET_GETOPT_option_ulong ('w',
+ "since-when",
+ "ROW",
+ "When asking the bank for transactions history, this option commands that all the results should have IDs settled after SW. If not given, then the 10 youngest transactions are returned.",
+ &start_row),
+ GNUNET_GETOPT_OPTION_END
+ };
+
+ GNUNET_assert (GNUNET_OK ==
+ GNUNET_log_setup ("taler-bank-transfer",
+ "WARNING",
+ NULL));
+ global_ret = 1;
+ if (GNUNET_OK !=
+ GNUNET_PROGRAM_run (argc, argv,
+ "taler-bank-transfer",
+ "Client tool of the Taler Wire Gateway",
+ options,
+ &run, NULL))
+ return 1;
+ return global_ret;
+}
+
+
+/* end taler-bank-transfer.c */