/* 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 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 testing/testing_api_cmd_tme.c * @brief run the taler-merchant-reconciliation command * @author Christian Grothoff */ #include "platform.h" #include "taler/taler_json_lib.h" #include #include "taler/taler_signatures.h" #include "taler/taler_testing_lib.h" #include "taler_merchant_testing_lib.h" /** * State for a "taler-merchant-reconciliation" CMD. */ struct MerchantExchangeState { /** * Process for taler-merchant-reconciliation */ struct GNUNET_OS_Process *merchant_reconciliation_proc; /** * Configuration file used by the program. */ const char *config_filename; }; /** * Run the command; use the `taler-merchant-reconciliation' program. * * @param cls closure. * @param cmd command currently being executed. * @param is interpreter state. */ static void tme_run (void *cls, const struct TALER_TESTING_Command *cmd, struct TALER_TESTING_Interpreter *is) { struct MerchantExchangeState *ws = cls; (void) cmd; ws->merchant_reconciliation_proc = GNUNET_OS_start_process (GNUNET_OS_INHERIT_STD_ALL, NULL, NULL, NULL, "taler-merchant-reconciliation", "taler-merchant-reconciliation", "-c", ws->config_filename, "-t", /* exit when done */ "-L", "DEBUG", NULL); if (NULL == ws->merchant_reconciliation_proc) { GNUNET_break (0); TALER_TESTING_interpreter_fail (is); return; } TALER_TESTING_wait_for_sigchld (is); } /** * Free the state of a "exchange" CMD, and possibly * kills its process if it did not terminate regularly. * * @param cls closure. * @param cmd the command being freed. */ static void tme_cleanup (void *cls, const struct TALER_TESTING_Command *cmd) { struct MerchantExchangeState *ws = cls; (void) cmd; if (NULL != ws->merchant_reconciliation_proc) { GNUNET_break (0 == GNUNET_OS_process_kill (ws->merchant_reconciliation_proc, SIGKILL)); GNUNET_OS_process_wait (ws->merchant_reconciliation_proc); GNUNET_OS_process_destroy (ws->merchant_reconciliation_proc); ws->merchant_reconciliation_proc = NULL; } GNUNET_free (ws); } /** * Offer "tme" CMD internal data to other commands. * * @param cls closure. * @param[out] ret result. * @param trait name of the trait. * @param index index number of the object to offer. * @return #GNUNET_OK on success. */ static enum GNUNET_GenericReturnValue tme_traits (void *cls, const void **ret, const char *trait, unsigned int index) { struct MerchantExchangeState *ws = cls; struct TALER_TESTING_Trait traits[] = { TALER_TESTING_make_trait_process (&ws->merchant_reconciliation_proc), TALER_TESTING_trait_end () }; return TALER_TESTING_get_trait (traits, ret, trait, index); } struct TALER_TESTING_Command TALER_TESTING_cmd_run_tme (const char *label, const char *config_filename) { struct MerchantExchangeState *ws; ws = GNUNET_new (struct MerchantExchangeState); ws->config_filename = config_filename; { struct TALER_TESTING_Command cmd = { .cls = ws, .label = label, .run = &tme_run, .cleanup = &tme_cleanup, .traits = &tme_traits }; return cmd; } } /* end of testing_api_cmd_tme.c */