/* This file is part of TALER Copyright (C) 2024 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/> */ #include "platform.h" #include <gnunet/gnunet_util_lib.h> #include <gnunet/gnunet_json_lib.h> #include <jansson.h> #include <microhttpd.h> #include <pthread.h> #include "taler_json_lib.h" #include "taler_mhd_lib.h" #include "taler-auditor-httpd.h" #include "taler-auditor-httpd_purse-not-closed-inconsistencies-get.h" /** * Add purse-not-closed-inconsistencies to the list. * * @param[in,out] cls a `json_t *` array to extend * @param serial_id location of the @a dc in the database * @param dc struct of inconsistencies * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating */ static enum GNUNET_GenericReturnValue process_purse_not_closed_inconsistencies (void *cls, uint64_t serial_id, const struct TALER_AUDITORDB_PurseNotClosedInconsistencies *dc) { json_t *list = cls; json_t *obj; obj = GNUNET_JSON_PACK ( GNUNET_JSON_pack_data_auto ("purse_pub", &dc->purse_pub), TALER_JSON_pack_amount ("amount", &dc->amount), TALER_JSON_pack_time_abs_human ("expiration_date", dc->expiration_date) ); GNUNET_break (0 == json_array_append_new (list, obj)); return GNUNET_OK; } /** * * @param rh context of the handler * @param connection the MHD connection to handle * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data * @return MHD result code */ MHD_RESULT TAH_PURSE_NOT_CLOSED_INCONSISTENCIES_handler_get (struct TAH_RequestHandler *rh, struct MHD_Connection * connection, void **connection_cls, const char *upload_data, size_t *upload_data_size, const char *const args[]) { json_t *ja; enum GNUNET_DB_QueryStatus qs; (void) rh; (void) connection_cls; (void) upload_data; (void) upload_data_size; if (GNUNET_SYSERR == TAH_plugin->preflight (TAH_plugin->cls)) { GNUNET_break (0); return TALER_MHD_reply_with_error (connection, MHD_HTTP_INTERNAL_SERVER_ERROR, TALER_EC_GENERIC_DB_SETUP_FAILED, NULL); } ja = json_array (); GNUNET_break (NULL != ja); int64_t limit = -20; uint64_t offset; TALER_MHD_parse_request_snumber (connection, "limit", &limit); if (limit < 0) offset = INT64_MAX; else offset = 0; TALER_MHD_parse_request_number (connection, "offset", &offset); bool return_suppressed = false; qs = TAH_plugin->get_purse_not_closed_inconsistencies ( TAH_plugin->cls, limit, offset, return_suppressed, &process_purse_not_closed_inconsistencies, ja); if (0 > qs) { GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); json_decref (ja); TALER_LOG_WARNING ( "Failed to handle GET /purse-not-closed-inconsistencies\n"); return TALER_MHD_reply_with_error (connection, MHD_HTTP_INTERNAL_SERVER_ERROR, TALER_EC_GENERIC_DB_FETCH_FAILED, "purse-not-closed-inconsistencies"); } return TALER_MHD_REPLY_JSON_PACK ( connection, MHD_HTTP_OK, GNUNET_JSON_pack_array_steal ("purse-not-closed-inconsistencies", ja)); }