/* This file is part of TALER Copyright (C) 2014-2021 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 */ /** * @file exchange-tools/taler-exchange-dbinit.c * @brief Create tables for the exchange database. * @author Florian Dold * @author Christian Grothoff */ #include "platform.h" #include #include "taler_exchangedb_lib.h" /** * Return value from main(). */ static int global_ret; /** * -r option: do full DB reset */ static int reset_db; /** * -s option: clear revolving shard locks */ static int clear_shards; /** * -g option: garbage collect DB reset */ static int gc_db; /** * 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) { struct TALER_EXCHANGEDB_Plugin *plugin; (void) cls; (void) args; (void) cfgfile; if (NULL == (plugin = TALER_EXCHANGEDB_plugin_load (cfg))) { fprintf (stderr, "Failed to initialize database plugin.\n"); global_ret = EXIT_NOTINSTALLED; return; } if (reset_db) { if (GNUNET_OK != plugin->drop_tables (plugin->cls)) { GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Could not drop tables as requested. Either database was not yet initialized, or permission denied. Consult the logs. Will still try to create new tables.\n"); } } if (GNUNET_OK != plugin->create_tables (plugin->cls)) { fprintf (stderr, "Failed to initialize database.\n"); TALER_EXCHANGEDB_plugin_unload (plugin); global_ret = EXIT_NOPERMISSION; return; } if (clear_shards) { if (0 < plugin->delete_revolving_shards (plugin->cls)) { fprintf (stderr, "Clearing revolving shards failed!\n"); } } if (gc_db) { if (GNUNET_SYSERR == plugin->gc (plugin->cls)) { fprintf (stderr, "Garbage collection failed!\n"); } } TALER_EXCHANGEDB_plugin_unload (plugin); } /** * The main function of the database initialization tool. * Used to initialize the Taler Exchange's database. * * @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[] = { GNUNET_GETOPT_option_flag ('g', "gc", "garbage collect database", &gc_db), GNUNET_GETOPT_option_flag ('r', "reset", "reset database (DANGEROUS: all existing data is lost!)", &reset_db), GNUNET_GETOPT_option_flag ('s', "shardunlock", "unlock all revolving shard locks (use after system crash or shard size change while services are not running)", &clear_shards), GNUNET_GETOPT_OPTION_END }; enum GNUNET_GenericReturnValue ret; if (GNUNET_OK != GNUNET_STRINGS_get_utf8_args (argc, argv, &argc, &argv)) return EXIT_INVALIDARGUMENT; /* force linker to link against libtalerutil; if we do not do this, the linker may "optimize" libtalerutil away and skip #TALER_OS_init(), which we do need */ TALER_OS_init (); ret = GNUNET_PROGRAM_run ( argc, argv, "taler-exchange-dbinit", gettext_noop ("Initialize Taler exchange database"), options, &run, NULL); GNUNET_free_nz ((void *) argv); if (GNUNET_SYSERR == ret) return EXIT_INVALIDARGUMENT; if (GNUNET_NO == ret) return EXIT_SUCCESS; return global_ret; } /* end of taler-exchange-dbinit.c */