[taler-exchange] branch master updated: -insert routines

[gnunet]

This is an automated email from the git hooks/post-receive script.

grothoff pushed a commit to branch master
in repository exchange.

The following commit(s) were added to refs/heads/master by this push:
     new 7e5c6a7e -insert routines
7e5c6a7e is described below

commit 7e5c6a7e46b860f2c26971923b96cc1aad6f5d30
Author: Christian Grothoff <grothoff@gnunet.org>
AuthorDate: Wed Oct 5 16:38:29 2022 +0200

    -insert routines
---
 contrib/gana                          |   2 +-
 src/exchangedb/irbt_callbacks.c       | 152 ++++++++++++++++++++++++++++++++++
 src/include/taler_exchangedb_plugin.h |  10 ---
 3 files changed, 153 insertions(+), 11 deletions(-)

diff --git a/contrib/gana b/contrib/gana
index 9dee7d6e..58a94dc4 160000
--- a/contrib/gana
+++ b/contrib/gana
@@ -1 +1 @@
-Subproject commit 9dee7d6e8f967fdc58ae224e19ec03989ac35c52
+Subproject commit 58a94dc411d8ec0f23c5364c37719e90bb9ad8a9
diff --git a/src/exchangedb/irbt_callbacks.c b/src/exchangedb/irbt_callbacks.c
index ffad1c9b..570d4221 100644
--- a/src/exchangedb/irbt_callbacks.c
+++ b/src/exchangedb/irbt_callbacks.c
@@ -131,6 +131,64 @@ irbt_cb_table_wire_targets (struct PostgresClosure *pg,
 }
 
 
