Line data    Source code

       1             : /*
       2             :    This file is part of TALER
       3             :    Copyright (C) 2022 Taler Systems SA
       4             : 
       5             :    TALER is free software; you can redistribute it and/or modify it under the
       6             :    terms of the GNU General Public License as published by the Free Software
       7             :    Foundation; either version 3, or (at your option) any later version.
       8             : 
       9             :    TALER is distributed in the hope that it will be useful, but WITHOUT ANY
      10             :    WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
      11             :    A PARTICULAR PURPOSE.  See the GNU General Public License for more details.
      12             : 
      13             :    You should have received a copy of the GNU General Public License along with
      14             :    TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
      15             :  */
      16             : /**
      17             :  * @file exchangedb/pg_insert_purse_request.c
      18             :  * @brief Implementation of the insert_purse_request function for Postgres
      19             :  * @author Christian Grothoff
      20             :  */
      21             : #include "taler/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_insert_purse_request.h"
      26             : #include "pg_get_purse_request.h"
      27             : #include "pg_helper.h"
      28             : 
      29             : 
      30             : enum GNUNET_DB_QueryStatus
      31          24 : TEH_PG_insert_purse_request (
      32             :   void *cls,
      33             :   const struct TALER_PurseContractPublicKeyP *purse_pub,
      34             :   const struct TALER_PurseMergePublicKeyP *merge_pub,
      35             :   struct GNUNET_TIME_Timestamp purse_expiration,
      36             :   const struct TALER_PrivateContractHashP *h_contract_terms,
      37             :   uint32_t age_limit,
      38             :   enum TALER_WalletAccountMergeFlags flags,
      39             :   const struct TALER_Amount *purse_fee,
      40             :   const struct TALER_Amount *amount,
      41             :   const struct TALER_PurseContractSignatureP *purse_sig,
      42             :   bool *in_conflict)
      43             : {
      44          24 :   struct PostgresClosure *pg = cls;
      45             :   enum GNUNET_DB_QueryStatus qs;
      46          24 :   struct GNUNET_TIME_Timestamp now = GNUNET_TIME_timestamp_get ();
      47          24 :   uint32_t flags32 = (uint32_t) flags;
      48          24 :   bool in_reserve_quota = (TALER_WAMF_MODE_CREATE_FROM_PURSE_QUOTA
      49          24 :                            == (flags & TALER_WAMF_MERGE_MODE_MASK));
      50          24 :   struct GNUNET_PQ_QueryParam params[] = {
      51          24 :     GNUNET_PQ_query_param_auto_from_type (purse_pub),
      52          24 :     GNUNET_PQ_query_param_auto_from_type (merge_pub),
      53          24 :     GNUNET_PQ_query_param_timestamp (&now),
      54          24 :     GNUNET_PQ_query_param_timestamp (&purse_expiration),
      55          24 :     GNUNET_PQ_query_param_auto_from_type (h_contract_terms),
      56          24 :     GNUNET_PQ_query_param_uint32 (&age_limit),
      57          24 :     GNUNET_PQ_query_param_uint32 (&flags32),
      58          24 :     GNUNET_PQ_query_param_bool (in_reserve_quota),
      59          24 :     TALER_PQ_query_param_amount (pg->conn,
      60             :                                  amount),
      61          24 :     TALER_PQ_query_param_amount (pg->conn,
      62             :                                  purse_fee),
      63          24 :     GNUNET_PQ_query_param_auto_from_type (purse_sig),
      64             :     GNUNET_PQ_query_param_end
      65             :   };
      66             : 
      67          24 :   *in_conflict = false;
      68          24 :   PREPARE (pg,
      69             :            "insert_purse_request",
      70             :            "INSERT INTO purse_requests"
      71             :            "  (purse_pub"
      72             :            "  ,merge_pub"
      73             :            "  ,purse_creation"
      74             :            "  ,purse_expiration"
      75             :            "  ,h_contract_terms"
      76             :            "  ,age_limit"
      77             :            "  ,flags"
      78             :            "  ,in_reserve_quota"
      79             :            "  ,amount_with_fee"
      80             :            "  ,purse_fee"
      81             :            "  ,purse_sig"
      82             :            "  ) VALUES "
      83             :            "  ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11)"
      84             :            "  ON CONFLICT DO NOTHING;");
      85          24 :   qs = GNUNET_PQ_eval_prepared_non_select (pg->conn,
      86             :                                            "insert_purse_request",
      87             :                                            params);
      88          24 :   if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS != qs)
      89          24 :     return qs;
      90             :   {
      91             :     struct TALER_PurseMergePublicKeyP merge_pub2;
      92             :     struct GNUNET_TIME_Timestamp purse_expiration2;
      93             :     struct TALER_PrivateContractHashP h_contract_terms2;
      94             :     uint32_t age_limit2;
      95             :     struct TALER_Amount amount2;
      96             :     struct TALER_Amount balance;
      97             :     struct TALER_PurseContractSignatureP purse_sig2;
      98             : 
      99           0 :     qs = TEH_PG_get_purse_request (pg,
     100             :                                    purse_pub,
     101             :                                    &merge_pub2,
     102             :                                    &purse_expiration2,
     103             :                                    &h_contract_terms2,
     104             :                                    &age_limit2,
     105             :                                    &amount2,
     106             :                                    &balance,
     107             :                                    &purse_sig2);
     108           0 :     if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT != qs)
     109             :     {
     110           0 :       GNUNET_break (0);
     111           0 :       return GNUNET_DB_STATUS_HARD_ERROR;
     112             :     }
     113           0 :     if ( (age_limit2 == age_limit) &&
     114           0 :          (0 == TALER_amount_cmp (amount,
     115           0 :                                  &amount2)) &&
     116           0 :          (0 == GNUNET_memcmp (&h_contract_terms2,
     117           0 :                               h_contract_terms)) &&
     118           0 :          (0 == GNUNET_memcmp (&merge_pub2,
     119             :                               merge_pub)) )
     120             :     {
     121           0 :       return GNUNET_DB_STATUS_SUCCESS_NO_RESULTS;
     122             :     }
     123           0 :     *in_conflict = true;
     124           0 :     return GNUNET_DB_STATUS_SUCCESS_ONE_RESULT;
     125             :   }
     126             : }