Line data Source code
1 : /*
2 : This file is part of TALER
3 : Copyright (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 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/backenddb/iterate_custom_units_by_names.c
18 : * @brief Lookup custom measurement units by name
19 : * @author Bohdan Potuzhnyi
20 : */
21 : #include "platform.h"
22 : #include <taler/taler_error_codes.h>
23 : #include <taler/taler_dbevents.h>
24 : #include <taler/taler_pq_lib.h>
25 : #include "merchant-database/iterate_custom_units_by_names.h"
26 : #include "helper.h"
27 :
28 :
29 : /**
30 : * Context used for TALER_MERCHANTDB_iterate_custom_units_by_names().
31 : */
32 : struct LookupUnitsContext
33 : {
34 : TALER_MERCHANTDB_UnitsCallback cb;
35 : void *cb_cls;
36 : bool extract_failed;
37 : };
38 :
39 :
40 : static void
41 4 : lookup_units_cb (void *cls,
42 : PGresult *result,
43 : unsigned int num_results)
44 : {
45 4 : struct LookupUnitsContext *luc = cls;
46 :
47 6 : for (unsigned int i = 0; i<num_results; i++)
48 : {
49 2 : struct TALER_MERCHANTDB_UnitDetails ud = { 0 };
50 2 : struct GNUNET_PQ_ResultSpec rs[] = {
51 2 : GNUNET_PQ_result_spec_uint64 ("unit_serial",
52 : &ud.unit_serial),
53 2 : GNUNET_PQ_result_spec_string ("unit",
54 : &ud.unit),
55 2 : GNUNET_PQ_result_spec_string ("unit_name_long",
56 : &ud.unit_name_long),
57 2 : GNUNET_PQ_result_spec_string ("unit_name_short",
58 : &ud.unit_name_short),
59 2 : TALER_PQ_result_spec_json ("unit_name_long_i18n",
60 : &ud.unit_name_long_i18n),
61 2 : TALER_PQ_result_spec_json ("unit_name_short_i18n",
62 : &ud.unit_name_short_i18n),
63 2 : GNUNET_PQ_result_spec_bool ("unit_allow_fraction",
64 : &ud.unit_allow_fraction),
65 2 : GNUNET_PQ_result_spec_uint32 ("unit_precision_level",
66 : &ud.unit_precision_level),
67 2 : GNUNET_PQ_result_spec_bool ("unit_active",
68 : &ud.unit_active),
69 2 : GNUNET_PQ_result_spec_bool ("unit_builtin",
70 : &ud.unit_builtin),
71 : GNUNET_PQ_result_spec_end
72 : };
73 :
74 2 : if (GNUNET_OK !=
75 2 : GNUNET_PQ_extract_result (result,
76 : rs,
77 : i))
78 : {
79 0 : GNUNET_break (0);
80 0 : luc->extract_failed = true;
81 0 : return;
82 : }
83 2 : luc->cb (luc->cb_cls,
84 : ud.unit_serial,
85 : &ud);
86 2 : GNUNET_PQ_cleanup_result (rs);
87 : }
88 : }
89 :
90 :
91 : enum GNUNET_DB_QueryStatus
92 4 : TALER_MERCHANTDB_iterate_custom_units_by_names (
93 : struct TALER_MERCHANTDB_PostgresContext *pg,
94 : const char *instance_id,
95 : const char *const *units,
96 : size_t num_units,
97 : TALER_MERCHANTDB_UnitsCallback cb,
98 : void *cb_cls)
99 : {
100 4 : struct LookupUnitsContext luc = {
101 : .cb = cb,
102 : .cb_cls = cb_cls,
103 : .extract_failed = false
104 : };
105 4 : struct GNUNET_PQ_QueryParam params[] = {
106 4 : GNUNET_PQ_query_param_array_ptrs_string (num_units,
107 : (const char **) units,
108 : pg->conn),
109 : GNUNET_PQ_query_param_end
110 : };
111 : enum GNUNET_DB_QueryStatus qs;
112 :
113 4 : GNUNET_assert (NULL != pg->current_merchant_id);
114 4 : GNUNET_assert (0 == strcmp (instance_id,
115 : pg->current_merchant_id));
116 4 : TMH_PQ_prepare_anon (pg,
117 : "SELECT cu.unit_serial"
118 : " ,cu.unit"
119 : " ,cu.unit_name_long"
120 : " ,cu.unit_name_short"
121 : " ,cu.unit_name_long_i18n"
122 : " ,cu.unit_name_short_i18n"
123 : " ,cu.unit_allow_fraction"
124 : " ,cu.unit_precision_level"
125 : " ,cu.unit_active"
126 : " ,FALSE AS unit_builtin"
127 : " FROM merchant_custom_units cu"
128 : " WHERE cu.unit = ANY ($1)"
129 : " ORDER BY cu.unit");
130 4 : qs = GNUNET_PQ_eval_prepared_multi_select (pg->conn,
131 : "",
132 : params,
133 : &lookup_units_cb,
134 : &luc);
135 4 : GNUNET_PQ_cleanup_query_params_closures (params);
136 4 : if (luc.extract_failed)
137 0 : return GNUNET_DB_STATUS_HARD_ERROR;
138 4 : return qs;
139 : }
|
