/* 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 */ #include "platform.h" #include #include #include #include #include #include "taler_json_lib.h" #include "taler_mhd_lib.h" #include "taler-auditor-httpd.h" #include "taler-auditor-httpd_wire-out-inconsistency-get.h" /** * Add wire-out-inconsistency to the list. * * @param[in,out] cls a `json_t *` array to extend * @param dc struct of inconsistencies * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating */ static enum GNUNET_GenericReturnValue process_wire_out_inconsistency ( void *cls, const struct TALER_AUDITORDB_WireOutInconsistency *dc) { json_t *list = cls; json_t *obj; obj = GNUNET_JSON_PACK ( GNUNET_JSON_pack_int64 ("row_id", dc->row_id), GNUNET_JSON_pack_string ("destination_account", dc->destination_account), GNUNET_JSON_pack_int64 ("wire_out_row_id", dc->wire_out_row_id), GNUNET_JSON_pack_string ("diagnostic", dc->diagnostic), TALER_JSON_pack_amount ("expected", &dc->expected), TALER_JSON_pack_amount ("claimed", &dc->claimed), GNUNET_JSON_pack_bool ("suppressed", dc->suppressed) ); GNUNET_break (0 == json_array_append_new (list, obj)); return GNUNET_OK; } MHD_RESULT TAH_WIRE_OUT_INCONSISTENCY_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; int64_t limit = -20; uint64_t offset; enum TALER_EXCHANGE_YesNoAll return_suppressed; (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); } 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); TALER_MHD_parse_request_yna (connection, "return_suppressed", false, &return_suppressed); ja = json_array (); GNUNET_break (NULL != ja); qs = TAH_plugin->get_wire_out_inconsistency ( TAH_plugin->cls, limit, offset, (TALER_EXCHANGE_YNA_NO != return_suppressed), &process_wire_out_inconsistency, ja); if (0 > qs) { GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); json_decref (ja); TALER_LOG_WARNING ( "Failed to handle GET /wire-out-inconsistency"); return TALER_MHD_reply_with_error (connection, MHD_HTTP_INTERNAL_SERVER_ERROR, TALER_EC_GENERIC_DB_FETCH_FAILED, "wire-out-inconsistency"); } return TALER_MHD_REPLY_JSON_PACK ( connection, MHD_HTTP_OK, GNUNET_JSON_pack_array_steal ("wire_out_inconsistency", ja)); }