pg_lookup_product.c (7052B)
1 /* 2 This file is part of TALER 3 Copyright (C) 2022, 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 backenddb/pg_lookup_product.c 18 * @brief Implementation of the lookup_product function for Postgres 19 * @author Iván Ávalos 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 "pg_lookup_product.h" 26 #include "pg_helper.h" 27 28 29 enum GNUNET_DB_QueryStatus 30 TMH_PG_lookup_product (void *cls, 31 const char *instance_id, 32 const char *product_id, 33 struct TALER_MERCHANTDB_ProductDetails *pd, 34 size_t *num_categories, 35 uint64_t **categories) 36 { 37 struct PostgresClosure *pg = cls; 38 struct GNUNET_PQ_QueryParam params[] = { 39 GNUNET_PQ_query_param_string (instance_id), 40 GNUNET_PQ_query_param_string (product_id), 41 GNUNET_PQ_query_param_end 42 }; 43 44 PREPARE (pg, 45 "lookup_product", 46 "SELECT" 47 " mi.description" 48 ",mi.description_i18n::TEXT" 49 ",mi.product_name" 50 ",mi.unit" 51 ",mi.price" 52 ",mi.price_array" 53 ",mi.taxes::TEXT" 54 ",mi.total_stock" 55 ",mi.total_stock_frac" 56 ",mi.allow_fractional_quantity" 57 ",mi.fractional_precision_level" 58 ",mi.total_sold" 59 ",mi.total_sold_frac" 60 ",mi.total_lost" 61 ",mi.total_lost_frac" 62 ",mi.image" 63 ",mi.address::TEXT" 64 ",mi.next_restock" 65 ",mi.minimum_age" 66 ",t.category_array AS categories" 67 " FROM merchant_inventory mi" 68 " JOIN merchant_instances inst" 69 " USING (merchant_serial)" 70 ",LATERAL (" 71 " SELECT ARRAY (" 72 " SELECT mpc.category_serial" 73 " FROM merchant_product_categories mpc" 74 " WHERE mpc.product_serial = mi.product_serial" 75 " ) AS category_array" 76 " ) t" 77 " WHERE inst.merchant_id=$1" 78 " AND mi.product_id=$2" 79 ); 80 if (NULL == pd) 81 { 82 struct GNUNET_PQ_ResultSpec rs_null[] = { 83 GNUNET_PQ_result_spec_end 84 }; 85 86 check_connection (pg); 87 return GNUNET_PQ_eval_prepared_singleton_select (pg->conn, 88 "lookup_product", 89 params, 90 rs_null); 91 } 92 else 93 { 94 char *my_name = NULL; 95 char *my_description = NULL; 96 json_t *my_description_i18n = NULL; 97 char *my_unit = NULL; 98 char *my_image = NULL; 99 json_t *my_address = NULL; 100 json_t *my_taxes = NULL; 101 uint64_t *my_categories = NULL; 102 struct TALER_Amount *my_price_array = NULL; 103 size_t my_price_array_length = 0; 104 struct GNUNET_PQ_ResultSpec rs[] = { 105 GNUNET_PQ_result_spec_string ("description", 106 &my_description), 107 TALER_PQ_result_spec_json ("description_i18n", 108 &my_description_i18n), 109 GNUNET_PQ_result_spec_string ("product_name", 110 &my_name), 111 GNUNET_PQ_result_spec_string ("unit", 112 &my_unit), 113 TALER_PQ_result_spec_amount_with_currency ("price", 114 &pd->price), 115 TALER_PQ_result_spec_array_amount_with_currency (pg->conn, 116 "price_array", 117 &my_price_array_length, 118 &my_price_array), 119 TALER_PQ_result_spec_json ("taxes", 120 &my_taxes), 121 GNUNET_PQ_result_spec_uint64 ("total_stock", 122 &pd->total_stock), 123 GNUNET_PQ_result_spec_uint32 ("total_stock_frac", 124 &pd->total_stock_frac), 125 GNUNET_PQ_result_spec_bool ("allow_fractional_quantity", 126 &pd->allow_fractional_quantity), 127 GNUNET_PQ_result_spec_uint32 ("fractional_precision_level", 128 &pd->fractional_precision_level), 129 GNUNET_PQ_result_spec_uint64 ("total_sold", 130 &pd->total_sold), 131 GNUNET_PQ_result_spec_uint32 ("total_sold_frac", 132 &pd->total_sold_frac), 133 GNUNET_PQ_result_spec_uint64 ("total_lost", 134 &pd->total_lost), 135 GNUNET_PQ_result_spec_uint32 ("total_lost_frac", 136 &pd->total_lost_frac), 137 GNUNET_PQ_result_spec_string ("image", 138 &my_image), 139 TALER_PQ_result_spec_json ("address", 140 &my_address), 141 GNUNET_PQ_result_spec_timestamp ("next_restock", 142 &pd->next_restock), 143 GNUNET_PQ_result_spec_uint32 ("minimum_age", 144 &pd->minimum_age), 145 GNUNET_PQ_result_spec_array_uint64 (pg->conn, 146 "categories", 147 num_categories, 148 &my_categories), 149 GNUNET_PQ_result_spec_end 150 }; 151 enum GNUNET_DB_QueryStatus qs; 152 153 check_connection (pg); 154 qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn, 155 "lookup_product", 156 params, 157 rs); 158 pd->product_name = my_name; 159 pd->description = my_description; 160 pd->description_i18n = my_description_i18n; 161 pd->unit = my_unit; 162 pd->taxes = my_taxes; 163 pd->image = my_image; 164 pd->address = my_address; 165 pd->price_array = my_price_array; 166 pd->price_array_length = my_price_array_length; 167 *categories = my_categories; 168 /* Clear original pointers to that cleanup_result doesn't squash them */ 169 my_name = NULL; 170 my_description = NULL; 171 my_description_i18n = NULL; 172 my_unit = NULL; 173 my_taxes = NULL; 174 my_image = NULL; 175 my_address = NULL; 176 my_price_array = NULL; 177 my_price_array_length = 0; 178 my_categories = NULL; 179 GNUNET_PQ_cleanup_result (rs); 180 return qs; 181 } 182 }