Line data Source code
1 : /*
2 : This file is part of GNUnet
3 : Copyright (C) 2020-2025 Taler Systems SA
4 :
5 : GNUnet is free software: you can redistribute it and/or modify it
6 : under the terms of the GNU Affero General Public License as published
7 : by the Free Software Foundation, either version 3 of the License,
8 : or (at your option) any later version.
9 :
10 : GNUnet is distributed in the hope that it will be useful, but
11 : WITHOUT ANY WARRANTY; without even the implied warranty of
12 : MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 : Affero General Public License for more details.
14 :
15 : You should have received a copy of the GNU Affero General Public License
16 : along with this program. If not, see <http://www.gnu.org/licenses/>.
17 :
18 : SPDX-License-Identifier: AGPL3.0-or-later
19 : */
20 : /**
21 : * @file exchangedb/insert_records_by_table.c
22 : * @brief replicate_records_by_table implementation
23 : * @author Christian Grothoff
24 : * @author Özgür Kesim
25 : */
26 : #include "taler/taler_error_codes.h"
27 : #include "taler/taler_dbevents.h"
28 : #include "taler/taler_pq_lib.h"
29 : #include "exchange-database/insert_records_by_table.h"
30 : #include "helper.h"
31 : #include <gnunet/gnunet_pq_lib.h>
32 :
33 :
34 : /**
35 : * Signature of helper functions of #TALER_EXCHANGEDB_insert_records_by_table().
36 : *
37 : * @param pg plugin context
38 : * @param td record to insert
39 : * @return transaction status code
40 : */
41 : typedef enum GNUNET_DB_QueryStatus
42 : (*InsertRecordCallback)(struct TALER_EXCHANGEDB_PostgresContext *pg,
43 : const struct TALER_EXCHANGEDB_TableData *td);
44 :
45 :
46 : /**
47 : * Function called with denominations records to insert into table.
48 : *
49 : * @param pg plugin context
50 : * @param td record to insert
51 : */
52 : static enum GNUNET_DB_QueryStatus
53 0 : irbt_cb_table_denominations (struct TALER_EXCHANGEDB_PostgresContext *pg,
54 : const struct TALER_EXCHANGEDB_TableData *td)
55 : {
56 : struct TALER_DenominationHashP denom_hash;
57 0 : struct GNUNET_PQ_QueryParam params[] = {
58 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
59 0 : GNUNET_PQ_query_param_auto_from_type (&denom_hash),
60 0 : GNUNET_PQ_query_param_uint32 (
61 : &td->details.denominations.denom_type),
62 0 : GNUNET_PQ_query_param_uint32 (
63 : &td->details.denominations.age_mask),
64 0 : TALER_PQ_query_param_denom_pub (
65 : &td->details.denominations.denom_pub),
66 0 : GNUNET_PQ_query_param_auto_from_type (
67 : &td->details.denominations.master_sig),
68 0 : GNUNET_PQ_query_param_timestamp (
69 : &td->details.denominations.valid_from),
70 0 : GNUNET_PQ_query_param_timestamp (
71 : &td->details.denominations.expire_withdraw),
72 0 : GNUNET_PQ_query_param_timestamp (
73 : &td->details.denominations.expire_deposit),
74 0 : GNUNET_PQ_query_param_timestamp (
75 : &td->details.denominations.expire_legal),
76 0 : TALER_PQ_query_param_amount (
77 0 : pg->conn,
78 : &td->details.denominations.coin),
79 0 : TALER_PQ_query_param_amount (
80 0 : pg->conn,
81 : &td->details.denominations.fees.withdraw),
82 0 : TALER_PQ_query_param_amount (
83 0 : pg->conn,
84 : &td->details.denominations.fees.deposit),
85 0 : TALER_PQ_query_param_amount (
86 0 : pg->conn,
87 : &td->details.denominations.fees.refresh),
88 0 : TALER_PQ_query_param_amount (
89 0 : pg->conn,
90 : &td->details.denominations.fees.refund),
91 : GNUNET_PQ_query_param_end
92 : };
93 :
94 0 : PREPARE (pg,
95 : "insert_into_table_denominations",
96 : "INSERT INTO denominations"
97 : "(denominations_serial"
98 : ",denom_pub_hash"
99 : ",denom_type"
100 : ",age_mask"
101 : ",denom_pub"
102 : ",master_sig"
103 : ",valid_from"
104 : ",expire_withdraw"
105 : ",expire_deposit"
106 : ",expire_legal"
107 : ",coin"
108 : ",fee_withdraw"
109 : ",fee_deposit"
110 : ",fee_refresh"
111 : ",fee_refund"
112 : ") VALUES "
113 : "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10,"
114 : " $11, $12, $13, $14, $15);");
115 :
116 0 : TALER_denom_pub_hash (
117 : &td->details.denominations.denom_pub,
118 : &denom_hash);
119 :
120 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
121 : "insert_into_table_denominations",
122 : params);
123 : }
124 :
125 :
126 : /**
127 : * Function called with denomination_revocations records to insert into table.
128 : *
129 : * @param pg plugin context
130 : * @param td record to insert
131 : */
132 : static enum GNUNET_DB_QueryStatus
133 0 : irbt_cb_table_denomination_revocations (
134 : struct TALER_EXCHANGEDB_PostgresContext *pg,
135 : const struct TALER_EXCHANGEDB_TableData *td)
136 : {
137 0 : struct GNUNET_PQ_QueryParam params[] = {
138 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
139 0 : GNUNET_PQ_query_param_auto_from_type (
140 : &td->details.denomination_revocations.master_sig),
141 0 : GNUNET_PQ_query_param_uint64 (
142 : &td->details.denomination_revocations.denominations_serial),
143 : GNUNET_PQ_query_param_end
144 : };
145 :
146 0 : PREPARE (pg,
147 : "insert_into_table_denomination_revocations",
148 : "INSERT INTO denomination_revocations"
149 : "(denom_revocations_serial_id"
150 : ",master_sig"
151 : ",denominations_serial"
152 : ") VALUES "
153 : "($1, $2, $3);");
154 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
155 : "insert_into_table_denomination_revocations",
156 : params);
157 : }
158 :
159 :
160 : /**
161 : * Function called with wire target records to insert into table.
162 : *
163 : * @param pg plugin context
164 : * @param td record to insert
165 : */
166 : static enum GNUNET_DB_QueryStatus
167 0 : irbt_cb_table_wire_targets (struct TALER_EXCHANGEDB_PostgresContext *pg,
168 : const struct TALER_EXCHANGEDB_TableData *td)
169 : {
170 : struct TALER_NormalizedPaytoHashP normalized_payto_hash;
171 : struct TALER_FullPaytoHashP full_payto_hash;
172 0 : struct GNUNET_PQ_QueryParam params[] = {
173 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
174 0 : GNUNET_PQ_query_param_auto_from_type (&full_payto_hash),
175 0 : GNUNET_PQ_query_param_auto_from_type (&normalized_payto_hash),
176 0 : GNUNET_PQ_query_param_string (
177 0 : td->details.wire_targets.full_payto_uri.full_payto),
178 : GNUNET_PQ_query_param_end
179 : };
180 :
181 0 : TALER_full_payto_hash (
182 : td->details.wire_targets.full_payto_uri,
183 : &full_payto_hash);
184 0 : TALER_full_payto_normalize_and_hash (
185 : td->details.wire_targets.full_payto_uri,
186 : &normalized_payto_hash);
187 0 : PREPARE (pg,
188 : "insert_into_table_wire_targets",
189 : "INSERT INTO wire_targets"
190 : "(wire_target_serial_id"
191 : ",wire_target_h_payto"
192 : ",h_normalized_payto"
193 : ",payto_uri"
194 : ") VALUES "
195 : "($1, $2, $3, $4);");
196 0 : return GNUNET_PQ_eval_prepared_non_select (
197 : pg->conn,
198 : "insert_into_table_wire_targets",
199 : params);
200 : }
201 :
202 :
203 : /**
204 : * Function called with kyc target records to insert into table.
205 : *
206 : * @param pg plugin context
207 : * @param td record to insert
208 : */
209 : static enum GNUNET_DB_QueryStatus
210 0 : irbt_cb_table_kyc_targets (struct TALER_EXCHANGEDB_PostgresContext *pg,
211 : const struct TALER_EXCHANGEDB_TableData *td)
212 : {
213 0 : struct GNUNET_PQ_QueryParam params[] = {
214 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
215 0 : GNUNET_PQ_query_param_auto_from_type (
216 : &td->details.kyc_targets.h_normalized_payto),
217 0 : GNUNET_PQ_query_param_auto_from_type (
218 : &td->details.kyc_targets.access_token),
219 0 : td->details.kyc_targets.no_account
220 0 : ? GNUNET_PQ_query_param_null ()
221 0 : : GNUNET_PQ_query_param_auto_from_type (
222 : &td->details.kyc_targets.target_pub),
223 0 : GNUNET_PQ_query_param_bool (
224 0 : td->details.kyc_targets.is_wallet),
225 : GNUNET_PQ_query_param_end
226 : };
227 :
228 0 : PREPARE (pg,
229 : "insert_into_table_kyc_targets",
230 : "INSERT INTO kyc_targets"
231 : "(kyc_target_serial_id"
232 : ",h_normalized_payto"
233 : ",access_token"
234 : ",target_pub"
235 : ",is_wallet"
236 : ") VALUES "
237 : "($1, $2, $3, $4, $5);");
238 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
239 : "insert_into_table_kyc_targets",
240 : params);
241 : }
242 :
243 :
244 : /**
245 : * Function called with records to insert into table.
246 : *
247 : * @param pg plugin context
248 : * @param td record to insert
249 : */
250 : static enum GNUNET_DB_QueryStatus
251 0 : irbt_cb_table_legitimization_measures (
252 : struct TALER_EXCHANGEDB_PostgresContext *pg,
253 : const struct TALER_EXCHANGEDB_TableData *td)
254 : {
255 0 : struct GNUNET_PQ_QueryParam params[] = {
256 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
257 0 : GNUNET_PQ_query_param_auto_from_type (
258 : &td->details.legitimization_measures.target_token),
259 0 : GNUNET_PQ_query_param_timestamp (
260 : &td->details.legitimization_measures.start_time),
261 0 : TALER_PQ_query_param_json (
262 0 : td->details.legitimization_measures.measures),
263 0 : GNUNET_PQ_query_param_uint32 (
264 : &td->details.legitimization_measures.display_priority),
265 : GNUNET_PQ_query_param_end
266 : };
267 :
268 0 : PREPARE (pg,
269 : "insert_into_table_legitimization_measures",
270 : "INSERT INTO legitimization_measures"
271 : "(legitimization_measure_serial_id"
272 : ",access_token"
273 : ",start_time"
274 : ",jmeasures"
275 : ",display_priority"
276 : ") VALUES "
277 : "($1, $2, $3, $4::TEXT::JSONB, $5);");
278 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
279 : "insert_into_table_legitimization_measures",
280 : params);
281 : }
282 :
283 :
284 : /**
285 : * Function called with records to insert into table.
286 : *
287 : * @param pg plugin context
288 : * @param td record to insert
289 : */
290 : static enum GNUNET_DB_QueryStatus
291 0 : irbt_cb_table_legitimization_outcomes (
292 : struct TALER_EXCHANGEDB_PostgresContext *pg,
293 : const struct TALER_EXCHANGEDB_TableData *td)
294 : {
295 0 : struct GNUNET_PQ_QueryParam params[] = {
296 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
297 0 : GNUNET_PQ_query_param_auto_from_type (
298 : &td->details.legitimization_outcomes.h_payto),
299 0 : GNUNET_PQ_query_param_timestamp (
300 : &td->details.legitimization_outcomes.decision_time),
301 0 : GNUNET_PQ_query_param_timestamp (
302 : &td->details.legitimization_outcomes.expiration_time),
303 0 : TALER_PQ_query_param_json (
304 0 : td->details.legitimization_outcomes.properties),
305 0 : GNUNET_PQ_query_param_bool (
306 0 : td->details.legitimization_outcomes.to_investigate),
307 0 : TALER_PQ_query_param_json (
308 0 : td->details.legitimization_outcomes.new_rules),
309 : GNUNET_PQ_query_param_end
310 : };
311 :
312 0 : PREPARE (pg,
313 : "insert_into_table_legitimization_outcomes",
314 : "INSERT INTO legitimization_outcomes"
315 : "(outcome_serial_id"
316 : ",h_payto"
317 : ",decision_time"
318 : ",expiration_time"
319 : ",jproperties"
320 : ",to_investigate"
321 : ",jnew_rules"
322 : ") VALUES "
323 : "($1, $2, $3, $4, $5::TEXT::JSONB, $6, $7::TEXT::JSONB);");
324 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
325 : "insert_into_table_legitimization_outcomes",
326 : params);
327 : }
328 :
329 :
330 : /**
331 : * Function called with records to insert into table.
332 : *
333 : * @param pg plugin context
334 : * @param td record to insert
335 : */
336 : static enum GNUNET_DB_QueryStatus
337 0 : irbt_cb_table_legitimization_processes (
338 : struct TALER_EXCHANGEDB_PostgresContext *pg,
339 : const struct TALER_EXCHANGEDB_TableData *td)
340 : {
341 0 : struct GNUNET_PQ_QueryParam params[] = {
342 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
343 0 : GNUNET_PQ_query_param_auto_from_type (
344 : &td->details.legitimization_processes.h_payto),
345 0 : GNUNET_PQ_query_param_timestamp (
346 : &td->details.legitimization_processes.start_time),
347 0 : GNUNET_PQ_query_param_timestamp (
348 : &td->details.legitimization_processes.expiration_time),
349 0 : GNUNET_PQ_query_param_uint64 (
350 : &td->details.legitimization_processes.legitimization_measure_serial_id),
351 0 : GNUNET_PQ_query_param_uint32 (
352 : &td->details.legitimization_processes.measure_index),
353 0 : GNUNET_PQ_query_param_string (
354 0 : td->details.legitimization_processes.provider_name),
355 0 : GNUNET_PQ_query_param_string (
356 0 : td->details.legitimization_processes.provider_user_id),
357 0 : GNUNET_PQ_query_param_string (
358 0 : td->details.legitimization_processes.provider_legitimization_id),
359 0 : GNUNET_PQ_query_param_string (
360 0 : td->details.legitimization_processes.redirect_url),
361 : GNUNET_PQ_query_param_end
362 : };
363 :
364 0 : PREPARE (pg,
365 : "insert_into_table_legitimization_processes",
366 : "INSERT INTO legitimization_processes"
367 : "(legitimization_process_serial_id"
368 : ",h_payto"
369 : ",start_time"
370 : ",expiration_time"
371 : ",legitimization_measure_serial_id"
372 : ",measure_index"
373 : ",provider_name"
374 : ",provider_user_id"
375 : ",provider_legitimization_id"
376 : ",redirect_url"
377 : ") VALUES "
378 : "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10);");
379 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
380 : "insert_into_table_legitimization_processes",
381 : params);
382 : }
383 :
384 :
385 : /**
386 : * Function called with reserves records to insert into table.
387 : *
388 : * @param pg plugin context
389 : * @param td record to insert
390 : */
391 : static enum GNUNET_DB_QueryStatus
392 0 : irbt_cb_table_reserves (struct TALER_EXCHANGEDB_PostgresContext *pg,
393 : const struct TALER_EXCHANGEDB_TableData *td)
394 : {
395 0 : struct GNUNET_PQ_QueryParam params[] = {
396 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
397 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.reserves.reserve_pub),
398 0 : GNUNET_PQ_query_param_timestamp (&td->details.reserves.expiration_date),
399 0 : GNUNET_PQ_query_param_timestamp (&td->details.reserves.gc_date),
400 : GNUNET_PQ_query_param_end
401 : };
402 :
403 0 : PREPARE (pg,
404 : "insert_into_table_reserves",
405 : "INSERT INTO reserves"
406 : "(reserve_uuid"
407 : ",reserve_pub"
408 : ",expiration_date"
409 : ",gc_date"
410 : ") VALUES "
411 : "($1, $2, $3, $4);");
412 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
413 : "insert_into_table_reserves",
414 : params);
415 : }
416 :
417 :
418 : /**
419 : * Function called with reserves_in records to insert into table.
420 : *
421 : * @param pg plugin context
422 : * @param td record to insert
423 : */
424 : static enum GNUNET_DB_QueryStatus
425 0 : irbt_cb_table_reserves_in (struct TALER_EXCHANGEDB_PostgresContext *pg,
426 : const struct TALER_EXCHANGEDB_TableData *td)
427 : {
428 0 : struct GNUNET_PQ_QueryParam params[] = {
429 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
430 0 : GNUNET_PQ_query_param_uint64 (&td->details.reserves_in.wire_reference),
431 0 : TALER_PQ_query_param_amount (
432 0 : pg->conn,
433 : &td->details.reserves_in.credit),
434 0 : GNUNET_PQ_query_param_auto_from_type (
435 : &td->details.reserves_in.sender_account_h_payto),
436 0 : GNUNET_PQ_query_param_string (
437 0 : td->details.reserves_in.exchange_account_section),
438 0 : GNUNET_PQ_query_param_timestamp (
439 : &td->details.reserves_in.execution_date),
440 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.reserves_in.reserve_pub),
441 : GNUNET_PQ_query_param_end
442 : };
443 :
444 0 : PREPARE (pg,
445 : "insert_into_table_reserves_in",
446 : "INSERT INTO reserves_in"
447 : "(reserve_in_serial_id"
448 : ",wire_reference"
449 : ",credit"
450 : ",wire_source_h_payto"
451 : ",exchange_account_section"
452 : ",execution_date"
453 : ",reserve_pub"
454 : ") VALUES "
455 : "($1, $2, $3, $4, $5, $6, $7);");
456 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
457 : "insert_into_table_reserves_in",
458 : params);
459 : }
460 :
461 :
462 : /**
463 : * Function called with kycauth_in records to insert into table.
464 : *
465 : * @param pg plugin context
466 : * @param td record to insert
467 : */
468 : static enum GNUNET_DB_QueryStatus
469 0 : irbt_cb_table_kycauths_in (struct TALER_EXCHANGEDB_PostgresContext *pg,
470 : const struct TALER_EXCHANGEDB_TableData *td)
471 : {
472 0 : struct GNUNET_PQ_QueryParam params[] = {
473 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
474 0 : GNUNET_PQ_query_param_uint64 (&td->details.kycauth_in.wire_reference),
475 0 : TALER_PQ_query_param_amount (
476 0 : pg->conn,
477 : &td->details.reserves_in.credit),
478 0 : GNUNET_PQ_query_param_auto_from_type (
479 : &td->details.reserves_in.sender_account_h_payto),
480 0 : GNUNET_PQ_query_param_string (
481 0 : td->details.reserves_in.exchange_account_section),
482 0 : GNUNET_PQ_query_param_timestamp (
483 : &td->details.reserves_in.execution_date),
484 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.kycauth_in.account_pub),
485 : GNUNET_PQ_query_param_end
486 : };
487 :
488 0 : PREPARE (pg,
489 : "insert_into_table_kycauth_in",
490 : "INSERT INTO kycauths_in"
491 : "(kycauth_in_serial_id"
492 : ",wire_reference"
493 : ",credit"
494 : ",wire_source_h_payto"
495 : ",exchange_account_section"
496 : ",execution_date"
497 : ",account_pub"
498 : ") VALUES "
499 : "($1, $2, $3, $4, $5, $6, $7);");
500 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
501 : "insert_into_table_kycauth_in",
502 : params);
503 : }
504 :
505 :
506 : /**
507 : * Function called with reserves_open_requests records to insert into table.
508 : *
509 : * @param pg plugin context
510 : * @param td record to insert
511 : */
512 : static enum GNUNET_DB_QueryStatus
513 0 : irbt_cb_table_reserves_open_requests (struct TALER_EXCHANGEDB_PostgresContext *
514 : pg,
515 : const struct
516 : TALER_EXCHANGEDB_TableData *td)
517 : {
518 0 : struct GNUNET_PQ_QueryParam params[] = {
519 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
520 0 : GNUNET_PQ_query_param_timestamp (
521 : &td->details.reserves_open_requests.expiration_date),
522 0 : GNUNET_PQ_query_param_auto_from_type (
523 : &td->details.reserves_open_requests.reserve_sig),
524 0 : TALER_PQ_query_param_amount (
525 0 : pg->conn,
526 : &td->details.reserves_open_requests.reserve_payment),
527 0 : GNUNET_PQ_query_param_uint32 (
528 : &td->details.reserves_open_requests.requested_purse_limit),
529 : GNUNET_PQ_query_param_end
530 : };
531 :
532 0 : PREPARE (pg,
533 : "insert_into_table_reserves_open_requests",
534 : "INSERT INTO reserves_open_requests"
535 : "(open_request_uuid"
536 : ",reserve_pub"
537 : ",request_timestamp"
538 : ",expiration_date"
539 : ",reserve_sig"
540 : ",reserve_payment"
541 : ",requested_purse_limit"
542 : ") VALUES "
543 : "($1, $2, $3, $4, $5, $6, $7);");
544 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
545 : "insert_into_table_reserves_open_requests",
546 : params);
547 : }
548 :
549 :
550 : /**
551 : * Function called with reserves_open_requests records to insert into table.
552 : *
553 : * @param pg plugin context
554 : * @param td record to insert
555 : */
556 : static enum GNUNET_DB_QueryStatus
557 0 : irbt_cb_table_reserves_open_deposits (
558 : struct TALER_EXCHANGEDB_PostgresContext *pg,
559 : const struct TALER_EXCHANGEDB_TableData *td)
560 : {
561 0 : struct GNUNET_PQ_QueryParam params[] = {
562 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
563 0 : GNUNET_PQ_query_param_auto_from_type (
564 : &td->details.reserves_open_deposits.coin_pub),
565 0 : GNUNET_PQ_query_param_auto_from_type (
566 : &td->details.reserves_open_deposits.coin_sig),
567 0 : GNUNET_PQ_query_param_auto_from_type (
568 : &td->details.reserves_open_deposits.reserve_sig),
569 0 : TALER_PQ_query_param_amount (
570 0 : pg->conn,
571 : &td->details.reserves_open_deposits.contribution),
572 : GNUNET_PQ_query_param_end
573 : };
574 :
575 0 : PREPARE (pg,
576 : "insert_into_table_reserves_open_deposits",
577 : "INSERT INTO reserves_open_deposits"
578 : "(reserve_open_deposit_uuid"
579 : ",reserve_sig"
580 : ",reserve_pub"
581 : ",coin_pub"
582 : ",coin_sig"
583 : ",contribution"
584 : ") VALUES "
585 : "($1, $2, $3, $4, $5, $6);");
586 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
587 : "insert_into_table_reserves_open_deposits",
588 : params);
589 : }
590 :
591 :
592 : /**
593 : * Function called with reserves_close records to insert into table.
594 : *
595 : * @param pg plugin context
596 : * @param td record to insert
597 : */
598 : static enum GNUNET_DB_QueryStatus
599 0 : irbt_cb_table_reserves_close (struct TALER_EXCHANGEDB_PostgresContext *pg,
600 : const struct TALER_EXCHANGEDB_TableData *td)
601 : {
602 0 : struct GNUNET_PQ_QueryParam params[] = {
603 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
604 0 : GNUNET_PQ_query_param_timestamp (
605 : &td->details.reserves_close.execution_date),
606 0 : GNUNET_PQ_query_param_auto_from_type (
607 : &td->details.reserves_close.wtid),
608 0 : GNUNET_PQ_query_param_auto_from_type (
609 : &td->details.reserves_close.sender_account_h_payto),
610 0 : TALER_PQ_query_param_amount (
611 0 : pg->conn,
612 : &td->details.reserves_close.amount),
613 0 : TALER_PQ_query_param_amount (
614 0 : pg->conn,
615 : &td->details.reserves_close.closing_fee),
616 0 : GNUNET_PQ_query_param_auto_from_type (
617 : &td->details.reserves_close.reserve_pub),
618 : GNUNET_PQ_query_param_end
619 : };
620 :
621 0 : PREPARE (pg,
622 : "insert_into_table_reserves_close",
623 : "INSERT INTO reserves_close"
624 : "(close_uuid"
625 : ",execution_date"
626 : ",wtid"
627 : ",wire_target_h_payto"
628 : ",amount"
629 : ",closing_fee"
630 : ",reserve_pub"
631 : ") VALUES "
632 : "($1, $2, $3, $4, $5, $6, $7);");
633 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
634 : "insert_into_table_reserves_close",
635 : params);
636 : }
637 :
638 :
639 : /**
640 : * Function called with auditors records to insert into table.
641 : *
642 : * @param pg plugin context
643 : * @param td record to insert
644 : */
645 : static enum GNUNET_DB_QueryStatus
646 0 : irbt_cb_table_auditors (struct TALER_EXCHANGEDB_PostgresContext *pg,
647 : const struct TALER_EXCHANGEDB_TableData *td)
648 : {
649 0 : struct GNUNET_PQ_QueryParam params[] = {
650 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
651 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.auditors.auditor_pub),
652 0 : GNUNET_PQ_query_param_string (td->details.auditors.auditor_name),
653 0 : GNUNET_PQ_query_param_string (td->details.auditors.auditor_url),
654 0 : GNUNET_PQ_query_param_bool (td->details.auditors.is_active),
655 0 : GNUNET_PQ_query_param_timestamp (&td->details.auditors.last_change),
656 : GNUNET_PQ_query_param_end
657 : };
658 :
659 0 : PREPARE (pg,
660 : "insert_into_table_auditors",
661 : "INSERT INTO auditors"
662 : "(auditor_uuid"
663 : ",auditor_pub"
664 : ",auditor_name"
665 : ",auditor_url"
666 : ",is_active"
667 : ",last_change"
668 : ") VALUES "
669 : "($1, $2, $3, $4, $5, $6);");
670 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
671 : "insert_into_table_auditors",
672 : params);
673 : }
674 :
675 :
676 : /**
677 : * Function called with auditor_denom_sigs records to insert into table.
678 : *
679 : * @param pg plugin context
680 : * @param td record to insert
681 : */
682 : static enum GNUNET_DB_QueryStatus
683 0 : irbt_cb_table_auditor_denom_sigs (struct TALER_EXCHANGEDB_PostgresContext *pg,
684 : const struct TALER_EXCHANGEDB_TableData *td)
685 : {
686 0 : struct GNUNET_PQ_QueryParam params[] = {
687 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
688 0 : GNUNET_PQ_query_param_uint64 (&td->details.auditor_denom_sigs.auditor_uuid),
689 0 : GNUNET_PQ_query_param_uint64 (
690 : &td->details.auditor_denom_sigs.denominations_serial),
691 0 : GNUNET_PQ_query_param_auto_from_type (
692 : &td->details.auditor_denom_sigs.auditor_sig),
693 : GNUNET_PQ_query_param_end
694 : };
695 :
696 0 : PREPARE (pg,
697 : "insert_into_table_auditor_denom_sigs",
698 : "INSERT INTO auditor_denom_sigs"
699 : "(auditor_denom_serial"
700 : ",auditor_uuid"
701 : ",denominations_serial"
702 : ",auditor_sig"
703 : ") VALUES "
704 : "($1, $2, $3, $4);");
705 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
706 : "insert_into_table_auditor_denom_sigs",
707 : params);
708 : }
709 :
710 :
711 : /**
712 : * Function called with exchange_sign_keys records to insert into table.
713 : *
714 : * @param pg plugin context
715 : * @param td record to insert
716 : */
717 : static enum GNUNET_DB_QueryStatus
718 0 : irbt_cb_table_exchange_sign_keys (struct TALER_EXCHANGEDB_PostgresContext *pg,
719 : const struct TALER_EXCHANGEDB_TableData *td)
720 : {
721 0 : struct GNUNET_PQ_QueryParam params[] = {
722 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
723 0 : GNUNET_PQ_query_param_auto_from_type (
724 : &td->details.exchange_sign_keys.exchange_pub),
725 0 : GNUNET_PQ_query_param_auto_from_type (
726 : &td->details.exchange_sign_keys.master_sig),
727 0 : GNUNET_PQ_query_param_timestamp (
728 : &td->details.exchange_sign_keys.meta.start),
729 0 : GNUNET_PQ_query_param_timestamp (
730 : &td->details.exchange_sign_keys.meta.expire_sign),
731 0 : GNUNET_PQ_query_param_timestamp (
732 : &td->details.exchange_sign_keys.meta.expire_legal),
733 : GNUNET_PQ_query_param_end
734 : };
735 :
736 0 : PREPARE (pg,
737 : "insert_into_table_exchange_sign_keys",
738 : "INSERT INTO exchange_sign_keys"
739 : "(esk_serial"
740 : ",exchange_pub"
741 : ",master_sig"
742 : ",valid_from"
743 : ",expire_sign"
744 : ",expire_legal"
745 : ") VALUES "
746 : "($1, $2, $3, $4, $5, $6);");
747 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
748 : "insert_into_table_exchange_sign_keys",
749 : params);
750 : }
751 :
752 :
753 : /**
754 : * Function called with signkey_revocations records to insert into table.
755 : *
756 : * @param pg plugin context
757 : * @param td record to insert
758 : */
759 : static enum GNUNET_DB_QueryStatus
760 0 : irbt_cb_table_signkey_revocations (struct TALER_EXCHANGEDB_PostgresContext *pg,
761 : const struct TALER_EXCHANGEDB_TableData *td)
762 : {
763 0 : struct GNUNET_PQ_QueryParam params[] = {
764 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
765 0 : GNUNET_PQ_query_param_uint64 (&td->details.signkey_revocations.esk_serial),
766 0 : GNUNET_PQ_query_param_auto_from_type (
767 : &td->details.signkey_revocations.master_sig),
768 : GNUNET_PQ_query_param_end
769 : };
770 :
771 0 : PREPARE (pg,
772 : "insert_into_table_signkey_revocations",
773 : "INSERT INTO signkey_revocations"
774 : "(signkey_revocations_serial_id"
775 : ",esk_serial"
776 : ",master_sig"
777 : ") VALUES "
778 : "($1, $2, $3);");
779 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
780 : "insert_into_table_signkey_revocations",
781 : params);
782 : }
783 :
784 :
785 : /**
786 : * Function called with known_coins records to insert into table.
787 : *
788 : * @param pg plugin context
789 : * @param td record to insert
790 : */
791 : static enum GNUNET_DB_QueryStatus
792 0 : irbt_cb_table_known_coins (struct TALER_EXCHANGEDB_PostgresContext *pg,
793 : const struct TALER_EXCHANGEDB_TableData *td)
794 : {
795 0 : struct GNUNET_PQ_QueryParam params[] = {
796 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
797 0 : GNUNET_PQ_query_param_auto_from_type (
798 : &td->details.known_coins.coin_pub),
799 0 : TALER_PQ_query_param_denom_sig (
800 : &td->details.known_coins.denom_sig),
801 0 : GNUNET_PQ_query_param_uint64 (
802 : &td->details.known_coins.denominations_serial),
803 : GNUNET_PQ_query_param_end
804 : };
805 :
806 0 : PREPARE (pg,
807 : "insert_into_table_known_coins",
808 : "INSERT INTO known_coins"
809 : "(known_coin_id"
810 : ",coin_pub"
811 : ",denom_sig"
812 : ",denominations_serial"
813 : ") VALUES "
814 : "($1, $2, $3, $4);");
815 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
816 : "insert_into_table_known_coins",
817 : params);
818 : }
819 :
820 :
821 : /**
822 : * Function called with refresh records to insert into table.
823 : *
824 : * @param pg plugin context
825 : * @param td record to insert
826 : */
827 : static enum GNUNET_DB_QueryStatus
828 0 : irbt_cb_table_refresh (struct TALER_EXCHANGEDB_PostgresContext *pg,
829 : const struct TALER_EXCHANGEDB_TableData *td)
830 : {
831 0 : struct GNUNET_PQ_QueryParam params[] = {
832 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
833 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.refresh.rc),
834 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.refresh.execution_date),
835 0 : TALER_PQ_query_param_amount (
836 0 : pg->conn,
837 : &td->details.refresh.amount_with_fee),
838 0 : GNUNET_PQ_query_param_auto_from_type (
839 : &td->details.refresh.old_coin_pub),
840 0 : GNUNET_PQ_query_param_auto_from_type (
841 : &td->details.refresh.old_coin_sig),
842 0 : GNUNET_PQ_query_param_auto_from_type (
843 : &td->details.refresh.refresh_seed),
844 0 : GNUNET_PQ_query_param_uint32 (
845 : &td->details.refresh.noreveal_index),
846 0 : GNUNET_PQ_query_param_auto_from_type (
847 : &td->details.refresh.planchets_h),
848 0 : GNUNET_PQ_query_param_auto_from_type (
849 : &td->details.refresh.selected_h),
850 0 : td->details.refresh.no_blinding_seed
851 0 : ? GNUNET_PQ_query_param_null ()
852 0 : : GNUNET_PQ_query_param_auto_from_type (
853 : &td->details.refresh.blinding_seed),
854 0 : td->details.refresh.no_blinding_seed
855 0 : ? GNUNET_PQ_query_param_null ()
856 0 : : TALER_PQ_query_param_array_cs_r_pub (
857 0 : td->details.refresh.num_cs_r_values,
858 0 : td->details.refresh.cs_r_values,
859 : pg->conn),
860 0 : td->details.refresh.no_blinding_seed
861 0 : ? GNUNET_PQ_query_param_null ()
862 0 : : GNUNET_PQ_query_param_uint64 (
863 : &td->details.refresh.cs_r_choices),
864 0 : GNUNET_PQ_query_param_array_uint64 (
865 0 : td->details.refresh.num_coins,
866 0 : td->details.refresh.denom_serials,
867 : pg->conn),
868 0 : TALER_PQ_query_param_array_blinded_denom_sig (
869 0 : td->details.refresh.num_coins,
870 0 : td->details.refresh.denom_sigs,
871 : pg->conn),
872 : GNUNET_PQ_query_param_end
873 : };
874 :
875 0 : PREPARE (pg,
876 : "insert_into_table_refresh",
877 : "INSERT INTO refresh"
878 : "(refresh_id"
879 : ",rc"
880 : ",execution_date"
881 : ",amount_with_fee"
882 : ",old_coin_pub"
883 : ",old_coin_sig"
884 : ",refresh_seed"
885 : ",noreveal_index"
886 : ",planchets_h"
887 : ",selected_h"
888 : ",blinding_seed"
889 : ",cs_r_values"
890 : ",cs_r_choices"
891 : ",denom_serials"
892 : ",denom_sigs"
893 : ") VALUES "
894 : "($1, $2, $3, $4, $5, $6,$7,$8,$9,$10,$11,$12,$13,$14,$15);");
895 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
896 : "insert_into_table_refresh",
897 : params);
898 : }
899 :
900 :
901 : /**
902 : * Function called with batch deposits records to insert into table.
903 : *
904 : * @param pg plugin context
905 : * @param td record to insert
906 : */
907 : static enum GNUNET_DB_QueryStatus
908 0 : irbt_cb_table_batch_deposits (struct TALER_EXCHANGEDB_PostgresContext *pg,
909 : const struct TALER_EXCHANGEDB_TableData *td)
910 : {
911 0 : struct GNUNET_PQ_QueryParam params[] = {
912 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
913 0 : GNUNET_PQ_query_param_uint64 (&td->details.batch_deposits.shard),
914 0 : GNUNET_PQ_query_param_auto_from_type (
915 : &td->details.batch_deposits.merchant_pub),
916 0 : GNUNET_PQ_query_param_timestamp (
917 : &td->details.batch_deposits.wallet_timestamp),
918 0 : GNUNET_PQ_query_param_timestamp (
919 : &td->details.batch_deposits.exchange_timestamp),
920 0 : GNUNET_PQ_query_param_timestamp (
921 : &td->details.batch_deposits.refund_deadline),
922 0 : GNUNET_PQ_query_param_timestamp (&td->details.batch_deposits.wire_deadline),
923 0 : GNUNET_PQ_query_param_auto_from_type (
924 : &td->details.batch_deposits.h_contract_terms),
925 0 : td->details.batch_deposits.no_wallet_data_hash
926 0 : ? GNUNET_PQ_query_param_null ()
927 0 : : GNUNET_PQ_query_param_auto_from_type (
928 : &td->details.batch_deposits.wallet_data_hash),
929 0 : GNUNET_PQ_query_param_auto_from_type (
930 : &td->details.batch_deposits.wire_salt),
931 0 : GNUNET_PQ_query_param_auto_from_type (
932 : &td->details.batch_deposits.wire_target_h_payto),
933 0 : td->details.batch_deposits.no_policy_details
934 0 : ? GNUNET_PQ_query_param_null ()
935 0 : : GNUNET_PQ_query_param_uint64 (
936 : &td->details.batch_deposits.policy_details_serial_id),
937 0 : GNUNET_PQ_query_param_bool (td->details.batch_deposits.policy_blocked),
938 0 : TALER_PQ_query_param_amount (
939 0 : pg->conn,
940 : &td->details.batch_deposits.total_amount),
941 0 : TALER_PQ_query_param_amount (
942 0 : pg->conn,
943 : &td->details.batch_deposits.total_without_fee),
944 0 : GNUNET_PQ_query_param_auto_from_type (
945 : &td->details.batch_deposits.merchant_sig),
946 0 : GNUNET_PQ_query_param_bool (td->details.batch_deposits.done),
947 : GNUNET_PQ_query_param_end
948 : };
949 :
950 0 : PREPARE (pg,
951 : "insert_into_table_batch_deposits",
952 : "INSERT INTO batch_deposits"
953 : "(batch_deposit_serial_id"
954 : ",shard"
955 : ",merchant_pub"
956 : ",wallet_timestamp"
957 : ",exchange_timestamp"
958 : ",refund_deadline"
959 : ",wire_deadline"
960 : ",h_contract_terms"
961 : ",wallet_data_hash"
962 : ",wire_salt"
963 : ",wire_target_h_payto"
964 : ",policy_details_serial_id"
965 : ",policy_blocked"
966 : ",total_amount"
967 : ",total_without_fee"
968 : ",merchant_sig"
969 : ",done"
970 : ") VALUES "
971 : "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10,"
972 : " $11, $12, $13, $14, $15, $16, $17);");
973 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
974 : "insert_into_table_batch_deposits",
975 : params);
976 : }
977 :
978 :
979 : /**
980 : * Function called with deposits records to insert into table.
981 : *
982 : * @param pg plugin context
983 : * @param td record to insert
984 : */
985 : static enum GNUNET_DB_QueryStatus
986 0 : irbt_cb_table_coin_deposits (struct TALER_EXCHANGEDB_PostgresContext *pg,
987 : const struct TALER_EXCHANGEDB_TableData *td)
988 : {
989 0 : struct GNUNET_PQ_QueryParam params[] = {
990 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
991 0 : GNUNET_PQ_query_param_uint64 (
992 : &td->details.coin_deposits.batch_deposit_serial_id),
993 0 : GNUNET_PQ_query_param_auto_from_type (
994 : &td->details.coin_deposits.coin_pub),
995 0 : GNUNET_PQ_query_param_auto_from_type (
996 : &td->details.coin_deposits.coin_sig),
997 0 : TALER_PQ_query_param_amount (
998 0 : pg->conn,
999 : &td->details.coin_deposits.amount_with_fee),
1000 : GNUNET_PQ_query_param_end
1001 : };
1002 :
1003 0 : PREPARE (pg,
1004 : "insert_into_table_coin_deposits",
1005 : "INSERT INTO coin_deposits"
1006 : "(coin_deposit_serial_id"
1007 : ",batch_deposit_serial_id"
1008 : ",coin_pub"
1009 : ",coin_sig"
1010 : ",amount_with_fee"
1011 : ") VALUES "
1012 : "($1, $2, $3, $4, $5);");
1013 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1014 : "insert_into_table_coin_deposits",
1015 : params);
1016 : }
1017 :
1018 :
1019 : /**
1020 : * Function called with refunds records to insert into table.
1021 : *
1022 : * @param pg plugin context
1023 : * @param td record to insert
1024 : */
1025 : static enum GNUNET_DB_QueryStatus
1026 0 : irbt_cb_table_refunds (struct TALER_EXCHANGEDB_PostgresContext *pg,
1027 : const struct TALER_EXCHANGEDB_TableData *td)
1028 : {
1029 0 : struct GNUNET_PQ_QueryParam params[] = {
1030 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1031 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.refunds.coin_pub),
1032 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.refunds.merchant_sig),
1033 0 : GNUNET_PQ_query_param_uint64 (&td->details.refunds.rtransaction_id),
1034 0 : TALER_PQ_query_param_amount (
1035 0 : pg->conn,
1036 : &td->details.refunds.amount_with_fee),
1037 0 : GNUNET_PQ_query_param_uint64 (
1038 : &td->details.refunds.batch_deposit_serial_id),
1039 : GNUNET_PQ_query_param_end
1040 : };
1041 :
1042 0 : PREPARE (pg,
1043 : "insert_into_table_refunds",
1044 : "INSERT INTO refunds"
1045 : "(refund_serial_id"
1046 : ",coin_pub"
1047 : ",merchant_sig"
1048 : ",rtransaction_id"
1049 : ",amount_with_fee"
1050 : ",batch_deposit_serial_id"
1051 : ") VALUES "
1052 : "($1, $2, $3, $4, $5, $6);");
1053 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1054 : "insert_into_table_refunds",
1055 : params);
1056 : }
1057 :
1058 :
1059 : /**
1060 : * Function called with wire_out records to insert into table.
1061 : *
1062 : * @param pg plugin context
1063 : * @param td record to insert
1064 : */
1065 : static enum GNUNET_DB_QueryStatus
1066 0 : irbt_cb_table_wire_out (struct TALER_EXCHANGEDB_PostgresContext *pg,
1067 : const struct TALER_EXCHANGEDB_TableData *td)
1068 : {
1069 0 : struct GNUNET_PQ_QueryParam params[] = {
1070 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1071 0 : GNUNET_PQ_query_param_timestamp (&td->details.wire_out.execution_date),
1072 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.wire_out.wtid_raw),
1073 0 : GNUNET_PQ_query_param_auto_from_type (
1074 : &td->details.wire_out.wire_target_h_payto),
1075 0 : GNUNET_PQ_query_param_string (
1076 0 : td->details.wire_out.exchange_account_section),
1077 0 : TALER_PQ_query_param_amount (
1078 0 : pg->conn,
1079 : &td->details.wire_out.amount),
1080 : GNUNET_PQ_query_param_end
1081 : };
1082 :
1083 0 : PREPARE (pg,
1084 : "insert_into_table_wire_out",
1085 : "INSERT INTO wire_out"
1086 : "(wireout_uuid"
1087 : ",execution_date"
1088 : ",wtid_raw"
1089 : ",wire_target_h_payto"
1090 : ",exchange_account_section"
1091 : ",amount"
1092 : ") VALUES "
1093 : "($1, $2, $3, $4, $5, $6);");
1094 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1095 : "insert_into_table_wire_out",
1096 : params);
1097 : }
1098 :
1099 :
1100 : /**
1101 : * Function called with aggregation_tracking records to insert into table.
1102 : *
1103 : * @param pg plugin context
1104 : * @param td record to insert
1105 : */
1106 : static enum GNUNET_DB_QueryStatus
1107 0 : irbt_cb_table_aggregation_tracking (struct TALER_EXCHANGEDB_PostgresContext *pg,
1108 : const struct TALER_EXCHANGEDB_TableData *td)
1109 : {
1110 0 : struct GNUNET_PQ_QueryParam params[] = {
1111 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1112 0 : GNUNET_PQ_query_param_uint64 (
1113 : &td->details.aggregation_tracking.batch_deposit_serial_id),
1114 0 : GNUNET_PQ_query_param_auto_from_type (
1115 : &td->details.aggregation_tracking.wtid_raw),
1116 : GNUNET_PQ_query_param_end
1117 : };
1118 :
1119 0 : PREPARE (pg,
1120 : "insert_into_table_aggregation_tracking",
1121 : "INSERT INTO aggregation_tracking"
1122 : "(aggregation_serial_id"
1123 : ",batch_deposit_serial_id"
1124 : ",wtid_raw"
1125 : ") VALUES "
1126 : "($1, $2, $3);");
1127 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1128 : "insert_into_table_aggregation_tracking",
1129 : params);
1130 : }
1131 :
1132 :
1133 : /**
1134 : * Function called with wire_fee records to insert into table.
1135 : *
1136 : * @param pg plugin context
1137 : * @param td record to insert
1138 : */
1139 : static enum GNUNET_DB_QueryStatus
1140 0 : irbt_cb_table_wire_fee (struct TALER_EXCHANGEDB_PostgresContext *pg,
1141 : const struct TALER_EXCHANGEDB_TableData *td)
1142 : {
1143 0 : struct GNUNET_PQ_QueryParam params[] = {
1144 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1145 0 : GNUNET_PQ_query_param_string (td->details.wire_fee.wire_method),
1146 0 : GNUNET_PQ_query_param_timestamp (&td->details.wire_fee.start_date),
1147 0 : GNUNET_PQ_query_param_timestamp (&td->details.wire_fee.end_date),
1148 0 : TALER_PQ_query_param_amount (
1149 0 : pg->conn,
1150 : &td->details.wire_fee.fees.wire),
1151 0 : TALER_PQ_query_param_amount (
1152 0 : pg->conn,
1153 : &td->details.wire_fee.fees.closing),
1154 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.wire_fee.master_sig),
1155 : GNUNET_PQ_query_param_end
1156 : };
1157 :
1158 0 : PREPARE (pg,
1159 : "insert_into_table_wire_fee",
1160 : "INSERT INTO wire_fee"
1161 : "(wire_fee_serial"
1162 : ",wire_method"
1163 : ",start_date"
1164 : ",end_date"
1165 : ",wire_fee"
1166 : ",closing_fee"
1167 : ",master_sig"
1168 : ") VALUES "
1169 : "($1, $2, $3, $4, $5, $6, $7);");
1170 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1171 : "insert_into_table_wire_fee",
1172 : params);
1173 : }
1174 :
1175 :
1176 : /**
1177 : * Function called with wire_fee records to insert into table.
1178 : *
1179 : * @param pg plugin context
1180 : * @param td record to insert
1181 : */
1182 : static enum GNUNET_DB_QueryStatus
1183 0 : irbt_cb_table_global_fee (struct TALER_EXCHANGEDB_PostgresContext *pg,
1184 : const struct TALER_EXCHANGEDB_TableData *td)
1185 : {
1186 0 : struct GNUNET_PQ_QueryParam params[] = {
1187 0 : GNUNET_PQ_query_param_uint64 (
1188 : &td->serial),
1189 0 : GNUNET_PQ_query_param_timestamp (
1190 : &td->details.global_fee.start_date),
1191 0 : GNUNET_PQ_query_param_timestamp (
1192 : &td->details.global_fee.end_date),
1193 0 : TALER_PQ_query_param_amount (
1194 0 : pg->conn,
1195 : &td->details.global_fee.fees.history),
1196 0 : TALER_PQ_query_param_amount (
1197 0 : pg->conn,
1198 : &td->details.global_fee.fees.account),
1199 0 : TALER_PQ_query_param_amount (
1200 0 : pg->conn,
1201 : &td->details.global_fee.fees.purse),
1202 0 : GNUNET_PQ_query_param_relative_time (
1203 : &td->details.global_fee.purse_timeout),
1204 0 : GNUNET_PQ_query_param_relative_time (
1205 : &td->details.global_fee.history_expiration),
1206 0 : GNUNET_PQ_query_param_uint32 (
1207 : &td->details.global_fee.purse_account_limit),
1208 0 : GNUNET_PQ_query_param_auto_from_type (
1209 : &td->details.global_fee.master_sig),
1210 : GNUNET_PQ_query_param_end
1211 : };
1212 :
1213 0 : PREPARE (pg,
1214 : "insert_into_table_global_fee",
1215 : "INSERT INTO global_fee"
1216 : "(global_fee_serial"
1217 : ",start_date"
1218 : ",end_date"
1219 : ",history_fee"
1220 : ",account_fee"
1221 : ",purse_fee"
1222 : ",purse_timeout"
1223 : ",history_expiration"
1224 : ",purse_account_limit"
1225 : ",master_sig"
1226 : ") VALUES "
1227 : "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10);");
1228 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1229 : "insert_into_table_global_fee",
1230 : params);
1231 : }
1232 :
1233 :
1234 : /**
1235 : * Function called with recoup records to insert into table.
1236 : *
1237 : * @param pg plugin context
1238 : * @param td record to insert
1239 : */
1240 : static enum GNUNET_DB_QueryStatus
1241 0 : irbt_cb_table_recoup (struct TALER_EXCHANGEDB_PostgresContext *pg,
1242 : const struct TALER_EXCHANGEDB_TableData *td)
1243 : {
1244 0 : struct GNUNET_PQ_QueryParam params[] = {
1245 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1246 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.recoup.coin_sig),
1247 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.recoup.coin_blind),
1248 0 : TALER_PQ_query_param_amount (
1249 0 : pg->conn,
1250 : &td->details.recoup.amount),
1251 0 : GNUNET_PQ_query_param_timestamp (&td->details.recoup.timestamp),
1252 0 : GNUNET_PQ_query_param_auto_from_type (
1253 : &td->details.recoup.coin_pub),
1254 0 : GNUNET_PQ_query_param_uint64 (&td->details.recoup.withdraw_serial_id),
1255 : GNUNET_PQ_query_param_end
1256 : };
1257 :
1258 0 : PREPARE (pg,
1259 : "insert_into_table_recoup",
1260 : "INSERT INTO recoup"
1261 : "(recoup_uuid"
1262 : ",coin_sig"
1263 : ",coin_blind"
1264 : ",amount"
1265 : ",recoup_timestamp"
1266 : ",coin_pub"
1267 : ",withdraw_serial_id"
1268 : ") VALUES "
1269 : "($1, $2, $3, $4, $5, $6, $7);");
1270 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1271 : "insert_into_table_recoup",
1272 : params);
1273 : }
1274 :
1275 :
1276 : /**
1277 : * Function called with recoup_refresh records to insert into table.
1278 : *
1279 : * @param pg plugin context
1280 : * @param td record to insert
1281 : */
1282 : static enum GNUNET_DB_QueryStatus
1283 0 : irbt_cb_table_recoup_refresh (struct TALER_EXCHANGEDB_PostgresContext *pg,
1284 : const struct TALER_EXCHANGEDB_TableData *td)
1285 : {
1286 0 : struct GNUNET_PQ_QueryParam params[] = {
1287 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1288 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.recoup_refresh.coin_sig),
1289 0 : GNUNET_PQ_query_param_auto_from_type (
1290 : &td->details.recoup_refresh.coin_blind),
1291 0 : TALER_PQ_query_param_amount (
1292 0 : pg->conn,
1293 : &td->details.recoup_refresh.amount),
1294 0 : GNUNET_PQ_query_param_timestamp (&td->details.recoup_refresh.timestamp),
1295 0 : GNUNET_PQ_query_param_uint64 (&td->details.recoup_refresh.known_coin_id),
1296 0 : GNUNET_PQ_query_param_auto_from_type (
1297 : &td->details.recoup.coin_pub),
1298 0 : GNUNET_PQ_query_param_uint64 (&td->details.recoup_refresh.rrc_serial),
1299 : GNUNET_PQ_query_param_end
1300 : };
1301 :
1302 0 : PREPARE (pg,
1303 : "insert_into_table_recoup_refresh",
1304 : "INSERT INTO recoup_refresh"
1305 : "(recoup_refresh_uuid"
1306 : ",coin_sig"
1307 : ",coin_blind"
1308 : ",amount"
1309 : ",recoup_timestamp"
1310 : ",known_coin_id"
1311 : ",coin_pub"
1312 : ",rrc_serial"
1313 : ") VALUES "
1314 : "($1, $2, $3, $4, $5, $6, $7, $8);");
1315 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1316 : "insert_into_table_recoup_refresh",
1317 : params);
1318 : }
1319 :
1320 :
1321 : /**
1322 : * Function called with extensions records to insert into table.
1323 : *
1324 : * @param pg plugin context
1325 : * @param td record to insert
1326 : */
1327 : static enum GNUNET_DB_QueryStatus
1328 0 : irbt_cb_table_extensions (struct TALER_EXCHANGEDB_PostgresContext *pg,
1329 : const struct TALER_EXCHANGEDB_TableData *td)
1330 : {
1331 0 : struct GNUNET_PQ_QueryParam params[] = {
1332 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1333 0 : GNUNET_PQ_query_param_string (td->details.extensions.name),
1334 0 : NULL == td->details.extensions.manifest ?
1335 0 : GNUNET_PQ_query_param_null () :
1336 0 : GNUNET_PQ_query_param_string (td->details.extensions.manifest),
1337 : GNUNET_PQ_query_param_end
1338 : };
1339 :
1340 0 : PREPARE (pg,
1341 : "insert_into_table_extensions",
1342 : "INSERT INTO extensions"
1343 : "(extension_id"
1344 : ",name"
1345 : ",manifest"
1346 : ") VALUES "
1347 : "($1, $2, $3);");
1348 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1349 : "insert_into_table_extensions",
1350 : params);
1351 : }
1352 :
1353 :
1354 : /**
1355 : * Function called with policy_details records to insert into table.
1356 : *
1357 : * @param pg plugin context
1358 : * @param td record to insert
1359 : */
1360 : static enum GNUNET_DB_QueryStatus
1361 0 : irbt_cb_table_policy_details (struct TALER_EXCHANGEDB_PostgresContext *pg,
1362 : const struct TALER_EXCHANGEDB_TableData *td)
1363 : {
1364 0 : struct GNUNET_PQ_QueryParam params[] = {
1365 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1366 0 : GNUNET_PQ_query_param_auto_from_type (
1367 : &td->details.policy_details.hash_code),
1368 0 : (td->details.policy_details.no_policy_json)
1369 0 : ? GNUNET_PQ_query_param_null ()
1370 0 : : TALER_PQ_query_param_json (td->details.policy_details.policy_json),
1371 0 : TALER_PQ_query_param_amount (
1372 0 : pg->conn,
1373 : &td->details.policy_details.commitment),
1374 0 : TALER_PQ_query_param_amount (
1375 0 : pg->conn,
1376 : &td->details.policy_details.accumulated_total),
1377 0 : TALER_PQ_query_param_amount (
1378 0 : pg->conn,
1379 : &td->details.policy_details.fee),
1380 0 : TALER_PQ_query_param_amount (pg->conn,
1381 : &td->details.policy_details.transferable),
1382 0 : GNUNET_PQ_query_param_timestamp (&td->details.policy_details.deadline),
1383 0 : GNUNET_PQ_query_param_uint16 (
1384 : &td->details.policy_details.fulfillment_state),
1385 0 : (td->details.policy_details.no_fulfillment_id)
1386 0 : ? GNUNET_PQ_query_param_null ()
1387 0 : : GNUNET_PQ_query_param_uint64 (
1388 : &td->details.policy_details.fulfillment_id),
1389 : GNUNET_PQ_query_param_end
1390 : };
1391 :
1392 0 : PREPARE (pg,
1393 : "insert_into_table_policy_details",
1394 : "INSERT INTO policy_details"
1395 : "(policy_details_serial_id"
1396 : ",policy_hash_code"
1397 : ",policy_json"
1398 : ",deadline"
1399 : ",commitment"
1400 : ",accumulated_total"
1401 : ",fee"
1402 : ",transferable"
1403 : ",fulfillment_state"
1404 : ",fulfillment_id"
1405 : ") VALUES "
1406 : "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10);");
1407 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1408 : "insert_into_table_policy_details",
1409 : params);
1410 : }
1411 :
1412 :
1413 : /**
1414 : * Function called with policy_fulfillment records to insert into table.
1415 : *
1416 : * @param pg plugin context
1417 : * @param td record to insert
1418 : */
1419 : static enum GNUNET_DB_QueryStatus
1420 0 : irbt_cb_table_policy_fulfillments (struct TALER_EXCHANGEDB_PostgresContext *pg,
1421 : const struct TALER_EXCHANGEDB_TableData *td)
1422 : {
1423 0 : struct GNUNET_PQ_QueryParam params[] = {
1424 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1425 0 : GNUNET_PQ_query_param_timestamp (
1426 : &td->details.policy_fulfillments.fulfillment_timestamp),
1427 0 : (NULL == td->details.policy_fulfillments.fulfillment_proof)
1428 0 : ? GNUNET_PQ_query_param_null ()
1429 0 : : GNUNET_PQ_query_param_string (
1430 0 : td->details.policy_fulfillments.fulfillment_proof),
1431 0 : GNUNET_PQ_query_param_auto_from_type (
1432 : &td->details.policy_fulfillments.h_fulfillment_proof),
1433 0 : GNUNET_PQ_query_param_fixed_size (
1434 0 : td->details.policy_fulfillments.policy_hash_codes,
1435 0 : td->details.policy_fulfillments.policy_hash_codes_count),
1436 : GNUNET_PQ_query_param_end
1437 : };
1438 :
1439 0 : PREPARE (pg,
1440 : "insert_into_table_policy_fulfillments",
1441 : "INSERT INTO policy_fulfillments "
1442 : "(fulfillment_id"
1443 : ",fulfillment_timestamp"
1444 : ",fulfillment_proof"
1445 : ",h_fulfillment_proof"
1446 : ",policy_hash_codes"
1447 : ") VALUES "
1448 : "($1, $2, $3::TEXT::JSONB, $4, $5);");
1449 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1450 : "insert_into_table_policy_fulfillments",
1451 : params);
1452 : }
1453 :
1454 :
1455 : /**
1456 : * Function called with purse_requests records to insert into table.
1457 : *
1458 : * @param pg plugin context
1459 : * @param td record to insert
1460 : */
1461 : static enum GNUNET_DB_QueryStatus
1462 0 : irbt_cb_table_purse_requests (struct TALER_EXCHANGEDB_PostgresContext *pg,
1463 : const struct TALER_EXCHANGEDB_TableData *td)
1464 : {
1465 0 : struct GNUNET_PQ_QueryParam params[] = {
1466 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1467 0 : GNUNET_PQ_query_param_auto_from_type (
1468 : &td->details.purse_requests.purse_pub),
1469 0 : GNUNET_PQ_query_param_auto_from_type (
1470 : &td->details.purse_requests.merge_pub),
1471 0 : GNUNET_PQ_query_param_timestamp (
1472 : &td->details.purse_requests.purse_creation),
1473 0 : GNUNET_PQ_query_param_timestamp (
1474 : &td->details.purse_requests.purse_expiration),
1475 0 : GNUNET_PQ_query_param_auto_from_type (
1476 : &td->details.purse_requests.h_contract_terms),
1477 0 : GNUNET_PQ_query_param_uint32 (&td->details.purse_requests.age_limit),
1478 0 : GNUNET_PQ_query_param_uint32 (&td->details.purse_requests.flags),
1479 0 : TALER_PQ_query_param_amount (
1480 0 : pg->conn,
1481 : &td->details.purse_requests.amount_with_fee),
1482 0 : TALER_PQ_query_param_amount (
1483 0 : pg->conn,
1484 : &td->details.purse_requests.purse_fee),
1485 0 : GNUNET_PQ_query_param_auto_from_type (
1486 : &td->details.purse_requests.purse_sig),
1487 : GNUNET_PQ_query_param_end
1488 : };
1489 :
1490 0 : PREPARE (pg,
1491 : "insert_into_table_purse_requests",
1492 : "INSERT INTO purse_requests"
1493 : "(purse_requests_serial_id"
1494 : ",purse_pub"
1495 : ",merge_pub"
1496 : ",purse_creation"
1497 : ",purse_expiration"
1498 : ",h_contract_terms"
1499 : ",age_limit"
1500 : ",flags"
1501 : ",amount_with_fee"
1502 : ",purse_fee"
1503 : ",purse_sig"
1504 : ") VALUES "
1505 : "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11);");
1506 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1507 : "insert_into_table_purse_requests",
1508 : params);
1509 : }
1510 :
1511 :
1512 : /**
1513 : * Function called with purse_decision records to insert into table.
1514 : *
1515 : * @param pg plugin context
1516 : * @param td record to insert
1517 : */
1518 : static enum GNUNET_DB_QueryStatus
1519 0 : irbt_cb_table_purse_decision (struct TALER_EXCHANGEDB_PostgresContext *pg,
1520 : const struct TALER_EXCHANGEDB_TableData *td)
1521 : {
1522 0 : struct GNUNET_PQ_QueryParam params[] = {
1523 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1524 0 : GNUNET_PQ_query_param_auto_from_type (
1525 : &td->details.purse_decision.purse_pub),
1526 0 : GNUNET_PQ_query_param_timestamp (
1527 : &td->details.purse_decision.action_timestamp),
1528 0 : GNUNET_PQ_query_param_bool (
1529 0 : td->details.purse_decision.refunded),
1530 : GNUNET_PQ_query_param_end
1531 : };
1532 :
1533 0 : PREPARE (pg,
1534 : "insert_into_table_purse_refunds",
1535 : "INSERT INTO purse_refunds"
1536 : "(purse_refunds_serial_id"
1537 : ",purse_pub"
1538 : ",action_timestamp"
1539 : ",refunded"
1540 : ") VALUES "
1541 : "($1, $2, $3, $4);");
1542 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1543 : "insert_into_table_purse_decision",
1544 : params);
1545 : }
1546 :
1547 :
1548 : /**
1549 : * Function called with purse_merges records to insert into table.
1550 : *
1551 : * @param pg plugin context
1552 : * @param td record to insert
1553 : */
1554 : static enum GNUNET_DB_QueryStatus
1555 0 : irbt_cb_table_purse_merges (struct TALER_EXCHANGEDB_PostgresContext *pg,
1556 : const struct TALER_EXCHANGEDB_TableData *td)
1557 : {
1558 0 : struct GNUNET_PQ_QueryParam params[] = {
1559 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1560 0 : GNUNET_PQ_query_param_uint64 (&td->details.purse_merges.partner_serial_id),
1561 0 : GNUNET_PQ_query_param_auto_from_type (
1562 : &td->details.purse_merges.reserve_pub),
1563 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.purse_merges.purse_pub),
1564 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.purse_merges.merge_sig),
1565 0 : GNUNET_PQ_query_param_timestamp (&td->details.purse_merges.merge_timestamp),
1566 : GNUNET_PQ_query_param_end
1567 : };
1568 :
1569 0 : PREPARE (pg,
1570 : "insert_into_table_purse_merges",
1571 : "INSERT INTO purse_merges"
1572 : "(purse_merge_request_serial_id"
1573 : ",partner_serial_id"
1574 : ",reserve_pub"
1575 : ",purse_pub"
1576 : ",merge_sig"
1577 : ",merge_timestamp"
1578 : ") VALUES "
1579 : "($1, $2, $3, $4, $5, $6);");
1580 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1581 : "insert_into_table_purse_merges",
1582 : params);
1583 : }
1584 :
1585 :
1586 : /**
1587 : * Function called with purse_deposits records to insert into table.
1588 : *
1589 : * @param pg plugin context
1590 : * @param td record to insert
1591 : */
1592 : static enum GNUNET_DB_QueryStatus
1593 0 : irbt_cb_table_purse_deposits (struct TALER_EXCHANGEDB_PostgresContext *pg,
1594 : const struct TALER_EXCHANGEDB_TableData *td)
1595 : {
1596 0 : struct GNUNET_PQ_QueryParam params[] = {
1597 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1598 0 : GNUNET_PQ_query_param_uint64 (
1599 : &td->details.purse_deposits.partner_serial_id),
1600 0 : GNUNET_PQ_query_param_auto_from_type (
1601 : &td->details.purse_deposits.purse_pub),
1602 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.purse_deposits.coin_pub),
1603 0 : TALER_PQ_query_param_amount (
1604 0 : pg->conn,
1605 : &td->details.purse_deposits.amount_with_fee),
1606 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.purse_deposits.coin_sig),
1607 : GNUNET_PQ_query_param_end
1608 : };
1609 :
1610 0 : PREPARE (pg,
1611 : "insert_into_table_purse_deposits",
1612 : "INSERT INTO purse_deposits"
1613 : "(purse_deposit_serial_id"
1614 : ",partner_serial_id"
1615 : ",purse_pub"
1616 : ",coin_pub"
1617 : ",amount_with_fee"
1618 : ",coin_sig"
1619 : ") VALUES "
1620 : "($1, $2, $3, $4, $5, $6);");
1621 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1622 : "insert_into_table_purse_deposits",
1623 : params);
1624 : }
1625 :
1626 :
1627 : /**
1628 : x * Function called with account_mergers records to insert into table.
1629 : *
1630 : * @param pg plugin context
1631 : * @param td record to insert
1632 : */
1633 : static enum GNUNET_DB_QueryStatus
1634 0 : irbt_cb_table_account_mergers (struct TALER_EXCHANGEDB_PostgresContext *pg,
1635 : const struct TALER_EXCHANGEDB_TableData *td)
1636 : {
1637 0 : struct GNUNET_PQ_QueryParam params[] = {
1638 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1639 0 : GNUNET_PQ_query_param_auto_from_type (
1640 : &td->details.account_merges.reserve_pub),
1641 0 : GNUNET_PQ_query_param_auto_from_type (
1642 : &td->details.account_merges.reserve_sig),
1643 0 : GNUNET_PQ_query_param_auto_from_type (
1644 : &td->details.account_merges.purse_pub),
1645 0 : GNUNET_PQ_query_param_auto_from_type (
1646 : &td->details.account_merges.wallet_h_payto),
1647 : GNUNET_PQ_query_param_end
1648 : };
1649 :
1650 0 : PREPARE (pg,
1651 : "insert_into_table_account_merges",
1652 : "INSERT INTO account_merges"
1653 : "(account_merge_request_serial_id"
1654 : ",reserve_pub"
1655 : ",reserve_sig"
1656 : ",purse_pub"
1657 : ",wallet_h_payto"
1658 : ") VALUES "
1659 : "($1, $2, $3, $4, $5);");
1660 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1661 : "insert_into_table_account_merges",
1662 : params);
1663 : }
1664 :
1665 :
1666 : /**
1667 : * Function called with history_requests records to insert into table.
1668 : *
1669 : * @param pg plugin context
1670 : * @param td record to insert
1671 : */
1672 : static enum GNUNET_DB_QueryStatus
1673 0 : irbt_cb_table_history_requests (struct TALER_EXCHANGEDB_PostgresContext *pg,
1674 : const struct TALER_EXCHANGEDB_TableData *td)
1675 : {
1676 0 : struct GNUNET_PQ_QueryParam params[] = {
1677 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1678 0 : GNUNET_PQ_query_param_auto_from_type (
1679 : &td->details.history_requests.reserve_pub),
1680 0 : GNUNET_PQ_query_param_timestamp (
1681 : &td->details.history_requests.request_timestamp),
1682 0 : GNUNET_PQ_query_param_auto_from_type (
1683 : &td->details.history_requests.reserve_sig),
1684 0 : TALER_PQ_query_param_amount (
1685 0 : pg->conn,
1686 : &td->details.history_requests.history_fee),
1687 : GNUNET_PQ_query_param_end
1688 : };
1689 :
1690 0 : PREPARE (pg,
1691 : "insert_into_table_history_requests",
1692 : "INSERT INTO history_requests"
1693 : "(history_request_serial_id"
1694 : ",reserve_pub"
1695 : ",request_timestamp"
1696 : ",reserve_sig"
1697 : ",history_fee"
1698 : ") VALUES "
1699 : "($1, $2, $3, $4, $5);");
1700 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1701 : "insert_into_table_history_requests",
1702 : params);
1703 : }
1704 :
1705 :
1706 : /**
1707 : * Function called with close_requests records to insert into table.
1708 : *
1709 : * @param pg plugin context
1710 : * @param td record to insert
1711 : */
1712 : static enum GNUNET_DB_QueryStatus
1713 0 : irbt_cb_table_close_requests (struct TALER_EXCHANGEDB_PostgresContext *pg,
1714 : const struct TALER_EXCHANGEDB_TableData *td)
1715 : {
1716 0 : struct GNUNET_PQ_QueryParam params[] = {
1717 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1718 0 : GNUNET_PQ_query_param_auto_from_type (
1719 : &td->details.close_requests.reserve_pub),
1720 0 : GNUNET_PQ_query_param_timestamp (
1721 : &td->details.close_requests.close_timestamp),
1722 0 : GNUNET_PQ_query_param_auto_from_type (
1723 : &td->details.close_requests.reserve_sig),
1724 0 : TALER_PQ_query_param_amount (
1725 0 : pg->conn,
1726 : &td->details.close_requests.close),
1727 0 : TALER_PQ_query_param_amount (
1728 0 : pg->conn,
1729 : &td->details.close_requests.close_fee),
1730 0 : GNUNET_PQ_query_param_string (
1731 0 : td->details.close_requests.payto_uri.full_payto),
1732 : GNUNET_PQ_query_param_end
1733 : };
1734 :
1735 0 : PREPARE (pg,
1736 : "insert_into_table_close_requests",
1737 : "INSERT INTO close_requests"
1738 : "(close_request_serial_id"
1739 : ",reserve_pub"
1740 : ",close_timestamp"
1741 : ",reserve_sig"
1742 : ",close"
1743 : ",close_fee"
1744 : ",payto_uri"
1745 : ") VALUES "
1746 : "($1, $2, $3, $4, $5, $6, $7);");
1747 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1748 : "insert_into_table_close_requests",
1749 : params);
1750 : }
1751 :
1752 :
1753 : /**
1754 : * Function called with wads_out records to insert into table.
1755 : *
1756 : * @param pg plugin context
1757 : * @param td record to insert
1758 : */
1759 : static enum GNUNET_DB_QueryStatus
1760 0 : irbt_cb_table_wads_out (struct TALER_EXCHANGEDB_PostgresContext *pg,
1761 : const struct TALER_EXCHANGEDB_TableData *td)
1762 : {
1763 0 : struct GNUNET_PQ_QueryParam params[] = {
1764 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1765 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.wads_out.wad_id),
1766 0 : GNUNET_PQ_query_param_uint64 (&td->details.wads_out.partner_serial_id),
1767 0 : TALER_PQ_query_param_amount (
1768 0 : pg->conn,
1769 : &td->details.wads_out.amount),
1770 0 : GNUNET_PQ_query_param_timestamp (&td->details.wads_out.execution_time),
1771 : GNUNET_PQ_query_param_end
1772 : };
1773 :
1774 0 : PREPARE (pg,
1775 : "insert_into_table_wads_out",
1776 : "INSERT INTO wads_out"
1777 : "(wad_out_serial_id"
1778 : ",wad_id"
1779 : ",partner_serial_id"
1780 : ",amount"
1781 : ",execution_time"
1782 : ") VALUES "
1783 : "($1, $2, $3, $4, $5);");
1784 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1785 : "insert_into_table_wads_out",
1786 : params);
1787 : }
1788 :
1789 :
1790 : /**
1791 : * Function called with wads_out_entries records to insert into table.
1792 : *
1793 : * @param pg plugin context
1794 : * @param td record to insert
1795 : */
1796 : static enum GNUNET_DB_QueryStatus
1797 0 : irbt_cb_table_wads_out_entries (struct TALER_EXCHANGEDB_PostgresContext *pg,
1798 : const struct TALER_EXCHANGEDB_TableData *td)
1799 : {
1800 0 : struct GNUNET_PQ_QueryParam params[] = {
1801 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1802 0 : GNUNET_PQ_query_param_uint64 (
1803 : &td->details.wads_out_entries.wad_out_serial_id),
1804 0 : GNUNET_PQ_query_param_auto_from_type (
1805 : &td->details.wads_out_entries.reserve_pub),
1806 0 : GNUNET_PQ_query_param_auto_from_type (
1807 : &td->details.wads_out_entries.purse_pub),
1808 0 : GNUNET_PQ_query_param_auto_from_type (
1809 : &td->details.wads_out_entries.h_contract),
1810 0 : GNUNET_PQ_query_param_timestamp (
1811 : &td->details.wads_out_entries.purse_expiration),
1812 0 : GNUNET_PQ_query_param_timestamp (
1813 : &td->details.wads_out_entries.merge_timestamp),
1814 0 : TALER_PQ_query_param_amount (
1815 0 : pg->conn,
1816 : &td->details.wads_out_entries.amount_with_fee),
1817 0 : TALER_PQ_query_param_amount (
1818 0 : pg->conn,
1819 : &td->details.wads_out_entries.wad_fee),
1820 0 : TALER_PQ_query_param_amount (
1821 0 : pg->conn,
1822 : &td->details.wads_out_entries.deposit_fees),
1823 0 : GNUNET_PQ_query_param_auto_from_type (
1824 : &td->details.wads_out_entries.reserve_sig),
1825 0 : GNUNET_PQ_query_param_auto_from_type (
1826 : &td->details.wads_out_entries.purse_sig),
1827 : GNUNET_PQ_query_param_end
1828 : };
1829 :
1830 0 : PREPARE (pg,
1831 : "insert_into_table_wad_out_entries",
1832 : "INSERT INTO wad_out_entries"
1833 : "(wad_out_entry_serial_id"
1834 : ",wad_out_serial_id"
1835 : ",reserve_pub"
1836 : ",purse_pub"
1837 : ",h_contract"
1838 : ",purse_expiration"
1839 : ",merge_timestamp"
1840 : ",amount_with_fee"
1841 : ",wad_fee"
1842 : ",deposit_fees"
1843 : ",reserve_sig"
1844 : ",purse_sig"
1845 : ") VALUES "
1846 : "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12);");
1847 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1848 : "insert_into_table_wads_out_entries",
1849 : params);
1850 : }
1851 :
1852 :
1853 : /**
1854 : * Function called with wads_in records to insert into table.
1855 : *
1856 : * @param pg plugin context
1857 : * @param td record to insert
1858 : */
1859 : static enum GNUNET_DB_QueryStatus
1860 0 : irbt_cb_table_wads_in (struct TALER_EXCHANGEDB_PostgresContext *pg,
1861 : const struct TALER_EXCHANGEDB_TableData *td)
1862 : {
1863 0 : struct GNUNET_PQ_QueryParam params[] = {
1864 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1865 0 : GNUNET_PQ_query_param_auto_from_type (&td->details.wads_in.wad_id),
1866 0 : GNUNET_PQ_query_param_string (td->details.wads_in.origin_exchange_url),
1867 0 : TALER_PQ_query_param_amount (
1868 0 : pg->conn,
1869 : &td->details.wads_in.amount),
1870 0 : GNUNET_PQ_query_param_timestamp (&td->details.wads_in.arrival_time),
1871 : GNUNET_PQ_query_param_end
1872 : };
1873 :
1874 0 : PREPARE (pg,
1875 : "insert_into_table_wads_in",
1876 : "INSERT INTO wads_in"
1877 : "(wad_in_serial_id"
1878 : ",wad_id"
1879 : ",origin_exchange_url"
1880 : ",amount"
1881 : ",arrival_time"
1882 : ") VALUES "
1883 : "($1, $2, $3, $4, $5);");
1884 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1885 : "insert_into_table_wads_in",
1886 : params);
1887 : }
1888 :
1889 :
1890 : /**
1891 : * Function called with wads_in_entries records to insert into table.
1892 : *
1893 : * @param pg plugin context
1894 : * @param td record to insert
1895 : */
1896 : static enum GNUNET_DB_QueryStatus
1897 0 : irbt_cb_table_wads_in_entries (struct TALER_EXCHANGEDB_PostgresContext *pg,
1898 : const struct TALER_EXCHANGEDB_TableData *td)
1899 : {
1900 0 : struct GNUNET_PQ_QueryParam params[] = {
1901 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1902 0 : GNUNET_PQ_query_param_auto_from_type (
1903 : &td->details.wads_in_entries.reserve_pub),
1904 0 : GNUNET_PQ_query_param_auto_from_type (
1905 : &td->details.wads_in_entries.purse_pub),
1906 0 : GNUNET_PQ_query_param_auto_from_type (
1907 : &td->details.wads_in_entries.h_contract),
1908 0 : GNUNET_PQ_query_param_timestamp (
1909 : &td->details.wads_in_entries.purse_expiration),
1910 0 : GNUNET_PQ_query_param_timestamp (
1911 : &td->details.wads_in_entries.merge_timestamp),
1912 0 : TALER_PQ_query_param_amount (
1913 0 : pg->conn,
1914 : &td->details.wads_in_entries.amount_with_fee),
1915 0 : TALER_PQ_query_param_amount (
1916 0 : pg->conn,
1917 : &td->details.wads_in_entries.wad_fee),
1918 0 : TALER_PQ_query_param_amount (
1919 0 : pg->conn,
1920 : &td->details.wads_in_entries.deposit_fees),
1921 0 : GNUNET_PQ_query_param_auto_from_type (
1922 : &td->details.wads_in_entries.reserve_sig),
1923 0 : GNUNET_PQ_query_param_auto_from_type (
1924 : &td->details.wads_in_entries.purse_sig),
1925 : GNUNET_PQ_query_param_end
1926 : };
1927 :
1928 0 : PREPARE (pg,
1929 : "insert_into_table_wad_in_entries",
1930 : "INSERT INTO wad_in_entries"
1931 : "(wad_in_entry_serial_id"
1932 : ",wad_in_serial_id"
1933 : ",reserve_pub"
1934 : ",purse_pub"
1935 : ",h_contract"
1936 : ",purse_expiration"
1937 : ",merge_timestamp"
1938 : ",amount_with_fee"
1939 : ",wad_fee"
1940 : ",deposit_fees"
1941 : ",reserve_sig"
1942 : ",purse_sig"
1943 : ") VALUES "
1944 : "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12);");
1945 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1946 : "insert_into_table_wads_in_entries",
1947 : params);
1948 : }
1949 :
1950 :
1951 : /**
1952 : * Function called with profit_drains records to insert into table.
1953 : *
1954 : * @param pg plugin context
1955 : * @param td record to insert
1956 : */
1957 : static enum GNUNET_DB_QueryStatus
1958 0 : irbt_cb_table_profit_drains (struct TALER_EXCHANGEDB_PostgresContext *pg,
1959 : const struct TALER_EXCHANGEDB_TableData *td)
1960 : {
1961 0 : struct GNUNET_PQ_QueryParam params[] = {
1962 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
1963 0 : GNUNET_PQ_query_param_auto_from_type (
1964 : &td->details.profit_drains.wtid),
1965 0 : GNUNET_PQ_query_param_string (
1966 0 : td->details.profit_drains.account_section),
1967 0 : GNUNET_PQ_query_param_string (
1968 0 : td->details.profit_drains.payto_uri.full_payto),
1969 0 : GNUNET_PQ_query_param_timestamp (
1970 : &td->details.profit_drains.trigger_date),
1971 0 : TALER_PQ_query_param_amount (
1972 0 : pg->conn,
1973 : &td->details.profit_drains.amount),
1974 0 : GNUNET_PQ_query_param_auto_from_type (
1975 : &td->details.profit_drains.master_sig),
1976 : GNUNET_PQ_query_param_end
1977 : };
1978 :
1979 0 : PREPARE (pg,
1980 : "insert_into_table_profit_drains",
1981 : "INSERT INTO profit_drains"
1982 : "(profit_drain_serial_id"
1983 : ",wtid"
1984 : ",account_section"
1985 : ",payto_uri"
1986 : ",trigger_date"
1987 : ",amount"
1988 : ",master_sig"
1989 : ") VALUES "
1990 : "($1, $2, $3, $4, $5, $6, $7);");
1991 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
1992 : "insert_into_table_profit_drains",
1993 : params);
1994 : }
1995 :
1996 :
1997 : /**
1998 : * Function called with aml_staff records to insert into table.
1999 : *
2000 : * @param pg plugin context
2001 : * @param td record to insert
2002 : */
2003 : static enum GNUNET_DB_QueryStatus
2004 0 : irbt_cb_table_aml_staff (struct TALER_EXCHANGEDB_PostgresContext *pg,
2005 : const struct TALER_EXCHANGEDB_TableData *td)
2006 : {
2007 0 : struct GNUNET_PQ_QueryParam params[] = {
2008 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
2009 0 : GNUNET_PQ_query_param_auto_from_type (
2010 : &td->details.aml_staff.decider_pub),
2011 0 : GNUNET_PQ_query_param_auto_from_type (
2012 : &td->details.aml_staff.master_sig),
2013 0 : GNUNET_PQ_query_param_string (
2014 0 : td->details.aml_staff.decider_name),
2015 0 : GNUNET_PQ_query_param_bool (
2016 0 : td->details.aml_staff.is_active),
2017 0 : GNUNET_PQ_query_param_bool (
2018 0 : td->details.aml_staff.read_only),
2019 0 : GNUNET_PQ_query_param_timestamp (
2020 : &td->details.aml_staff.last_change),
2021 : GNUNET_PQ_query_param_end
2022 : };
2023 :
2024 0 : PREPARE (pg,
2025 : "insert_into_table_aml_staff",
2026 : "INSERT INTO aml_staff"
2027 : "(aml_staff_uuid"
2028 : ",decider_pub"
2029 : ",master_sig"
2030 : ",decider_name"
2031 : ",is_active"
2032 : ",read_only"
2033 : ",last_change"
2034 : ") VALUES "
2035 : "($1, $2, $3, $4, $5, $6, $7);");
2036 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
2037 : "insert_into_table_aml_staff",
2038 : params);
2039 : }
2040 :
2041 :
2042 : /**
2043 : * Function called with kyc_attributes records to insert into table.
2044 : *
2045 : * @param pg plugin context
2046 : * @param td record to insert
2047 : */
2048 : static enum GNUNET_DB_QueryStatus
2049 0 : irbt_cb_table_kyc_attributes (struct TALER_EXCHANGEDB_PostgresContext *pg,
2050 : const struct TALER_EXCHANGEDB_TableData *td)
2051 : {
2052 0 : struct GNUNET_PQ_QueryParam params[] = {
2053 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
2054 0 : GNUNET_PQ_query_param_auto_from_type (
2055 : &td->details.kyc_attributes.h_payto),
2056 0 : GNUNET_PQ_query_param_uint64 (
2057 : &td->details.kyc_attributes.legitimization_serial),
2058 0 : GNUNET_PQ_query_param_timestamp (
2059 : &td->details.kyc_attributes.collection_time),
2060 0 : GNUNET_PQ_query_param_timestamp (
2061 : &td->details.kyc_attributes.expiration_time),
2062 0 : GNUNET_PQ_query_param_uint64 (
2063 : &td->details.kyc_attributes.trigger_outcome_serial),
2064 0 : GNUNET_PQ_query_param_fixed_size (
2065 0 : &td->details.kyc_attributes.encrypted_attributes,
2066 0 : td->details.kyc_attributes.encrypted_attributes_size),
2067 : GNUNET_PQ_query_param_end
2068 : };
2069 :
2070 0 : PREPARE (pg,
2071 : "insert_into_table_kyc_attributes",
2072 : "INSERT INTO kyc_attributes"
2073 : "(kyc_attributes_serial_id"
2074 : ",h_payto"
2075 : ",legitimization_serial"
2076 : ",collection_time"
2077 : ",expiration_time"
2078 : ",trigger_outcome_serial"
2079 : ",encrypted_attributes"
2080 : ") VALUES "
2081 : "($1, $2, $3, $4, $5, $6, $7);");
2082 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
2083 : "insert_into_table_kyc_attributes",
2084 : params);
2085 : }
2086 :
2087 :
2088 : /**
2089 : * Function called with aml_history records to insert into table.
2090 : *
2091 : * @param pg plugin context
2092 : * @param td record to insert
2093 : */
2094 : static enum GNUNET_DB_QueryStatus
2095 0 : irbt_cb_table_aml_history (struct TALER_EXCHANGEDB_PostgresContext *pg,
2096 : const struct TALER_EXCHANGEDB_TableData *td)
2097 : {
2098 0 : struct GNUNET_PQ_QueryParam params[] = {
2099 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
2100 0 : GNUNET_PQ_query_param_auto_from_type (
2101 : &td->details.aml_history.h_payto),
2102 0 : GNUNET_PQ_query_param_uint64 (
2103 : &td->details.aml_history.outcome_serial_id),
2104 0 : GNUNET_PQ_query_param_string (
2105 0 : td->details.aml_history.justification),
2106 0 : GNUNET_PQ_query_param_auto_from_type (
2107 : &td->details.aml_history.decider_pub),
2108 0 : GNUNET_PQ_query_param_auto_from_type (
2109 : &td->details.aml_history.decider_sig),
2110 : GNUNET_PQ_query_param_end
2111 : };
2112 :
2113 0 : PREPARE (pg,
2114 : "insert_into_table_aml_history",
2115 : "INSERT INTO aml_history"
2116 : "(aml_history_serial_id"
2117 : ",h_payto"
2118 : ",outcome_serial_id"
2119 : ",justification"
2120 : ",decider_pub"
2121 : ",decider_sig"
2122 : ") VALUES "
2123 : "($1, $2, $3, $4, $5, $6);");
2124 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
2125 : "insert_into_table_aml_history",
2126 : params);
2127 : }
2128 :
2129 :
2130 : /**
2131 : * Function called with kyc_event records to insert into table.
2132 : *
2133 : * @param pg plugin context
2134 : * @param td record to insert
2135 : */
2136 : static enum GNUNET_DB_QueryStatus
2137 0 : irbt_cb_table_kyc_events (struct TALER_EXCHANGEDB_PostgresContext *pg,
2138 : const struct TALER_EXCHANGEDB_TableData *td)
2139 : {
2140 0 : struct GNUNET_PQ_QueryParam params[] = {
2141 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
2142 0 : GNUNET_PQ_query_param_timestamp (
2143 : &td->details.kyc_events.event_timestamp),
2144 0 : GNUNET_PQ_query_param_string (
2145 0 : td->details.kyc_events.event_type),
2146 : GNUNET_PQ_query_param_end
2147 : };
2148 :
2149 0 : PREPARE (pg,
2150 : "insert_into_table_kyc_events",
2151 : "INSERT INTO kyc_events"
2152 : "(kyc_event_serial_id"
2153 : ",event_timestamp"
2154 : ",event_type"
2155 : ") VALUES "
2156 : "($1, $2, $3);");
2157 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
2158 : "insert_into_table_kyc_events",
2159 : params);
2160 : }
2161 :
2162 :
2163 : /**
2164 : * Function called with purse_deletion records to insert into table.
2165 : *
2166 : * @param pg plugin context
2167 : * @param td record to insert
2168 : */
2169 : static enum GNUNET_DB_QueryStatus
2170 0 : irbt_cb_table_purse_deletion (struct TALER_EXCHANGEDB_PostgresContext *pg,
2171 : const struct TALER_EXCHANGEDB_TableData *td)
2172 : {
2173 0 : struct GNUNET_PQ_QueryParam params[] = {
2174 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
2175 0 : GNUNET_PQ_query_param_auto_from_type (
2176 : &td->details.purse_deletion.purse_pub),
2177 0 : GNUNET_PQ_query_param_auto_from_type (
2178 : &td->details.purse_deletion.purse_sig),
2179 : GNUNET_PQ_query_param_end
2180 : };
2181 :
2182 0 : PREPARE (pg,
2183 : "insert_into_table_purse_deletion",
2184 : "INSERT INTO purse_deletion"
2185 : "(purse_deletion_serial_id"
2186 : ",purse_pub"
2187 : ",purse_sig"
2188 : ") VALUES "
2189 : "($1, $2, $3);");
2190 0 : return GNUNET_PQ_eval_prepared_non_select (pg->conn,
2191 : "insert_into_table_purse_deletion",
2192 : params);
2193 : }
2194 :
2195 :
2196 : /**
2197 : * Function called with withdraw records to insert into table.
2198 : *
2199 : * @param pg plugin context
2200 : * @param td record to insert
2201 : */
2202 : static enum GNUNET_DB_QueryStatus
2203 0 : irbt_cb_table_withdraw (
2204 : struct TALER_EXCHANGEDB_PostgresContext *pg,
2205 : const struct TALER_EXCHANGEDB_TableData *td)
2206 : {
2207 0 : struct GNUNET_PQ_QueryParam params[] = {
2208 0 : GNUNET_PQ_query_param_uint64 (&td->serial),
2209 0 : GNUNET_PQ_query_param_auto_from_type (
2210 : &td->details.withdraw.planchets_h),
2211 0 : GNUNET_PQ_query_param_timestamp (
2212 : &td->details.withdraw.execution_date),
2213 0 : TALER_PQ_query_param_amount (
2214 0 : pg->conn,
2215 : &td->details.withdraw.amount_with_fee),
2216 0 : GNUNET_PQ_query_param_auto_from_type (
2217 : &td->details.withdraw.reserve_pub),
2218 0 : GNUNET_PQ_query_param_auto_from_type (
2219 : &td->details.withdraw.reserve_sig),
2220 0 : td->details.withdraw.age_proof_required
2221 0 : ? GNUNET_PQ_query_param_uint16 (
2222 : &td->details.withdraw.max_age)
2223 0 : : GNUNET_PQ_query_param_null (),
2224 0 : td->details.withdraw.age_proof_required
2225 0 : ? GNUNET_PQ_query_param_uint16 (
2226 : &td->details.withdraw.noreveal_index)
2227 0 : : GNUNET_PQ_query_param_null (),
2228 0 : td->details.withdraw.age_proof_required
2229 0 : ? GNUNET_PQ_query_param_auto_from_type (
2230 : &td->details.withdraw.selected_h)
2231 0 : : GNUNET_PQ_query_param_null (),
2232 0 : td->details.withdraw.no_blinding_seed
2233 0 : ? GNUNET_PQ_query_param_null ()
2234 0 : : GNUNET_PQ_query_param_auto_from_type (
2235 : &td->details.withdraw.blinding_seed),
2236 0 : (0 < td->details.withdraw.num_cs_r_values)
2237 0 : ? TALER_PQ_query_param_array_cs_r_pub (
2238 0 : td->details.withdraw.num_cs_r_values,
2239 0 : td->details.withdraw.cs_r_values,
2240 : pg->conn)
2241 0 : : GNUNET_PQ_query_param_null (),
2242 0 : (0 < td->details.withdraw.num_cs_r_values)
2243 0 : ? GNUNET_PQ_query_param_uint64 (
2244 : &td->details.withdraw.cs_r_choices)
2245 0 : : GNUNET_PQ_query_param_null (),
2246 0 : GNUNET_PQ_query_param_array_uint64 (
2247 0 : td->details.withdraw.num_coins,
2248 0 : td->details.withdraw.denom_serials,
2249 : pg->conn),
2250 0 : TALER_PQ_query_param_array_blinded_denom_sig (
2251 0 : td->details.withdraw.num_coins,
2252 0 : td->details.withdraw.denom_sigs,
2253 : pg->conn),
2254 : GNUNET_PQ_query_param_end
2255 : };
2256 : enum GNUNET_DB_QueryStatus qs;
2257 :
2258 0 : PREPARE (pg,
2259 : "insert_into_table_withdraw",
2260 : "INSERT INTO withdraw"
2261 : "(withdraw_id"
2262 : ",planchets_h"
2263 : ",execution_date"
2264 : ",amount_with_fee"
2265 : ",reserve_pub"
2266 : ",reserve_sig"
2267 : ",max_age"
2268 : ",noreveal_index"
2269 : ",selected_h"
2270 : ",blinding_seed"
2271 : ",cs_r_values"
2272 : ",cs_r_choices"
2273 : ",denom_serials"
2274 : ",denom_sigs"
2275 : ") VALUES "
2276 : "($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14);");
2277 0 : qs = GNUNET_PQ_eval_prepared_non_select (pg->conn,
2278 : "insert_into_table_withdraw",
2279 : params);
2280 0 : GNUNET_PQ_cleanup_query_params_closures (params);
2281 0 : return qs;
2282 : }
2283 :
2284 :
2285 : enum GNUNET_DB_QueryStatus
2286 0 : TALER_EXCHANGEDB_insert_records_by_table (struct
2287 : TALER_EXCHANGEDB_PostgresContext *pg,
2288 : const struct
2289 : TALER_EXCHANGEDB_TableData *td)
2290 : {
2291 0 : InsertRecordCallback rh = NULL;
2292 :
2293 0 : switch (td->table)
2294 : {
2295 0 : case TALER_EXCHANGEDB_RT_DENOMINATIONS:
2296 0 : rh = &irbt_cb_table_denominations;
2297 0 : break;
2298 0 : case TALER_EXCHANGEDB_RT_DENOMINATION_REVOCATIONS:
2299 0 : rh = &irbt_cb_table_denomination_revocations;
2300 0 : break;
2301 0 : case TALER_EXCHANGEDB_RT_WIRE_TARGETS:
2302 0 : rh = &irbt_cb_table_wire_targets;
2303 0 : break;
2304 0 : case TALER_EXCHANGEDB_RT_KYC_TARGETS:
2305 0 : rh = &irbt_cb_table_kyc_targets;
2306 0 : break;
2307 0 : case TALER_EXCHANGEDB_RT_RESERVES:
2308 0 : rh = &irbt_cb_table_reserves;
2309 0 : break;
2310 0 : case TALER_EXCHANGEDB_RT_RESERVES_IN:
2311 0 : rh = &irbt_cb_table_reserves_in;
2312 0 : break;
2313 0 : case TALER_EXCHANGEDB_RT_KYCAUTHS_IN:
2314 0 : rh = &irbt_cb_table_kycauths_in;
2315 0 : break;
2316 0 : case TALER_EXCHANGEDB_RT_RESERVES_CLOSE:
2317 0 : rh = &irbt_cb_table_reserves_close;
2318 0 : break;
2319 0 : case TALER_EXCHANGEDB_RT_RESERVES_OPEN_REQUESTS:
2320 0 : rh = &irbt_cb_table_reserves_open_requests;
2321 0 : break;
2322 0 : case TALER_EXCHANGEDB_RT_RESERVES_OPEN_DEPOSITS:
2323 0 : rh = &irbt_cb_table_reserves_open_deposits;
2324 0 : break;
2325 0 : case TALER_EXCHANGEDB_RT_AUDITORS:
2326 0 : rh = &irbt_cb_table_auditors;
2327 0 : break;
2328 0 : case TALER_EXCHANGEDB_RT_AUDITOR_DENOM_SIGS:
2329 0 : rh = &irbt_cb_table_auditor_denom_sigs;
2330 0 : break;
2331 0 : case TALER_EXCHANGEDB_RT_EXCHANGE_SIGN_KEYS:
2332 0 : rh = &irbt_cb_table_exchange_sign_keys;
2333 0 : break;
2334 0 : case TALER_EXCHANGEDB_RT_SIGNKEY_REVOCATIONS:
2335 0 : rh = &irbt_cb_table_signkey_revocations;
2336 0 : break;
2337 0 : case TALER_EXCHANGEDB_RT_KNOWN_COINS:
2338 0 : rh = &irbt_cb_table_known_coins;
2339 0 : break;
2340 0 : case TALER_EXCHANGEDB_RT_REFRESH:
2341 0 : rh = &irbt_cb_table_refresh;
2342 0 : break;
2343 0 : case TALER_EXCHANGEDB_RT_BATCH_DEPOSITS:
2344 0 : rh = &irbt_cb_table_batch_deposits;
2345 0 : break;
2346 0 : case TALER_EXCHANGEDB_RT_COIN_DEPOSITS:
2347 0 : rh = &irbt_cb_table_coin_deposits;
2348 0 : break;
2349 0 : case TALER_EXCHANGEDB_RT_REFUNDS:
2350 0 : rh = &irbt_cb_table_refunds;
2351 0 : break;
2352 0 : case TALER_EXCHANGEDB_RT_WIRE_OUT:
2353 0 : rh = &irbt_cb_table_wire_out;
2354 0 : break;
2355 0 : case TALER_EXCHANGEDB_RT_AGGREGATION_TRACKING:
2356 0 : rh = &irbt_cb_table_aggregation_tracking;
2357 0 : break;
2358 0 : case TALER_EXCHANGEDB_RT_WIRE_FEE:
2359 0 : rh = &irbt_cb_table_wire_fee;
2360 0 : break;
2361 0 : case TALER_EXCHANGEDB_RT_GLOBAL_FEE:
2362 0 : rh = &irbt_cb_table_global_fee;
2363 0 : break;
2364 0 : case TALER_EXCHANGEDB_RT_RECOUP:
2365 0 : rh = &irbt_cb_table_recoup;
2366 0 : break;
2367 0 : case TALER_EXCHANGEDB_RT_RECOUP_REFRESH:
2368 0 : rh = &irbt_cb_table_recoup_refresh;
2369 0 : break;
2370 0 : case TALER_EXCHANGEDB_RT_EXTENSIONS:
2371 0 : rh = &irbt_cb_table_extensions;
2372 0 : break;
2373 0 : case TALER_EXCHANGEDB_RT_POLICY_DETAILS:
2374 0 : rh = &irbt_cb_table_policy_details;
2375 0 : break;
2376 0 : case TALER_EXCHANGEDB_RT_POLICY_FULFILLMENTS:
2377 0 : rh = &irbt_cb_table_policy_fulfillments;
2378 0 : break;
2379 0 : case TALER_EXCHANGEDB_RT_PURSE_REQUESTS:
2380 0 : rh = &irbt_cb_table_purse_requests;
2381 0 : break;
2382 0 : case TALER_EXCHANGEDB_RT_PURSE_DECISION:
2383 0 : rh = &irbt_cb_table_purse_decision;
2384 0 : break;
2385 0 : case TALER_EXCHANGEDB_RT_PURSE_MERGES:
2386 0 : rh = &irbt_cb_table_purse_merges;
2387 0 : break;
2388 0 : case TALER_EXCHANGEDB_RT_PURSE_DEPOSITS:
2389 0 : rh = &irbt_cb_table_purse_deposits;
2390 0 : break;
2391 0 : case TALER_EXCHANGEDB_RT_ACCOUNT_MERGES:
2392 0 : rh = &irbt_cb_table_account_mergers;
2393 0 : break;
2394 0 : case TALER_EXCHANGEDB_RT_HISTORY_REQUESTS:
2395 0 : rh = &irbt_cb_table_history_requests;
2396 0 : break;
2397 0 : case TALER_EXCHANGEDB_RT_CLOSE_REQUESTS:
2398 0 : rh = &irbt_cb_table_close_requests;
2399 0 : break;
2400 0 : case TALER_EXCHANGEDB_RT_WADS_OUT:
2401 0 : rh = &irbt_cb_table_wads_out;
2402 0 : break;
2403 0 : case TALER_EXCHANGEDB_RT_WADS_OUT_ENTRIES:
2404 0 : rh = &irbt_cb_table_wads_out_entries;
2405 0 : break;
2406 0 : case TALER_EXCHANGEDB_RT_WADS_IN:
2407 0 : rh = &irbt_cb_table_wads_in;
2408 0 : break;
2409 0 : case TALER_EXCHANGEDB_RT_WADS_IN_ENTRIES:
2410 0 : rh = &irbt_cb_table_wads_in_entries;
2411 0 : break;
2412 0 : case TALER_EXCHANGEDB_RT_PROFIT_DRAINS:
2413 0 : rh = &irbt_cb_table_profit_drains;
2414 0 : break;
2415 0 : case TALER_EXCHANGEDB_RT_AML_STAFF:
2416 0 : rh = &irbt_cb_table_aml_staff;
2417 0 : break;
2418 0 : case TALER_EXCHANGEDB_RT_PURSE_DELETION:
2419 0 : rh = &irbt_cb_table_purse_deletion;
2420 0 : break;
2421 0 : case TALER_EXCHANGEDB_RT_WITHDRAW:
2422 0 : rh = &irbt_cb_table_withdraw;
2423 0 : break;
2424 0 : case TALER_EXCHANGEDB_RT_LEGITIMIZATION_MEASURES:
2425 0 : rh = &irbt_cb_table_legitimization_measures;
2426 0 : break;
2427 0 : case TALER_EXCHANGEDB_RT_LEGITIMIZATION_OUTCOMES:
2428 0 : rh = &irbt_cb_table_legitimization_outcomes;
2429 0 : break;
2430 0 : case TALER_EXCHANGEDB_RT_LEGITIMIZATION_PROCESSES:
2431 0 : rh = &irbt_cb_table_legitimization_processes;
2432 0 : break;
2433 0 : case TALER_EXCHANGEDB_RT_KYC_ATTRIBUTES:
2434 0 : rh = &irbt_cb_table_kyc_attributes;
2435 0 : break;
2436 0 : case TALER_EXCHANGEDB_RT_AML_HISTORY:
2437 0 : rh = &irbt_cb_table_aml_history;
2438 0 : break;
2439 0 : case TALER_EXCHANGEDB_RT_KYC_EVENTS:
2440 0 : rh = &irbt_cb_table_kyc_events;
2441 0 : break;
2442 : }
2443 0 : if (NULL == rh)
2444 : {
2445 0 : GNUNET_break (0);
2446 0 : return GNUNET_DB_STATUS_HARD_ERROR;
2447 : }
2448 0 : return rh (pg,
2449 : td);
2450 : }
2451 :
2452 :
2453 : /* end of insert_records_by_table.c */
|
