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_purse_deposit.c
18 : * @brief Implementation of the do_purse_deposit 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_purse_deposit.h"
26 : #include "pg_helper.h"
27 :
28 :
29 : enum GNUNET_DB_QueryStatus
30 18 : TEH_PG_do_purse_deposit (
31 : void *cls,
32 : const struct TALER_PurseContractPublicKeyP *purse_pub,
33 : const struct TALER_CoinSpendPublicKeyP *coin_pub,
34 : const struct TALER_Amount *amount,
35 : const struct TALER_CoinSpendSignatureP *coin_sig,
36 : const struct TALER_Amount *amount_minus_fee,
37 : bool *balance_ok,
38 : bool *too_late,
39 : bool *conflict)
40 : {
41 18 : struct PostgresClosure *pg = cls;
42 18 : struct GNUNET_TIME_Timestamp now = GNUNET_TIME_timestamp_get ();
43 : struct GNUNET_TIME_Timestamp reserve_expiration;
44 18 : uint64_t partner_id = 0; /* FIXME #7271: WAD support... */
45 18 : struct GNUNET_PQ_QueryParam params[] = {
46 18 : (0 == partner_id)
47 18 : ? GNUNET_PQ_query_param_null ()
48 18 : : GNUNET_PQ_query_param_uint64 (&partner_id),
49 18 : GNUNET_PQ_query_param_auto_from_type (purse_pub),
50 18 : TALER_PQ_query_param_amount (
51 18 : pg->conn,
52 : amount),
53 18 : GNUNET_PQ_query_param_auto_from_type (coin_pub),
54 18 : GNUNET_PQ_query_param_auto_from_type (coin_sig),
55 18 : TALER_PQ_query_param_amount (
56 18 : pg->conn,
57 : amount_minus_fee),
58 18 : GNUNET_PQ_query_param_timestamp (&reserve_expiration),
59 18 : GNUNET_PQ_query_param_timestamp (&now),
60 : GNUNET_PQ_query_param_end
61 : };
62 18 : struct GNUNET_PQ_ResultSpec rs[] = {
63 18 : GNUNET_PQ_result_spec_bool ("balance_ok",
64 : balance_ok),
65 18 : GNUNET_PQ_result_spec_bool ("too_late",
66 : too_late),
67 18 : GNUNET_PQ_result_spec_bool ("conflict",
68 : conflict),
69 : GNUNET_PQ_result_spec_end
70 : };
71 :
72 : reserve_expiration
73 18 : = GNUNET_TIME_absolute_to_timestamp (
74 : GNUNET_TIME_absolute_add (GNUNET_TIME_absolute_get (),
75 : pg->legal_reserve_expiration_time));
76 :
77 18 : PREPARE (pg,
78 : "call_purse_deposit",
79 : "SELECT "
80 : " out_balance_ok AS balance_ok"
81 : ",out_conflict AS conflict"
82 : ",out_late AS too_late"
83 : " FROM exchange_do_purse_deposit"
84 : " ($1,$2,$3,$4,$5,$6,$7,$8);");
85 :
86 18 : return GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
87 : "call_purse_deposit",
88 : params,
89 : rs);
90 : }
|