taler-merchant-httpd_get-private-incoming.c (7875B)
1 /* 2 This file is part of TALER 3 (C) 2025 Taler Systems SA 4 5 TALER is free software; you can redistribute it and/or modify it under the 6 terms of the GNU Affero 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 /** 17 * @file src/backend/taler-merchant-httpd_get-private-incoming.c 18 * @brief implement API for obtaining a list of expected incoming wire transfers 19 * @author Christian Grothoff 20 */ 21 #include "platform.h" 22 #include <jansson.h> 23 #include <taler/taler_json_lib.h> 24 #include "taler-merchant-httpd_get-private-incoming.h" 25 #include "merchant-database/lookup_expected_transfers.h" 26 #include "merchant-database/preflight.h" 27 28 29 /** 30 * Function called with information about a wire transfer. 31 * Generate a response (array entry) based on the given arguments. 32 * 33 * @param cls closure with a `json_t *` array to build up the response 34 * @param expected_credit_amount amount expected to be wired to the merchant (minus fees), NULL if unknown 35 * @param wtid wire transfer identifier 36 * @param payto_uri target account that received the wire transfer 37 * @param exchange_url base URL of the exchange that made the wire transfer 38 * @param expected_transfer_serial_id serial number identifying the transfer in the backend 39 * @param execution_time when did the exchange make the transfer, #GNUNET_TIME_UNIT_FOREVER_ABS 40 * if it did not yet happen 41 * @param confirmed true if the merchant acknowledged the wire transfer reception 42 * @param validated true if the reconciliation succeeded 43 * @param last_http_status HTTP status of our last request to the exchange for this transfer 44 * @param last_ec last error code we got back (otherwise #TALER_EC_NONE) 45 * @param last_error_detail last detail we got back (or NULL for none) 46 */ 47 static void 48 incoming_cb (void *cls, 49 const struct TALER_Amount *expected_credit_amount, 50 const struct TALER_WireTransferIdentifierRawP *wtid, 51 struct TALER_FullPayto payto_uri, 52 const char *exchange_url, 53 uint64_t expected_transfer_serial_id, 54 struct GNUNET_TIME_Timestamp execution_time, 55 bool confirmed, 56 bool validated, 57 unsigned int last_http_status, 58 enum TALER_ErrorCode last_ec, 59 const char *last_error_detail) 60 { 61 json_t *ja = cls; 62 json_t *r; 63 64 r = GNUNET_JSON_PACK ( 65 GNUNET_JSON_pack_allow_null ( 66 TALER_JSON_pack_amount ("expected_credit_amount", 67 expected_credit_amount)), 68 GNUNET_JSON_pack_data_auto ("wtid", 69 wtid), 70 TALER_JSON_pack_full_payto ("payto_uri", 71 payto_uri), 72 GNUNET_JSON_pack_string ("exchange_url", 73 exchange_url), 74 GNUNET_JSON_pack_uint64 ("expected_transfer_serial_id", 75 expected_transfer_serial_id), 76 GNUNET_JSON_pack_allow_null ( 77 GNUNET_JSON_pack_timestamp ("execution_time", 78 execution_time)), 79 GNUNET_JSON_pack_bool ("validated", 80 validated), 81 GNUNET_JSON_pack_bool ("confirmed", 82 confirmed), 83 GNUNET_JSON_pack_uint64 ("last_http_status", 84 last_http_status), 85 GNUNET_JSON_pack_uint64 ("last_ec", 86 last_ec), 87 GNUNET_JSON_pack_allow_null ( 88 GNUNET_JSON_pack_string ("last_error_detail", 89 last_error_detail))); 90 GNUNET_assert (0 == 91 json_array_append_new (ja, 92 r)); 93 } 94 95 96 /** 97 * Manages a GET /private/incoming call. 98 * 99 * @param rh context of the handler 100 * @param connection the MHD connection to handle 101 * @param[in,out] hc context with further information about the request 102 * @return MHD result code 103 */ 104 enum MHD_Result 105 TMH_private_get_incoming (const struct TMH_RequestHandler *rh, 106 struct MHD_Connection *connection, 107 struct TMH_HandlerContext *hc) 108 { 109 struct TALER_FullPayto payto_uri = { 110 .full_payto = NULL 111 }; 112 struct GNUNET_TIME_Timestamp before = GNUNET_TIME_UNIT_FOREVER_TS; 113 struct GNUNET_TIME_Timestamp after = GNUNET_TIME_UNIT_ZERO_TS; 114 int64_t limit = -20; 115 uint64_t offset; 116 enum TALER_EXCHANGE_YesNoAll confirmed; 117 enum TALER_EXCHANGE_YesNoAll verified; 118 119 (void) rh; 120 TALER_MHD_parse_request_snumber (connection, 121 "limit", 122 &limit); 123 if (limit < 0) 124 offset = INT64_MAX; 125 else 126 offset = 0; 127 TALER_MHD_parse_request_number (connection, 128 "offset", 129 &offset); 130 TALER_MHD_parse_request_yna (connection, 131 "verified", 132 TALER_EXCHANGE_YNA_ALL, 133 &verified); 134 TALER_MHD_parse_request_yna (connection, 135 "confirmed", 136 TALER_EXCHANGE_YNA_ALL, 137 &confirmed); 138 TALER_MHD_parse_request_timestamp (connection, 139 "before", 140 &before); 141 TALER_MHD_parse_request_timestamp (connection, 142 "after", 143 &after); 144 { 145 const char *esc_payto; 146 147 esc_payto = MHD_lookup_connection_value (connection, 148 MHD_GET_ARGUMENT_KIND, 149 "payto_uri"); 150 if (NULL != esc_payto) 151 { 152 payto_uri.full_payto 153 = GNUNET_strdup (esc_payto); 154 (void) MHD_http_unescape (payto_uri.full_payto); 155 } 156 } 157 TALER_MERCHANTDB_preflight (TMH_db); 158 { 159 json_t *ja; 160 enum GNUNET_DB_QueryStatus qs; 161 162 ja = json_array (); 163 GNUNET_assert (NULL != ja); 164 qs = TALER_MERCHANTDB_lookup_expected_transfers (TMH_db, 165 hc->instance->settings.id, 166 payto_uri, 167 before, 168 after, 169 limit, 170 offset, 171 confirmed, 172 verified, 173 &incoming_cb, 174 ja); 175 GNUNET_free (payto_uri.full_payto); 176 if (0 > qs) 177 { 178 /* Simple select queries should not cause serialization issues */ 179 GNUNET_break (GNUNET_DB_STATUS_SOFT_ERROR != qs); 180 /* Always report on hard error as well to enable diagnostics */ 181 GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); 182 return TALER_MHD_reply_with_error (connection, 183 MHD_HTTP_INTERNAL_SERVER_ERROR, 184 TALER_EC_GENERIC_DB_FETCH_FAILED, 185 "lookup_expected_transfers"); 186 } 187 return TALER_MHD_REPLY_JSON_PACK ( 188 connection, 189 MHD_HTTP_OK, 190 GNUNET_JSON_pack_array_steal ("incoming", 191 ja)); 192 } 193 } 194 195 196 /* end of taler-merchant-httpd_get-private-incoming.c */