Line data Source code
1 : /*
2 : This file is part of TALER
3 : Copyright (C) 2022 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 : /**
17 : * @file exchangedb/pg_do_refund.c
18 : * @brief Implementation of the do_refund function for Postgres
19 : * @author Christian Grothoff
20 : */
21 : #include "platform.h"
22 : #include "taler_error_codes.h"
23 : #include "taler_dbevents.h"
24 : #include "taler_pq_lib.h"
25 : #include "pg_do_refund.h"
26 : #include "pg_helper.h"
27 : #include "pg_compute_shard.h"
28 :
29 :
30 : enum GNUNET_DB_QueryStatus
31 16 : TEH_PG_do_refund (
32 : void *cls,
33 : const struct TALER_EXCHANGEDB_Refund *refund,
34 : const struct TALER_Amount *deposit_fee,
35 : uint64_t known_coin_id,
36 : bool *not_found,
37 : bool *refund_ok,
38 : bool *gone,
39 : bool *conflict)
40 : {
41 16 : struct PostgresClosure *pg = cls;
42 16 : uint64_t deposit_shard = TEH_PG_compute_shard (&refund->details.merchant_pub);
43 : struct TALER_Amount amount_without_fee;
44 16 : struct GNUNET_PQ_QueryParam params[] = {
45 16 : TALER_PQ_query_param_amount (pg->conn,
46 : &refund->details.refund_amount),
47 16 : TALER_PQ_query_param_amount (pg->conn,
48 : &amount_without_fee),
49 16 : TALER_PQ_query_param_amount (pg->conn,
50 : deposit_fee),
51 16 : GNUNET_PQ_query_param_auto_from_type (&refund->details.h_contract_terms),
52 16 : GNUNET_PQ_query_param_uint64 (&refund->details.rtransaction_id),
53 16 : GNUNET_PQ_query_param_uint64 (&deposit_shard),
54 16 : GNUNET_PQ_query_param_uint64 (&known_coin_id),
55 16 : GNUNET_PQ_query_param_auto_from_type (&refund->coin.coin_pub),
56 16 : GNUNET_PQ_query_param_auto_from_type (&refund->details.merchant_pub),
57 16 : GNUNET_PQ_query_param_auto_from_type (&refund->details.merchant_sig),
58 : GNUNET_PQ_query_param_end
59 : };
60 16 : struct GNUNET_PQ_ResultSpec rs[] = {
61 16 : GNUNET_PQ_result_spec_bool ("not_found",
62 : not_found),
63 16 : GNUNET_PQ_result_spec_bool ("refund_ok",
64 : refund_ok),
65 16 : GNUNET_PQ_result_spec_bool ("gone",
66 : gone),
67 16 : GNUNET_PQ_result_spec_bool ("conflict",
68 : conflict),
69 : GNUNET_PQ_result_spec_end
70 : };
71 :
72 16 : if (0 >
73 16 : TALER_amount_subtract (&amount_without_fee,
74 : &refund->details.refund_amount,
75 : &refund->details.refund_fee))
76 : {
77 0 : GNUNET_break (0);
78 0 : return GNUNET_DB_STATUS_HARD_ERROR;
79 : }
80 16 : PREPARE (pg,
81 : "call_refund",
82 : "SELECT "
83 : " out_not_found AS not_found"
84 : ",out_refund_ok AS refund_ok"
85 : ",out_gone AS gone"
86 : ",out_conflict AS conflict"
87 : " FROM exchange_do_refund"
88 : " ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10);");
89 16 : return GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
90 : "call_refund",
91 : params,
92 : rs);
93 : }
|