+/**
+ * Function called with records to insert into table.
+ *
+ * @param pg plugin context
+ * @param td record to insert
+ */
+static enum GNUNET_DB_QueryStatus
+irbt_cb_table_legitimization_processes (struct PostgresClosure *pg,
+                                        const struct
+                                        TALER_EXCHANGEDB_TableData *td)
+{
+  struct GNUNET_PQ_QueryParam params[] = {
+    GNUNET_PQ_query_param_uint64 (&td->serial),
+    GNUNET_PQ_query_param_auto_from_type (
+      &td->details.legitimization_processes.h_payto),
+    GNUNET_PQ_query_param_timestamp (
+      &td->details.legitimization_processes.expiration_time),
+    GNUNET_PQ_query_param_string (
+      td->details.legitimization_processes.provider_section),
+    GNUNET_PQ_query_param_string (
+      td->details.legitimization_processes.provider_user_id),
+    GNUNET_PQ_query_param_string (
+      td->details.legitimization_processes.provider_legitimization_id),
+    GNUNET_PQ_query_param_end
+  };
+
+  return GNUNET_PQ_eval_prepared_non_select (pg->conn,
+                                             
"insert_into_table_legitimization_processes",
+                                             params);
+}
+
+
+/**
+ * Function called with records to insert into table.
+ *
+ * @param pg plugin context
+ * @param td record to insert
+ */
+static enum GNUNET_DB_QueryStatus
+irbt_cb_table_legitimization_requirements (struct PostgresClosure *pg,
+                                           const struct
+                                           TALER_EXCHANGEDB_TableData *td)
+{
+  struct GNUNET_PQ_QueryParam params[] = {
+    GNUNET_PQ_query_param_uint64 (&td->serial),
+    GNUNET_PQ_query_param_auto_from_type (
+      &td->details.legitimization_requirements.h_payto),
+    GNUNET_PQ_query_param_string (
+      td->details.legitimization_requirements.required_checks),
+    GNUNET_PQ_query_param_end
+  };
+
+  return GNUNET_PQ_eval_prepared_non_select (pg->conn,
+                                             
"insert_into_table_legitimization_requirements",
+                                             params);
+}
+
+
 /**
  * Function called with reserves records to insert into table.
  *
@@ -185,6 +243,100 @@ irbt_cb_table_reserves_in (struct PostgresClosure *pg,
 }
 
 
+/**
+ * Function called with reserves_open_requests records to insert into table.
+ *
+ * @param pg plugin context
+ * @param td record to insert
+ */
+static enum GNUNET_DB_QueryStatus
+irbt_cb_table_reserves_open_requests (struct PostgresClosure *pg,
+                                      const struct
+                                      TALER_EXCHANGEDB_TableData *td)
+{
+  struct GNUNET_PQ_QueryParam params[] = {
+    GNUNET_PQ_query_param_uint64 (&td->serial),
+    GNUNET_PQ_query_param_timestamp (
+      &td->details.reserves_open_requests.request_timestamp),
+    GNUNET_PQ_query_param_timestamp (
+      &td->details.reserves_open_requests.expiration_date),
+    GNUNET_PQ_query_param_auto_from_type (
+      &td->details.reserves_open_requests.reserve_sig),
+    TALER_PQ_query_param_amount (
+      &td->details.reserves_open_requests.reserve_payment),
+    GNUNET_PQ_query_param_uint32 (
+      &td->details.reserves_open_requests.requested_purse_limit),
+    GNUNET_PQ_query_param_end
+  };
+
+  return GNUNET_PQ_eval_prepared_non_select (pg->conn,
+                                             
"insert_into_table_reserves_open_requests",
+                                             params);
+}
+
+
+/**
+ * Function called with reserves_open_requests records to insert into table.
+ *
+ * @param pg plugin context
+ * @param td record to insert
+ */
+static enum GNUNET_DB_QueryStatus
+irbt_cb_table_reserves_open_deposits (struct PostgresClosure *pg,
+                                      const struct
+                                      TALER_EXCHANGEDB_TableData *td)
+{
+  struct GNUNET_PQ_QueryParam params[] = {
+    GNUNET_PQ_query_param_uint64 (&td->serial),
+    GNUNET_PQ_query_param_timestamp (
+      &td->details.reserves_open_deposits.request_timestamp),
+    GNUNET_PQ_query_param_auto_from_type (
+      &td->details.reserves_open_deposits.coin_pub),
+    GNUNET_PQ_query_param_auto_from_type (
+      &td->details.reserves_open_deposits.coin_sig),
+    GNUNET_PQ_query_param_auto_from_type (
+      &td->details.reserves_open_deposits.reserve_sig),
+    TALER_PQ_query_param_amount (
+      &td->details.reserves_open_deposits.contribution),
+    GNUNET_PQ_query_param_end
+  };
+
+  return GNUNET_PQ_eval_prepared_non_select (pg->conn,
+                                             
"insert_into_table_reserves_open_deposits",
+                                             params);
+}
+
+
+/**
+ * Function called with reserves_close records to insert into table.
+ *
+ * @param pg plugin context
+ * @param td record to insert
+ */
+static enum GNUNET_DB_QueryStatus
+irbt_cb_table_reserves_close_requests (struct PostgresClosure *pg,
+                                       const struct
+                                       TALER_EXCHANGEDB_TableData *td)
+{
+  struct GNUNET_PQ_QueryParam params[] = {
+    GNUNET_PQ_query_param_uint64 (&td->serial),
+    GNUNET_PQ_query_param_auto_from_type (
+      &td->details.reserves_close_requests.reserve_pub),
+    GNUNET_PQ_query_param_timestamp (
+      &td->details.reserves_close_requests.execution_date),
+    GNUNET_PQ_query_param_auto_from_type (
+      &td->details.reserves_close_requests.reserve_sig),
+    GNUNET_PQ_query_param_auto_from_type (
+      &td->details.reserves_close_requests.wire_target_h_payto),
+    GNUNET_PQ_query_param_end
+  };
+
+  return GNUNET_PQ_eval_prepared_non_select (pg->conn,
+                                             
"insert_into_table_reserves_close_requests",
+                                             params);
+}
+
+
 /**
  * Function called with reserves_close records to insert into table.
  *
diff --git a/src/include/taler_exchangedb_plugin.h 
b/src/include/taler_exchangedb_plugin.h
index 971b0372..a6b7a616 100644
--- a/src/include/taler_exchangedb_plugin.h
+++ b/src/include/taler_exchangedb_plugin.h
@@ -318,16 +318,6 @@ struct TALER_EXCHANGEDB_TableData
       struct TALER_ReservePublicKeyP reserve_pub;
     } reserves_in;
 
-    struct
-    {
-      struct TALER_ReservePublicKeyP reserve_pub;
-      struct GNUNET_TIME_Timestamp execution_date;
-      struct TALER_WireTransferIdentifierRawP wtid;
-      struct TALER_PaytoHashP wire_target_h_payto;
-      struct TALER_Amount amount;
-      struct TALER_Amount closing_fee;
-    } reserves_close;
-
     struct
     {
       struct TALER_ReservePublicKeyP reserve_pub;

-- 
To stop receiving notification emails like this one, please contact
gnunet@gnunet.org.