Line data Source code
1 : /*
2 : This file is part of TALER
3 : Copyright (C) 2024 Taler Systems SA
4 :
5 : TALER is free software; you can redistribute it and/or modify it under the
6 : terms of the GNU General Public License as published by the Free Software
7 : Foundation; either version 3, or (at your option) any later version.
8 :
9 : TALER is distributed in the hope that it will be useful, but WITHOUT ANY
10 : WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
11 : A PARTICULAR PURPOSE. See the GNU General Public License for more details.
12 :
13 : You should have received a copy of the GNU General Public License along with
14 : TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/>
15 : */
16 : #include "platform.h"
17 : #include <gnunet/gnunet_util_lib.h>
18 : #include <gnunet/gnunet_json_lib.h>
19 : #include <jansson.h>
20 : #include <microhttpd.h>
21 : #include <pthread.h>
22 : #include "taler_json_lib.h"
23 : #include "taler_mhd_lib.h"
24 : #include "taler-auditor-httpd.h"
25 : #include "taler-auditor-httpd_amount-arithmetic-inconsistency-get.h"
26 :
27 :
28 : /**
29 : * Add deposit confirmation to the list.
30 : *
31 : * @param[in,out] cls a `json_t *` array to extend
32 : * @param dc struct of inconsistencies
33 : * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
34 : */
35 : static enum GNUNET_GenericReturnValue
36 5 : add_amount_arithmetic_inconsistency (
37 : void *cls,
38 : const struct TALER_AUDITORDB_AmountArithmeticInconsistency *dc)
39 : {
40 5 : json_t *list = cls;
41 : json_t *obj;
42 :
43 5 : obj = GNUNET_JSON_PACK (
44 : GNUNET_JSON_pack_uint64 ("row_id",
45 : dc->row_id),
46 : GNUNET_JSON_pack_uint64 ("problem_row_id",
47 : dc->problem_row_id),
48 : GNUNET_JSON_pack_string ("operation",
49 : dc->operation),
50 : TALER_JSON_pack_amount ("exchange_amount",
51 : &dc->exchange_amount),
52 : TALER_JSON_pack_amount ("auditor_amount",
53 : &dc->auditor_amount),
54 : GNUNET_JSON_pack_bool ("profitable",
55 : dc->profitable),
56 : GNUNET_JSON_pack_bool ("suppressed",
57 : dc->suppressed)
58 : );
59 5 : GNUNET_break (0 ==
60 : json_array_append_new (list,
61 : obj));
62 5 : return GNUNET_OK;
63 : }
64 :
65 :
66 : MHD_RESULT
67 3 : TAH_AMOUNT_ARITHMETIC_INCONSISTENCY_handler_get (
68 : struct TAH_RequestHandler *rh,
69 : struct MHD_Connection *connection,
70 : void **connection_cls,
71 : const char *upload_data,
72 : size_t *upload_data_size,
73 : const char *const args[])
74 : {
75 : json_t *ja;
76 : enum GNUNET_DB_QueryStatus qs;
77 3 : int64_t limit = -20;
78 : uint64_t offset;
79 3 : bool return_suppressed = false;
80 :
81 : (void) rh;
82 : (void) connection_cls;
83 : (void) upload_data;
84 : (void) upload_data_size;
85 3 : if (GNUNET_SYSERR ==
86 3 : TAH_plugin->preflight (TAH_plugin->cls))
87 : {
88 0 : GNUNET_break (0);
89 0 : return TALER_MHD_reply_with_error (connection,
90 : MHD_HTTP_INTERNAL_SERVER_ERROR,
91 : TALER_EC_GENERIC_DB_SETUP_FAILED,
92 : NULL);
93 : }
94 3 : ja = json_array ();
95 3 : GNUNET_break (NULL != ja);
96 3 : TALER_MHD_parse_request_snumber (connection,
97 : "limit",
98 : &limit);
99 3 : if (limit < 0)
100 0 : offset = INT64_MAX;
101 : else
102 3 : offset = 0;
103 3 : TALER_MHD_parse_request_number (connection,
104 : "offset",
105 : &offset);
106 : {
107 : const char *ret_s;
108 :
109 3 : ret_s = MHD_lookup_connection_value (connection,
110 : MHD_GET_ARGUMENT_KIND,
111 : "return_suppressed");
112 3 : if ( (ret_s != NULL) &&
113 0 : (0 == strcmp (ret_s,
114 : "true")) )
115 : {
116 0 : return_suppressed = true;
117 : }
118 : }
119 :
120 3 : qs = TAH_plugin->get_amount_arithmetic_inconsistency (
121 3 : TAH_plugin->cls,
122 : limit,
123 : offset,
124 : return_suppressed,
125 : &add_amount_arithmetic_inconsistency,
126 : ja);
127 3 : if (0 > qs)
128 : {
129 0 : GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs);
130 0 : json_decref (ja);
131 0 : TALER_LOG_WARNING (
132 : "Failed to handle GET /amount-arithmetic-inconsistency in database\n");
133 0 : return TALER_MHD_reply_with_error (
134 : connection,
135 : MHD_HTTP_INTERNAL_SERVER_ERROR,
136 : TALER_EC_GENERIC_DB_FETCH_FAILED,
137 : "amount-arithmetic-inconsistency");
138 : }
139 3 : return TALER_MHD_REPLY_JSON_PACK (
140 : connection,
141 : MHD_HTTP_OK,
142 : GNUNET_JSON_pack_array_steal ("amount_arithmetic_inconsistency",
143 : ja));
144 : }
|