taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Wire plugin.

Browse Source 
Put logic to use the history-range API.
This commit is contained in:
Marcello Stanisci 2019-04-17 14:54:46 +02:00
parent 1fdec6b1bf
commit 5d3ae9655e
No known key found for this signature in database
GPG Key ID: 8D526861953F4C0F
1 changed files with 85 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

102
src/wire-plugins/plugin_wire_taler-bank.c
View File

@ -1014,10 +1014,11 @@ bhist_cb (void *cls,
* transfers. The @a start_off value must thus match the value of
* a `row_off` argument previously given to the @a hres_cb. Use
* NULL to query transfers from the beginning of time (with
* positive @a num_results) or from the lataler_bank committed transfers
* (with negative @a num_results).
* positive @a num_results) or from the lataler_bank committed
* transfers (with negative @a num_results).
*
* @param cls the @e cls of this struct with the plugin-specific state
* @param cls the @e cls of this struct with the plugin-specific
* state
* @param account_section specifies the configuration section which
* identifies the account for which we should get the history
* @param direction what kinds of wire transfers should be returned
@ -1059,13 +1060,18 @@ taler_bank_get_history (void *cls,
(sizeof (uint64_t) != start_off_len) )
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"Wire plugin 'taler_bank' got start offset of wrong size (%llu instead of %llu)\n",
"Wire plugin 'taler_bank' got"
" start offset of wrong size (%llu"
" instead of %llu)\n",
(unsigned long long) start_off_len,
(unsigned long long) sizeof (uint64_t));
GNUNET_break (0);
/* Probably something is wrong with the DB, some other component
* wrote a wrong value to it. Instead of completely stopping to work,
* we just scan from the beginning. */
/**
* Probably something is wrong with the DB, some
* other component wrote a wrong value to it. Instead
* of completely stopping to work, we just scan from the
* beginning. */
start_off = NULL;
}
if (NULL == start_off)
@ -1109,7 +1115,7 @@ taler_bank_get_history (void *cls,
&whh->auth,
(uint64_t) account.no,
direction,
/* Defaults to descending ordering always. */
/* Defaults to descending ordering always. */
GNUNET_NO,
start_row,
num_results,
@ -1136,9 +1142,11 @@ taler_bank_get_history (void *cls,
* Query transfer history of an account. The query is based on
* the dates where the wire transfers got settled at the bank.
*
* @param cls the @e cls of this struct with the plugin-specific state
* @param cls the @e cls of this struct with the plugin-specific
* state
* @param account_section specifies the configuration section which
* identifies the account for which we should get the history
* identifies the account for which we should get the
* history
* @param direction what kinds of wire transfers should be returned
* @param start_date each history entry in the result will be time
* stamped after, or at this date.
@ -1149,16 +1157,76 @@ taler_bank_get_history (void *cls,
* @param return the operation handle, or NULL on errors.
*/
static struct TALER_WIRE_HistoryHandle *
taler_bank_get_history_range (void *cls,
const char *account_section,
enum TALER_BANK_Direction direction,
struct GNUNET_TIME_Absolute start_date,
struct GNUNET_TIME_Absolute end_date,
TALER_WIRE_HistoryResultCallback hres_cb,
void *hres_cb_cls)
taler_bank_get_history_range
(void *cls,
const char *account_section,
enum TALER_BANK_Direction direction,
struct GNUNET_TIME_Absolute start_date,
struct GNUNET_TIME_Absolute end_date,
TALER_WIRE_HistoryResultCallback hres_cb,
void *hres_cb_cls)
{
GNUNET_break (0);
return NULL;
struct Account account;
struct TalerBankClosure *tc = cls;
struct TALER_WIRE_HistoryHandle *whh;
if (GNUNET_OK !=
parse_account_cfg (tc->cfg,
account_section,
&account))
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"Could not parse the config section '%s'\n",
account_section);
return NULL;
}
whh = GNUNET_new (struct TALER_WIRE_HistoryHandle);
whh->hres_cb = hres_cb;
whh->hres_cb_cls = hres_cb_cls;
if (GNUNET_OK !=
TALER_BANK_auth_parse_cfg (tc->cfg,
account_section,
&whh->auth))
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"Could not parse the auth values from '%s'\n",
account_section);
GNUNET_free (whh);
return NULL;
}
whh->hh = TALER_BANK_history_range (tc->ctx,
account.bank_base_url,
&whh->auth,
account.no,
direction,
/* Just always descending. */
GNUNET_NO,
start_date,
end_date,
&bhist_cb,
whh);
if (NULL == whh->hh)
{
GNUNET_break (0);
taler_bank_get_history_cancel (NULL,
whh);
GNUNET_free (account.hostname);
GNUNET_free (account.bank_base_url);
return NULL;
}
GNUNET_free (account.hostname);
GNUNET_free (account.bank_base_url);
GNUNET_assert (NULL != whh);
return whh;
}