adding auditor resp endpoints, trigger for helper deposit_confirmations

4 files changed, 133 insertions, 0 deletions

diff --git a/src/auditordb/0002-auditor-triggers.sql b/src/auditordb/0002-auditor-triggers.sql
new file mode 100644
index 000000000..43d8eb8f6
--- /dev/null
+++ b/src/auditordb/0002-auditor-triggers.sql
@@ -0,0 +1,19 @@
+SET search_path TO auditor;
+
+CREATE TRIGGER auditor_notify_helper_deposits
+    AFTER INSERT
+    ON auditor.deposit_confirmations
+EXECUTE PROCEDURE auditor_new_transactions_trigger();
+
+CREATE OR REPLACE FUNCTION auditor_new_transactions_trigger()
+    RETURNS trigger
+    LANGUAGE plpgsql
+AS $$
+BEGIN
+    -- TODO Add correct notify string
+    PERFORM('NOTIFY XRE2709K6TYDBVARD9Y5SCZY7VHE4D5DKF0R8DHQ4X5T13E8X2X60');
+    RETURN NEW;
+END $$;
+COMMENT ON FUNCTION auditor_new_transactions_trigger()
+    IS 'Call auditor_call_db_notify on new entry';
+
diff --git a/src/auditordb/pg_delete_deposit_confirmations.c b/src/auditordb/pg_delete_deposit_confirmations.c
new file mode 100644
index 000000000..553e97121
--- /dev/null
+++ b/src/auditordb/pg_delete_deposit_confirmations.c
@@ -0,0 +1,62 @@
+/*

+   This file is part of TALER

+   Copyright (C) 2024 Taler Systems SA

+

+   TALER is free software; you can redistribute it and/or modify it under the

+   terms of the GNU General Public License as published by the Free Software

+   Foundation; either version 3, or (at your option) any later version.

+

+   TALER is distributed in the hope that it will be useful, but WITHOUT ANY

+   WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR

+   A PARTICULAR PURPOSE.  See the GNU General Public License for more details.

+

+   You should have received a copy of the GNU General Public License along with

+   TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>

+ */

+/**

+ * @file auditordb/pg_delete_deposit_confirmations.c

+ * @brief Implementation of the delete_deposit_confirmations function for Postgres

+ * @author Nicola Eigel

+ */

+#include "platform.h"

+#include "taler_error_codes.h"

+#include "taler_dbevents.h"

+#include "taler_pq_lib.h"

+#include "pg_delete_deposit_confirmations.h"

+#include "pg_helper.h"

+

+enum GNUNET_DB_QueryStatus

+TAH_PG_delete_deposit_confirmations (

+  void *cls,

+  const struct TALER_PrivateContractHashP *h_contract_terms,

+  const struct TALER_MerchantWireHashP *h_wire,

+  const struct TALER_MerchantPublicKeyP *merchant_pub,

+  const struct TALER_ExchangeSignatureP *exchange_sig,

+  const struct TALER_ExchangePublicKeyP *exchange_pub,

+  const struct TALER_MasterSignatureP *master_sig)

+{

+  struct PostgresClosure *pg = cls;

+  struct GNUNET_PQ_QueryParam params[] = {

+    GNUNET_PQ_query_param_auto_from_type (h_contract_terms),

+    GNUNET_PQ_query_param_auto_from_type (h_wire),

+    GNUNET_PQ_query_param_auto_from_type (merchant_pub),

+    GNUNET_PQ_query_param_auto_from_type (exchange_sig),

+    GNUNET_PQ_query_param_auto_from_type (exchange_pub),

+    GNUNET_PQ_query_param_auto_from_type (master_sig),

+    GNUNET_PQ_query_param_end

+  };

+

+  PREPARE (pg,

+           "auditor_delete_deposit_confirmations",

+           "DELETE"

+           " FROM deposit_confirmations"

+           " WHERE h_contract_terms=$1"

+           "   AND h_wire=$2"

+           "   AND merchant_pub=$3"

+           "   AND exchange_sig=$4"

+           "   AND exchange_pub=$5"

+           "   AND master_sig=$6;");

+  return GNUNET_PQ_eval_prepared_non_select (pg->conn,

+                                             "auditor_delete_deposit_confirmations",

+                                             params);

+}

diff --git a/src/auditordb/pg_delete_deposit_confirmations.h b/src/auditordb/pg_delete_deposit_confirmations.h
new file mode 100644
index 000000000..f0339fd3d
--- /dev/null
+++ b/src/auditordb/pg_delete_deposit_confirmations.h
@@ -0,0 +1,51 @@
+/*
+   This file is part of TALER
+   Copyright (C) 2024 Taler Systems SA
+
+   TALER is free software; you can redistribute it and/or modify it under the
+   terms of the GNU General Public License as published by the Free Software
+   Foundation; either version 3, or (at your option) any later version.
+
+   TALER is distributed in the hope that it will be useful, but WITHOUT ANY
+   WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
+   A PARTICULAR PURPOSE.  See the GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License along with
+   TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
+ */
+/**
+ * @file auditordb/pg_delete_deposit_confirmations.h
+ * @brief implementation of the delete_deposit_confirmations function for Postgres
+ * @author Nicola Eigel
+ */
+#ifndef PG_DELETE_DEPOSIT_CONFIRMATIONS_H
+#define PG_DELETE_DEPOSIT_CONFIRMATIONS_H
+
+#include "taler_util.h"
+#include "taler_json_lib.h"
+#include "taler_auditordb_plugin.h"
+
+/**
+ * Delete a row from the deposit confirmations table.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param h_contract_terms private contract hash
+ * @param h_wire merchant wire hash
+ * @param merchant_pub master key of the merchant
+ * @param exchange_sig signature of the exchange
+ * @param exchange_pub master key of the exchange
+ * @param master_sig master signature of the exchange
+ * @return
+ */
+enum GNUNET_DB_QueryStatus
+TAH_PG_delete_deposit_confirmations (
+  void *cls,
+  const struct TALER_PrivateContractHashP *h_contract_terms,
+  const struct TALER_MerchantWireHashP *h_wire,
+  const struct TALER_MerchantPublicKeyP *merchant_pub,
+  const struct TALER_ExchangeSignatureP *exchange_sig,
+  const struct TALER_ExchangePublicKeyP *exchange_pub,
+  const struct TALER_MasterSignatureP *master_sig);
+
+
+#endif
diff --git a/src/auditordb/plugin_auditordb_postgres.c b/src/auditordb/plugin_auditordb_postgres.c
index 2b722a5ea..dc66990ba 100644
--- a/src/auditordb/plugin_auditordb_postgres.c
+++ b/src/auditordb/plugin_auditordb_postgres.c
@@ -77,6 +77,7 @@
 #include "pg_insert_exchange_signkey.h"
 #include "pg_insert_deposit_confirmation.h"
 #include "pg_get_deposit_confirmations.h"
+#include "pg_delete_deposit_confirmations.h"
 #include "pg_insert_auditor_progress_coin.h"
 #include "pg_update_auditor_progress_coin.h"
 #include "pg_get_auditor_progress_coin.h"