donau

commit 0d071090936533c1991b771cf97f6d3a02a2d7d7
parent c721f7f2cd7c8d093b7a85b1b8fb4f0830705313
Author: Casaburi Johannes <johannes.casaburi@students.bfh.ch>
Date:   Tue, 30 Apr 2024 22:33:49 +0200

added pg_iterate_submitted_receipts to db plugins

Diffstat:
M
src/donaudb/pg_iterate_submitted_receipts.c
 | 
12
++++++------
M
src/donaudb/pg_iterate_submitted_receipts.h
 | 
11
++++++-----
M
src/donaudb/plugin_donaudb_postgres.c
 | 
19
+++++++++++--------
M
src/include/donaudb_plugin.h
 | 
15
+++++++++++++++

4 files changed, 38 insertions(+), 19 deletions(-)
diff --git a/src/donaudb/pg_iterate_submitted_receipts.c b/src/donaudb/pg_iterate_submitted_receipts.c
@@ -94,12 +94,12 @@ iterate_submitted_receipts_cb (void *cls,
 
 
 enum GNUNET_DB_QueryStatus
-DH_PG_iterate_submitted_receipts (void *cls,
-                                  const uint64_t donation_year,
-                                  const struct DONAU_HashDonorTaxId *
-                                  h_donor_tax_id,
-                                  DONAUDB_IterateSubmittedReceiptsCallback cb,
-                                  void *cb_cls)
+DH_PG_iterate_submitted_receipts (
+  void *cls,
+  const uint64_t donation_year,
+  const struct DONAU_HashDonorTaxId *h_donor_tax_id,
+  DONAUDB_IterateSubmittedReceiptsCallback cb,
+  void *cb_cls)
 {
   struct PostgresClosure *pg = cls;
   struct GNUNET_PQ_QueryParam params[] = {
diff --git a/src/donaudb/pg_iterate_submitted_receipts.h b/src/donaudb/pg_iterate_submitted_receipts.h
@@ -34,10 +34,11 @@
  * @return transaction status code
  */
 enum GNUNET_DB_QueryStatus
-DH_PG_iterate_donation_units (void *cls,
-                              const uint64_t donation_year,
-                              const struct DONAU_HashDonorTaxId *h_donor_tax_id,
-                              DONAUDB_IterateSubmittedReceiptsCallback cb,
-                              void *cb_cls);
+DH_PG_iterate_submitted_receipts (
+  void *cls,
+  const uint64_t donation_year,
+  const struct DONAU_HashDonorTaxId *h_donor_tax_id,
+  DONAUDB_IterateSubmittedReceiptsCallback cb,
+  void *cb_cls);
 
 #endif
diff --git a/src/donaudb/plugin_donaudb_postgres.c b/src/donaudb/plugin_donaudb_postgres.c
@@ -45,6 +45,7 @@
 #include "pg_get_history.h"
 #include "pg_insert_issued_receipt.h"
 #include "pg_insert_submitted_receipts.h"
+#include "pg_iterate_submitted_receipts.h"
 #include "pg_insert_signing_key.h"
 #include "pg_iterate_active_signing_keys.h"
 #include "pg_lookup_signing_key.h"
@@ -69,14 +70,14 @@
  * @param conn SQL connection that was used
  */
 #define BREAK_DB_ERR(result,conn) do {                                  \
-    GNUNET_break (0);                                                   \
-    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,                                \
-                "Database failure: %s/%s/%s/%s/%s",                     \
-                PQresultErrorField (result, PG_DIAG_MESSAGE_PRIMARY),   \
-                PQresultErrorField (result, PG_DIAG_MESSAGE_DETAIL),    \
-                PQresultErrorMessage (result),                          \
-                PQresStatus (PQresultStatus (result)),                  \
-                PQerrorMessage (conn));                                 \
+          GNUNET_break (0);                                                   \
+          GNUNET_log (GNUNET_ERROR_TYPE_ERROR,                                \
+                      "Database failure: %s/%s/%s/%s/%s",                     \
+                      PQresultErrorField (result, PG_DIAG_MESSAGE_PRIMARY),   \
+                      PQresultErrorField (result, PG_DIAG_MESSAGE_DETAIL),    \
+                      PQresultErrorMessage (result),                          \
+                      PQresStatus (PQresultStatus (result)),                  \
+                      PQerrorMessage (conn));                                 \
 } while (0)
 
 
@@ -238,6 +239,8 @@ libtaler_plugin_donaudb_postgres_init (void *cls)
     = &DH_PG_lookup_signing_key;
   plugin->iterate_active_signing_keys
     = &DH_PG_iterate_active_signing_keys;
+  plugin->iterate_submitted_receipts
+    = &DH_PG_iterate_submitted_receipts;
   plugin->lookup_charity
     = &DH_PG_lookup_charity;
   plugin->insert_charity
diff --git a/src/include/donaudb_plugin.h b/src/include/donaudb_plugin.h
@@ -544,6 +544,21 @@ struct DONAUDB_Plugin
     uint64_t donation_year);
 
   /**
+    * Iterate submitted donation receipt.
+    *
+    * @param cls closure
+    * @param value
+    * @return database transaction status
+    */
+  enum GNUNET_DB_QueryStatus
+    (*iterate_submitted_receipts)(
+    void *cls,
+    const uint64_t donation_year,
+    const struct DONAU_HashDonorTaxId *h_donor_tax_id,
+    DONAUDB_IterateSubmittedReceiptsCallback cb,
+    void *cb_cls);
+
+  /**
   * Lookup issued receipts from the charity.
   *
   * @param cls closure