diff options
Diffstat (limited to 'src/exchangedb/exchangedb_fees.c')
| -rw-r--r-- | src/exchangedb/exchangedb_fees.c | 412 |
1 files changed, 0 insertions, 412 deletions
diff --git a/src/exchangedb/exchangedb_fees.c b/src/exchangedb/exchangedb_fees.c deleted file mode 100644 index 070f16eee..000000000 --- a/src/exchangedb/exchangedb_fees.c +++ /dev/null @@ -1,412 +0,0 @@ -/* - This file is part of TALER - Copyright (C) 2017 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 exchangedb/exchangedb_fees.c - * @brief Logic to read/write/convert aggregation wire fees (not other fees!) - * @author Christian Grothoff - */ -#include "platform.h" -#include "taler_exchangedb_lib.h" - - -GNUNET_NETWORK_STRUCT_BEGIN - -/** - * Structure for wire fees on disk. - */ -struct TALER_WireFeeDiskP -{ - - /** - * Wire fee details. - */ - struct TALER_MasterWireFeePS wf; - - - /** - * Signature affirming the above fee structure. - */ - struct TALER_MasterSignatureP master_sig; - -}; - -GNUNET_NETWORK_STRUCT_END - - -/** - * Convert @a wd disk format to host format. - * - * @param wd aggregate fees, disk format - * @return fees in host format - */ -static struct TALER_EXCHANGEDB_AggregateFees * -wd2af (const struct TALER_WireFeeDiskP *wd) -{ - struct TALER_EXCHANGEDB_AggregateFees *af; - - af = GNUNET_new (struct TALER_EXCHANGEDB_AggregateFees); - af->start_date = GNUNET_TIME_absolute_ntoh (wd->wf.start_date); - af->end_date = GNUNET_TIME_absolute_ntoh (wd->wf.end_date); - TALER_amount_ntoh (&af->wire_fee, - &wd->wf.wire_fee); - TALER_amount_ntoh (&af->closing_fee, - &wd->wf.closing_fee); - af->master_sig = wd->master_sig; - return af; -} - - -/** - * Read the current fee structure from disk. - * - * @param cfg configuration to use - * @param wireplugin name of the wire plugin to read fees for - * @return sorted list of aggregation fees, NULL on error - */ -struct TALER_EXCHANGEDB_AggregateFees * -TALER_EXCHANGEDB_fees_read (const struct GNUNET_CONFIGURATION_Handle *cfg, - const char *wireplugin) -{ - char *wirefee_base_dir; - char *fn; - struct GNUNET_DISK_FileHandle *fh; - struct TALER_WireFeeDiskP wd; - struct TALER_EXCHANGEDB_AggregateFees *af; - struct TALER_EXCHANGEDB_AggregateFees *endp; - - if (GNUNET_OK != - GNUNET_CONFIGURATION_get_value_filename (cfg, - "exchangedb", - "WIREFEE_BASE_DIR", - &wirefee_base_dir)) - { - GNUNET_log_config_missing (GNUNET_ERROR_TYPE_WARNING, - "exchangedb", - "WIREFEE_BASE_DIR"); - return NULL; - } - GNUNET_asprintf (&fn, - "%s/%s.fee", - wirefee_base_dir, - wireplugin); - GNUNET_free (wirefee_base_dir); - fh = GNUNET_DISK_file_open (fn, - GNUNET_DISK_OPEN_READ, - GNUNET_DISK_PERM_NONE); - if (NULL == fh) - { - GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_ERROR, - "open", - fn); - GNUNET_free (fn); - return NULL; - } - - af = NULL; - endp = NULL; - while (1) - { - struct TALER_EXCHANGEDB_AggregateFees *n; - ssize_t in = GNUNET_DISK_file_read (fh, - &wd, - sizeof (wd)); - if (-1 == in) - { - /* Unexpected I/O error */ - GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_ERROR, - "read", - fn); - GNUNET_break (GNUNET_OK == - GNUNET_DISK_file_close (fh)); - GNUNET_free (fn); - TALER_EXCHANGEDB_fees_free (af); - return NULL; - } - if (0 == in) - break; /* EOF, terminate normally */ - if (sizeof (wd) != in) - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "File `%s' has wrong size for fee structure\n", - fn); - GNUNET_break (GNUNET_OK == - GNUNET_DISK_file_close (fh)); - GNUNET_free (fn); - TALER_EXCHANGEDB_fees_free (af); - return NULL; - } - n = wd2af (&wd); - GNUNET_log (GNUNET_ERROR_TYPE_INFO, - "Loaded wire fees starting at %s from file\n", - GNUNET_STRINGS_absolute_time_to_string (n->start_date)); - if ( ( (NULL == af) || - (endp->end_date.abs_value_us == n->start_date.abs_value_us) ) && - (n->start_date.abs_value_us < n->end_date.abs_value_us) ) - { - /* append to list */ - if (NULL != endp) - endp->next = n; - else - af = n; - endp = n; - } - else - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "File `%s' does not have wire fees in chronological order\n", - fn); - GNUNET_DISK_file_close (fh); - GNUNET_free (n); - GNUNET_free (fn); - TALER_EXCHANGEDB_fees_free (af); - return NULL; - } - } - GNUNET_assert (GNUNET_OK == - GNUNET_DISK_file_close (fh)); - GNUNET_free (fn); - return af; -} - - -/** - * Convert @a af to @a wf. - * - * @param wiremethod name of the wire method the fees are for - * @param[in,out] af aggregate fees, host format (updated to round time) - * @param[out] wf aggregate fees, disk / signature format - */ -void -TALER_EXCHANGEDB_fees_2_wf (const char *wiremethod, - struct TALER_EXCHANGEDB_AggregateFees *af, - struct TALER_MasterWireFeePS *wf) -{ - (void) GNUNET_TIME_round_abs (&af->start_date); - (void) GNUNET_TIME_round_abs (&af->end_date); - wf->purpose.size = htonl (sizeof (*wf)); - wf->purpose.purpose = htonl (TALER_SIGNATURE_MASTER_WIRE_FEES); - GNUNET_CRYPTO_hash (wiremethod, - strlen (wiremethod) + 1, - &wf->h_wire_method); - wf->start_date = GNUNET_TIME_absolute_hton (af->start_date); - wf->end_date = GNUNET_TIME_absolute_hton (af->end_date); - TALER_amount_hton (&wf->wire_fee, - &af->wire_fee); - TALER_amount_hton (&wf->closing_fee, - &af->closing_fee); -} - - -/** - * Write given fee structure to disk. - * - * @param filename where to write the fees - * @param wireplugin which plugin the fees are about - * @param af fee structure to write - * @return #GNUNET_OK on success, #GNUNET_SYSERR on error - */ -int -TALER_EXCHANGEDB_fees_write (const char *filename, - const char *wireplugin, - struct TALER_EXCHANGEDB_AggregateFees *af) -{ - struct GNUNET_DISK_FileHandle *fh; - struct TALER_WireFeeDiskP wd; - struct TALER_EXCHANGEDB_AggregateFees *last; - - if (GNUNET_OK != - GNUNET_DISK_directory_create_for_file (filename)) - { - int eno; - - eno = errno; - GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_ERROR, - "mkdir (for file)", - filename); - errno = eno; - return GNUNET_SYSERR; - } - - fh = GNUNET_DISK_file_open (filename, - GNUNET_DISK_OPEN_WRITE - | GNUNET_DISK_OPEN_TRUNCATE - | GNUNET_DISK_OPEN_CREATE, - GNUNET_DISK_PERM_USER_READ - | GNUNET_DISK_PERM_USER_WRITE); - if (NULL == fh) - { - int eno; - - eno = errno; - GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_ERROR, - "open", - filename); - errno = eno; - return GNUNET_SYSERR; - } - - last = NULL; - while (NULL != af) - { - if ( ( (NULL != last) && - (last->end_date.abs_value_us != af->start_date.abs_value_us) ) || - (af->start_date.abs_value_us >= af->end_date.abs_value_us) ) - { - /* @a af malformed, refusing to write file that will be rejected */ - GNUNET_break (0); - GNUNET_assert (GNUNET_OK == - GNUNET_DISK_file_close (fh)); - /* try to remove the file, as it would be malformed */ - if (0 != unlink (filename)) - GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_ERROR, - "unlink", - filename); - errno = EINVAL; /* invalid inputs */ - return GNUNET_SYSERR; - } - TALER_EXCHANGEDB_fees_2_wf (wireplugin, - af, - &wd.wf); - wd.master_sig = af->master_sig; - last = af; - af = af->next; - if (sizeof (wd) != - GNUNET_DISK_file_write (fh, - &wd, - sizeof (wd))) - { - int eno = errno; - - GNUNET_break (GNUNET_OK == - GNUNET_DISK_file_close (fh)); - /* try to remove the file, as it must be malformed */ - if (0 != unlink (filename)) - GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_ERROR, - "unlink", - filename); - errno = eno; - return GNUNET_SYSERR; - } - } - GNUNET_assert (GNUNET_OK == - GNUNET_DISK_file_close (fh)); - return GNUNET_OK; -} - - -/** - * Free @a af data structure - * - * @param af list to free - */ -void -TALER_EXCHANGEDB_fees_free (struct TALER_EXCHANGEDB_AggregateFees *af) -{ - while (NULL != af) - { - struct TALER_EXCHANGEDB_AggregateFees *next; - - next = af->next; - GNUNET_free (af); - af = next; - } -} - - -/** - * Find the record valid at time @a now in the fee structure. - * - * @param wa wire transfer fee data structure to update - * @param now timestamp to update fees to - * @return fee valid at @a now, or NULL if unknown - */ -static struct TALER_EXCHANGEDB_AggregateFees * -advance_fees (struct TALER_EXCHANGEDB_WireAccount *wa, - struct GNUNET_TIME_Absolute now) -{ - struct TALER_EXCHANGEDB_AggregateFees *af; - - af = wa->af; - while ( (NULL != af) && - (af->end_date.abs_value_us < now.abs_value_us) ) - af = af->next; - return af; -} - - -/** - * Update wire transfer fee data structure in @a wa. - * - * @param cfg configuration to use - * @param db_plugin database plugin to use - * @param wa wire account data structure to update - * @param now timestamp to update fees to - * @param session DB session to use - * @return fee valid at @a now, or NULL if unknown - */ -struct TALER_EXCHANGEDB_AggregateFees * -TALER_EXCHANGEDB_update_fees (const struct GNUNET_CONFIGURATION_Handle *cfg, - struct TALER_EXCHANGEDB_Plugin *db_plugin, - struct TALER_EXCHANGEDB_WireAccount *wa, - struct GNUNET_TIME_Absolute now, - struct TALER_EXCHANGEDB_Session *session) -{ - enum GNUNET_DB_QueryStatus qs; - struct TALER_EXCHANGEDB_AggregateFees *af; - - af = advance_fees (wa, - now); - if (NULL != af) - return af; - /* Let's try to load it from disk... */ - wa->af = TALER_EXCHANGEDB_fees_read (cfg, - wa->method); - for (struct TALER_EXCHANGEDB_AggregateFees *p = wa->af; - NULL != p; - p = p->next) - { - GNUNET_log (GNUNET_ERROR_TYPE_INFO, - "Persisting fees starting at %s in database\n", - GNUNET_STRINGS_absolute_time_to_string (p->start_date)); - qs = db_plugin->insert_wire_fee (db_plugin->cls, - session, - wa->method, - p->start_date, - p->end_date, - &p->wire_fee, - &p->closing_fee, - &p->master_sig); - if (qs < 0) - { - GNUNET_break (GNUNET_DB_STATUS_SOFT_ERROR == qs); - TALER_EXCHANGEDB_fees_free (wa->af); - wa->af = NULL; - return NULL; - } - } - af = advance_fees (wa, - now); - if (NULL != af) - return af; - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "Failed to find current wire transfer fees for `%s' at %s\n", - wa->method, - GNUNET_STRINGS_absolute_time_to_string (now)); - return NULL; -} - - -/* end of exchangedb_fees.c */ |