diff options
author | Christian Grothoff <christian@grothoff.org> | 2023-04-12 13:17:48 +0200 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2023-04-12 13:17:48 +0200 |
commit | 69684b2fe1b0e7c857d23e6a7ffcaff41a931435 (patch) | |
tree | 29169cbfe0d758ed8384c1fd5d728dcc6f1c094d /src | |
parent | 5ed3b2cfe1aa0cb31c589b308cc70684a20dd368 (diff) | |
download | merchant-69684b2fe1b0e7c857d23e6a7ffcaff41a931435.tar.gz merchant-69684b2fe1b0e7c857d23e6a7ffcaff41a931435.tar.bz2 merchant-69684b2fe1b0e7c857d23e6a7ffcaff41a931435.zip |
wirewatch skeleton
Diffstat (limited to 'src')
-rw-r--r-- | src/backend/Makefile.am | 21 | ||||
-rw-r--r-- | src/backend/taler-merchant-wirewatch.c | 208 |
2 files changed, 228 insertions, 1 deletions
diff --git a/src/backend/Makefile.am b/src/backend/Makefile.am index c6b99bfc..21ff7907 100644 --- a/src/backend/Makefile.am +++ b/src/backend/Makefile.am @@ -17,7 +17,8 @@ EXTRA_DIST = \ bin_PROGRAMS = \ taler-merchant-httpd \ - taler-merchant-webhook + taler-merchant-webhook \ + taler-merchant-wirewatch taler_merchant_httpd_SOURCES = \ taler-merchant-httpd.c taler-merchant-httpd.h \ @@ -171,3 +172,21 @@ taler_merchant_webhook_LDADD = \ $(XLIB) taler_merchant_webhook_CFLAGS = \ $(AM_CFLAGS) + + +taler_merchant_wirewatch_SOURCES = \ + taler-merchant-wirewatch.c +taler_merchant_wirewatch_LDADD = \ + $(top_builddir)/src/backenddb/libtalermerchantdb.la \ + -ltalermhd \ + -ltalerjson \ + -ltalerutil \ + -ltalerpq \ + -ljansson \ + -lgnunetcurl \ + -lgnunetjson \ + -lgnunetutil \ + -lcurl \ + $(XLIB) +taler_merchant_wirewatch_CFLAGS = \ + $(AM_CFLAGS) diff --git a/src/backend/taler-merchant-wirewatch.c b/src/backend/taler-merchant-wirewatch.c new file mode 100644 index 00000000..a771c736 --- /dev/null +++ b/src/backend/taler-merchant-wirewatch.c @@ -0,0 +1,208 @@ +/* + This file is part of TALER + Copyright (C) 2023 Taler Systems SA + + TALER is free software; you can redistribute it and/or modify it under the + terms of the GNU Affero 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 Affero General Public License for more details. + + You should have received a copy of the GNU Affero General Public License along with + TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/> +*/ +/** + * @file taler-merchant-wirewatch.c + * @brief Process that imports information about incoming bank transfers into the merchant backend + * @author Christian Grothoff + */ +#include "platform.h" +#include <gnunet/gnunet_util_lib.h> +#include <jansson.h> +#include <pthread.h> +#include "taler_merchantdb_lib.h" +#include "taler_merchantdb_plugin.h" + + +/** + * The merchant's configuration. + */ +static const struct GNUNET_CONFIGURATION_Handle *cfg; + +/** + * Our database plugin. + */ +static struct TALER_MERCHANTDB_Plugin *db_plugin; + +/** + * Next task to run, if any. + */ +static struct GNUNET_SCHEDULER_Task *task; + +/** + * Handle to the context for interacting with the bank. + */ +static struct GNUNET_CURL_Context *ctx; + +/** + * Scheduler context for running the @e ctx. + */ +static struct GNUNET_CURL_RescheduleContext *rc; + +/** + * Value to return from main(). 0 on success, non-zero on errors. + */ +static int global_ret; + +/** + * #GNUNET_YES if we are in test mode and should exit when idle. + */ +static int test_mode; + + +/** + * We're being aborted with CTRL-C (or SIGTERM). Shut down. + * + * @param cls closure + */ +static void +shutdown_task (void *cls) +{ + (void) cls; + GNUNET_log (GNUNET_ERROR_TYPE_INFO, + "Running shutdown\n"); + if (NULL != task) + { + GNUNET_SCHEDULER_cancel (task); + task = NULL; + } + db_plugin->rollback (db_plugin->cls); /* just in case */ + TALER_MERCHANTDB_plugin_unload (db_plugin); + db_plugin = NULL; + cfg = NULL; + if (NULL != ctx) + { + GNUNET_CURL_fini (ctx); + ctx = NULL; + } + if (NULL != rc) + { + GNUNET_CURL_gnunet_rc_destroy (rc); + rc = NULL; + } +} + + +/** + * Run next iteration. + * + * @param cls NULL + */ +static void +do_work (void *cls); + + +static void +do_work (void *cls) +{ + (void) cls; + task = NULL; +} + + +/** + * First task. + * + * @param cls closure, NULL + * @param args remaining command-line arguments + * @param cfgfile name of the configuration file used (for saving, can be NULL!) + * @param c configuration + */ +static void +run (void *cls, + char *const *args, + const char *cfgfile, + const struct GNUNET_CONFIGURATION_Handle *c) +{ + (void) args; + (void) cfgfile; + + cfg = c; + GNUNET_SCHEDULER_add_shutdown (&shutdown_task, + NULL); + ctx = GNUNET_CURL_init (&GNUNET_CURL_gnunet_scheduler_reschedule, + &rc); + rc = GNUNET_CURL_gnunet_rc_create (ctx); + if (NULL == ctx) + { + GNUNET_break (0); + GNUNET_SCHEDULER_shutdown (); + return; + } + if (NULL == + (db_plugin = TALER_MERCHANTDB_plugin_load (cfg))) + { + GNUNET_log (GNUNET_ERROR_TYPE_ERROR, + "Failed to initialize DB subsystem\n"); + GNUNET_SCHEDULER_shutdown (); + return; + } + if (GNUNET_OK != + db_plugin->connect (db_plugin->cls)) + { + GNUNET_log (GNUNET_ERROR_TYPE_ERROR, + "Failed to connect to database\n"); + GNUNET_SCHEDULER_shutdown (); + return; + } + GNUNET_assert (NULL == task); + task = GNUNET_SCHEDULER_add_now (&do_work, + NULL); +} + + +/** + * The main function of taler-merchant-wirewatch + * + * @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) +{ + struct GNUNET_GETOPT_CommandLineOption options[] = { + GNUNET_GETOPT_option_flag ('t', + "test", + "run in test mode and exit when idle", + &test_mode), + GNUNET_GETOPT_option_version (VERSION "-" VCS_VERSION), + GNUNET_GETOPT_OPTION_END + }; + enum GNUNET_GenericReturnValue ret; + + if (GNUNET_OK != + GNUNET_STRINGS_get_utf8_args (argc, argv, + &argc, &argv)) + return EXIT_INVALIDARGUMENT; + TALER_OS_init (); + ret = GNUNET_PROGRAM_run ( + argc, argv, + "taler-merchant-wirewatch", + gettext_noop ( + "background process that watches for incoming wire transfers to the merchant bank account"), + 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-wirewatch.c */ |