merchant

Merchant backend to process payments, run by merchants
Log | Files | Refs | Submodules | README | LICENSE

pg_insert_order.c (3656B)

      1 /*
      2    This file is part of TALER
      3    Copyright (C) 2022, 2023, 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_insert_order.c
     18  * @brief Implementation of the insert_order function for Postgres
     19  * @author Iván Ávalos
     20  * @author Christian Grothoff
     21  */
     22 #include "platform.h"
     23 #include <taler/taler_error_codes.h>
     24 #include <taler/taler_dbevents.h>
     25 #include <taler/taler_pq_lib.h>
     26 #include "pg_insert_order.h"
     27 #include "pg_helper.h"
     28 
     29 enum GNUNET_DB_QueryStatus
     30 TMH_PG_insert_order (void *cls,
     31                      const char *instance_id,
     32                      const char *order_id,
     33                      const char *session_id,
     34                      const struct TALER_MerchantPostDataHashP *h_post_data,
     35                      struct GNUNET_TIME_Timestamp pay_deadline,
     36                      const struct TALER_ClaimTokenP *claim_token,
     37                      const json_t *contract_terms,
     38                      const char *pos_key,
     39                      enum TALER_MerchantConfirmationAlgorithm pos_algorithm)
     40 {
     41   struct PostgresClosure *pg = cls;
     42   struct GNUNET_TIME_Timestamp now;
     43   uint32_t pos32 = (uint32_t) pos_algorithm;
     44   const char *fulfillment_url
     45     = json_string_value (json_object_get (contract_terms,
     46                                           "fulfillment_url"));
     47   struct GNUNET_PQ_QueryParam params[] = {
     48     GNUNET_PQ_query_param_string (instance_id),
     49     GNUNET_PQ_query_param_string (order_id),
     50     GNUNET_PQ_query_param_timestamp (&pay_deadline),
     51     GNUNET_PQ_query_param_auto_from_type (claim_token),
     52     GNUNET_PQ_query_param_auto_from_type (h_post_data),
     53     GNUNET_PQ_query_param_timestamp (&now),
     54     TALER_PQ_query_param_json (contract_terms),
     55     (NULL == pos_key)
     56     ? GNUNET_PQ_query_param_null ()
     57     : GNUNET_PQ_query_param_string (pos_key),
     58     GNUNET_PQ_query_param_uint32 (&pos32),
     59     (NULL == session_id)
     60     ? GNUNET_PQ_query_param_string ("")
     61     : GNUNET_PQ_query_param_string (session_id),
     62     (NULL == fulfillment_url)
     63     ? GNUNET_PQ_query_param_null ()
     64     : GNUNET_PQ_query_param_string (fulfillment_url),
     65     GNUNET_PQ_query_param_end
     66   };
     67 
     68   now = GNUNET_TIME_timestamp_get ();
     69   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
     70               "inserting order: order_id: %s, instance_id: %s.\n",
     71               order_id,
     72               instance_id);
     73   check_connection (pg);
     74   PREPARE (pg,
     75            "insert_order",
     76            "INSERT INTO merchant_orders"
     77            "(merchant_serial"
     78            ",order_id"
     79            ",pay_deadline"
     80            ",claim_token"
     81            ",h_post_data"
     82            ",creation_time"
     83            ",contract_terms"
     84            ",pos_key"
     85            ",pos_algorithm"
     86            ",session_id"
     87            ",fulfillment_url)"
     88            " SELECT merchant_serial,"
     89            " $2, $3, $4, $5, $6, $7::TEXT::JSONB, $8, $9, $10, $11"
     90            " FROM merchant_instances"
     91            " WHERE merchant_id=$1");
     92   return GNUNET_PQ_eval_prepared_non_select (pg->conn,
     93                                              "insert_order",
     94                                              params);
     95 }