real-time-auditor

1 files changed, 367 insertions, 5 deletions

diff --git a/src/auditordb/plugin_auditordb_postgres.c b/src/auditordb/plugin_auditordb_postgres.c
index f5c405d8d..0e8c6ed44 100644
--- a/src/auditordb/plugin_auditordb_postgres.c
+++ b/src/auditordb/plugin_auditordb_postgres.c
@@ -56,7 +56,146 @@
 #include "pg_update_purse_info.h"
 #include "pg_update_reserve_info.h"
 #include "pg_update_wire_fee_summary.h"
-
+#include "pg_get_amount_arithmetic_inconsistency.h"
+#include "pg_get_coin_inconsistency.h"
+#include "pg_get_row_inconsistency.h"
+#include "pg_update_emergency_by_count.h"
+#include "pg_update_row_inconsistency.h"
+#include "pg_update_purse_not_closed_inconsistencies.h"
+#include "pg_update_reserve_balance_insufficient_inconsistency.h"
+#include "pg_update_coin_inconsistency.h"
+#include "pg_update_progress.h"
+#include "pg_update_denomination_key_validity_withdraw_inconsistency.h"
+#include "pg_update_refreshes_hanging.h"
+#include "pg_update_emergency.h"
+#include "pg_update_closure_lags.h"
+#include "pg_update_row_minor_inconsistencies.h"
+
+#include "pg_del_amount_arithmetic_inconsistency.h"
+#include "pg_del_coin_inconsistency.h"
+#include "pg_del_row_inconsistency.h"
+
+#include "pg_insert_coin_inconsistency.h"
+#include "pg_insert_row_inconsistency.h"
+#include "pg_insert_amount_arithmetic_inconsistency.h"
+
+#include "pg_get_auditor_closure_lags.h"
+#include "pg_del_auditor_closure_lags.h"
+#include "pg_insert_auditor_closure_lags.h"
+
+#include "pg_get_emergency_by_count.h"
+#include "pg_del_emergency_by_count.h"
+#include "pg_insert_emergency_by_count.h"
+
+#include "pg_get_emergency.h"
+#include "pg_del_emergency.h"
+#include "pg_insert_emergency.h"
+
+#include "pg_del_auditor_progress.h"
+
+#include "pg_get_bad_sig_losses.h"
+#include "pg_del_bad_sig_losses.h"
+#include "pg_insert_bad_sig_losses.h"
+#include "pg_update_bad_sig_losses.h"
+
+#include "pg_get_denomination_key_validity_withdraw_inconsistency.h"
+#include "pg_del_denomination_key_validity_withdraw_inconsistency.h"
+#include "pg_insert_denomination_key_validity_withdraw_inconsistency.h"
+
+#include "pg_get_fee_time_inconsistency.h"
+#include "pg_del_fee_time_inconsistency.h"
+#include "pg_insert_fee_time_inconsistency.h"
+#include "pg_update_fee_time_inconsistency.h"
+
+#include "pg_get_purse_not_closed_inconsistencies.h"
+#include "pg_del_purse_not_closed_inconsistencies.h"
+#include "pg_insert_purse_not_closed_inconsistencies.h"
+
+#include "pg_get_refreshes_hanging.h"
+#include "pg_del_refreshes_hanging.h"
+#include "pg_insert_refreshes_hanging.h"
+
+#include "pg_get_reserve_balance_insufficient_inconsistency.h"
+#include "pg_del_reserve_balance_insufficient_inconsistency.h"
+#include "pg_insert_reserve_balance_insufficient_inconsistency.h"
+
+#include "pg_get_reserve_in_inconsistency.h"
+#include "pg_del_reserve_in_inconsistency.h"
+#include "pg_insert_reserve_in_inconsistency.h"
+#include "pg_update_reserve_in_inconsistency.h"
+
+#include "pg_get_reserve_not_closed_inconsistency.h"
+#include "pg_del_reserve_not_closed_inconsistency.h"
+#include "pg_insert_reserve_not_closed_inconsistency.h"
+#include "pg_update_reserve_not_closed_inconsistency.h"
+
+#include "pg_get_denominations_without_sigs.h"
+#include "pg_del_denominations_without_sigs.h"
+#include "pg_insert_denominations_without_sigs.h"
+#include "pg_update_denominations_without_sigs.h"
+
+#include "pg_get_misattribution_in_inconsistency.h"
+#include "pg_del_misattribution_in_inconsistency.h"
+#include "pg_insert_misattribution_in_inconsistency.h"
+#include "pg_update_misattribution_in_inconsistency.h"
+
+#include "pg_get_reserves.h"
+#include "pg_del_reserves.h"
+#include "pg_insert_reserves.h"
+#include "pg_update_reserves.h"
+
+#include "pg_get_purses.h"
+#include "pg_del_purses.h"
+#include "pg_insert_purses.h"
+#include "pg_update_purses.h"
+
+#include "pg_get_historic_denomination_revenue.h"
+#include "pg_del_historic_denomination_revenue.h"
+#include "pg_insert_historic_denomination_revenue.h"
+#include "pg_update_historic_denomination_revenue.h"
+
+#include "pg_get_denomination_pending.h"
+#include "pg_del_denomination_pending.h"
+#include "pg_insert_denomination_pending.h"
+#include "pg_update_denomination_pending.h"
+
+#include "pg_get_historic_reserve_summary.h"
+#include "pg_del_historic_reserve_summary.h"
+#include "pg_insert_historic_reserve_summary.h"
+#include "pg_update_historic_reserve_summary.h"
+
+#include "pg_get_exchange_signkeys.h"
+#include "pg_del_exchange_signkeys.h"
+#include "pg_insert_exchange_signkeys.h"
+#include "pg_update_exchange_signkeys.h"
+
+#include "pg_get_wire_format_inconsistency.h"
+#include "pg_del_wire_format_inconsistency.h"
+#include "pg_insert_wire_format_inconsistency.h"
+#include "pg_update_wire_format_inconsistency.h"
+
+#include "pg_get_wire_out_inconsistency.h"
+#include "pg_del_wire_out_inconsistency.h"
+#include "pg_insert_wire_out_inconsistency.h"
+#include "pg_update_wire_out_inconsistency.h"
+
+#include "pg_get_reserve_balance_summary_wrong_inconsistency.h"
+#include "pg_del_reserve_balance_summary_wrong_inconsistency.h"
+#include "pg_insert_reserve_balance_summary_wrong_inconsistency.h"
+#include "pg_update_reserve_balance_summary_wrong_inconsistency.h"
+
+#include "pg_get_row_minor_inconsistencies.h"
+#include "pg_del_row_minor_inconsistencies.h"
+#include "pg_insert_row_minor_inconsistencies.h"
+#include "pg_update_row_minor_inconsistencies.h"
+
+#include "pg_get_balances.h"
+#include "pg_del_balances.h"
+#include "pg_insert_balances.h"
+#include "pg_update_balances.h"
+
+#include "pg_update_amount_arithmetic_inconsistency.h"
+#include "pg_update_deposit_confirmations.h"
 
 #define LOG(kind,...) GNUNET_log_from (kind, "taler-auditordb-postgres", \
                                        __VA_ARGS__)
@@ -449,6 +588,9 @@ libtaler_plugin_auditordb_postgres_init (void *cls)
     GNUNET_free (pg);
     return NULL;
   }
+
+  // MARK: CRUD
+
   plugin = GNUNET_new (struct TALER_AUDITORDB_Plugin);
   plugin->cls = pg;
   plugin->preflight = &postgres_preflight;
@@ -464,8 +606,9 @@ libtaler_plugin_auditordb_postgres_init (void *cls)
 
   plugin->get_auditor_progress
     = &TAH_PG_get_auditor_progress;
-  plugin->get_balance
-    = &TAH_PG_get_balance;
+
+  plugin->get_balance = &TAH_PG_get_balance;
+
   plugin->insert_auditor_progress
     = &TAH_PG_insert_auditor_progress;
   plugin->insert_balance
@@ -474,9 +617,10 @@ libtaler_plugin_auditordb_postgres_init (void *cls)
     = &TAH_PG_update_auditor_progress;
   plugin->update_balance
     = &TAH_PG_update_balance;
-
+/*
   plugin->insert_exchange_signkey
     = &TAH_PG_insert_exchange_signkey;
+  */
   plugin->insert_deposit_confirmation
     = &TAH_PG_insert_deposit_confirmation;
   plugin->get_deposit_confirmations
@@ -484,6 +628,30 @@ libtaler_plugin_auditordb_postgres_init (void *cls)
   plugin->delete_deposit_confirmation
     = &TAH_PG_delete_deposit_confirmation;
 
+
+  plugin->get_amount_arithmetic_inconsistency
+    = &TAH_PG_get_amount_arithmetic_inconsistency;
+  plugin->get_coin_inconsistency
+    = &TAH_PG_get_coin_inconsistency;
+  plugin->get_row_inconsistency
+    = &TAH_PG_get_row_inconsistency;
+
+
+  plugin->delete_row_inconsistency
+    = &TAH_PG_del_row_inconsistency;
+  plugin->delete_coin_inconsistency
+    = &TAH_PG_del_coin_inconsistency;
+  plugin->delete_amount_arithmetic_inconsistency
+    = &TAH_PG_del_amount_arithmetic_inconsistency;
+
+
+  plugin->insert_amount_arithmetic_inconsistency
+    = &TAH_PG_insert_amount_arithmetic_inconsistency;
+  plugin->insert_coin_inconsistency
+    = &TAH_PG_insert_coin_inconsistency;
+  plugin->insert_row_inconsistency
+    = &TAH_PG_insert_row_inconsistency;
+
   plugin->insert_reserve_info
     = &TAH_PG_insert_reserve_info;
   plugin->update_reserve_info
@@ -519,9 +687,10 @@ libtaler_plugin_auditordb_postgres_init (void *cls)
     = &TAH_PG_del_denomination_balance;
   plugin->get_denomination_balance
     = &TAH_PG_get_denomination_balance;
-
+/*
   plugin->insert_historic_denom_revenue
     = &TAH_PG_insert_historic_denom_revenue;
+    */
   plugin->select_historic_denom_revenue
     = &TAH_PG_select_historic_denom_revenue;
 
@@ -530,6 +699,199 @@ libtaler_plugin_auditordb_postgres_init (void *cls)
   plugin->select_historic_reserve_revenue
     = &TAH_PG_select_historic_reserve_revenue;
 
+
+  plugin->delete_emergency = &TAH_PG_del_emergency;
+  plugin->insert_emergency = &TAH_PG_insert_emergency;
+  plugin->get_emergency = &TAH_PG_get_emergency;
+
+  plugin->delete_emergency_by_count = &TAH_PG_del_emergency_by_count;
+  plugin->insert_emergency_by_count = &TAH_PG_insert_emergency_by_count;
+  plugin->get_emergency_by_count = &TAH_PG_get_emergency_by_count;
+
+
+  plugin->delete_denomination_key_validity_withdraw_inconsistency =
+    &TAH_PG_del_denomination_key_validity_withdraw_inconsistency;
+  plugin->insert_denomination_key_validity_withdraw_inconsistency =
+    &TAH_PG_insert_denomination_key_validity_withdraw_inconsistency;
+  plugin->get_denomination_key_validity_withdraw_inconsistency =
+    &TAH_PG_get_denomination_key_validity_withdraw_inconsistency;
+
+  plugin->delete_purse_not_closed_inconsistencies =
+    &TAH_PG_del_purse_not_closed_inconsistencies;
+  plugin->insert_purse_not_closed_inconsistencies =
+    &TAH_PG_insert_purse_not_closed_inconsistencies;
+  plugin->get_purse_not_closed_inconsistencies =
+    &TAH_PG_get_purse_not_closed_inconsistencies;
+
+
+  plugin->delete_reserve_balance_insufficient_inconsistency =
+    &TAH_PG_del_reserve_balance_insufficient_inconsistency;
+  plugin->insert_reserve_balance_insufficient_inconsistency =
+    &TAH_PG_insert_reserve_balance_insufficient_inconsistency;
+  plugin->get_reserve_balance_insufficient_inconsistency =
+    &TAH_PG_get_reserve_balance_insufficient_inconsistency;
+
+  plugin->delete_bad_sig_losses = &TAH_PG_del_bad_sig_losses;
+  plugin->insert_bad_sig_losses = &TAH_PG_insert_bad_sig_losses;
+  plugin->get_bad_sig_losses = &TAH_PG_get_bad_sig_losses;
+  plugin->update_bad_sig_losses = &TAH_PG_update_bad_sig_losses;
+
+  plugin->delete_auditor_closure_lags = &TAH_PG_del_auditor_closure_lags;
+  plugin->insert_auditor_closure_lags = &TAH_PG_insert_auditor_closure_lags;
+  plugin->get_auditor_closure_lags = &TAH_PG_get_auditor_closure_lags;
+
+
+  plugin->delete_progress = &TAH_PG_del_progress;
+
+
+  plugin->delete_refreshes_hanging = &TAH_PG_del_refreshes_hanging;
+  plugin->insert_refreshes_hanging = &TAH_PG_insert_refreshes_hanging;
+  plugin->get_refreshes_hanging = &TAH_PG_get_refreshes_hanging;
+
+  plugin->update_emergency_by_count = &TAH_PG_update_emergency_by_count;
+  plugin->update_row_inconsistency = &TAH_PG_update_row_inconsistency;
+  plugin->update_purse_not_closed_inconsistencies =
+    &TAH_PG_update_purse_not_closed_inconsistencies;
+  plugin->update_reserve_balance_insufficient_inconsistency =
+    &TAH_PG_update_reserve_balance_insufficient_inconsistency;
+  plugin->update_coin_inconsistency = &TAH_PG_update_coin_inconsistency;
+  plugin->update_progress = &TAH_PG_update_progress;
+  plugin->update_denomination_key_validity_withdraw_inconsistency =
+    &TAH_PG_update_denomination_key_validity_withdraw_inconsistency;
+  plugin->update_refreshes_hanging = &TAH_PG_update_refreshes_hanging;
+  plugin->update_emergency = &TAH_PG_update_emergency;
+  plugin->update_closure_lags = &TAH_PG_update_closure_lags;
+
+
+  plugin->delete_reserve_in_inconsistency =
+    &TAH_PG_del_reserve_in_inconsistency;
+  plugin->insert_reserve_in_inconsistency =
+    &TAH_PG_insert_reserve_in_inconsistency;
+  plugin->get_reserve_in_inconsistency = &TAH_PG_get_reserve_in_inconsistency;
+  plugin->update_reserve_in_inconsistency =
+    &TAH_PG_update_reserve_in_inconsistency;
+
+
+  plugin->delete_reserve_not_closed_inconsistency =
+    &TAH_PG_del_reserve_not_closed_inconsistency;
+  plugin->insert_reserve_not_closed_inconsistency =
+    &TAH_PG_insert_reserve_not_closed_inconsistency;
+  plugin->get_reserve_not_closed_inconsistency =
+    &TAH_PG_get_reserve_not_closed_inconsistency;
+  plugin->update_reserve_not_closed_inconsistency =
+    &TAH_PG_update_reserve_not_closed_inconsistency;
+
+
+  plugin->delete_denominations_without_sigs =
+    &TAH_PG_del_denominations_without_sigs;
+  plugin->insert_denominations_without_sigs =
+    &TAH_PG_insert_denominations_without_sigs;
+  plugin->get_denominations_without_sigs =
+    &TAH_PG_get_denominations_without_sigs;
+  plugin->update_denominations_without_sigs =
+    &TAH_PG_update_denominations_without_sigs;
+
+
+  plugin->delete_misattribution_in_inconsistency =
+    &TAH_PG_del_misattribution_in_inconsistency;
+  plugin->insert_misattribution_in_inconsistency =
+    &TAH_PG_insert_misattribution_in_inconsistency;
+  plugin->get_misattribution_in_inconsistency =
+    &TAH_PG_get_misattribution_in_inconsistency;
+  plugin->update_misattribution_in_inconsistency =
+    &TAH_PG_update_misattribution_in_inconsistency;
+
+
+  plugin->delete_reserves = &TAH_PG_del_reserves;
+  plugin->insert_reserves = &TAH_PG_insert_reserves;
+  plugin->get_reserves = &TAH_PG_get_reserves;
+  plugin->update_reserves = &TAH_PG_update_reserves;
+
+
+  plugin->delete_purses = &TAH_PG_del_purses;
+  plugin->insert_purses = &TAH_PG_insert_purses;
+  plugin->get_purses = &TAH_PG_get_purses;
+  plugin->update_purses = &TAH_PG_update_purses;
+
+
+  plugin->delete_historic_denomination_revenue =
+    &TAH_PG_del_historic_denomination_revenue;
+  plugin->insert_historic_denomination_revenue =
+    &TAH_PG_insert_historic_denomination_revenue;
+  plugin->get_historic_denomination_revenue =
+    &TAH_PG_get_historic_denomination_revenue;
+  plugin->update_historic_denomination_revenue =
+    &TAH_PG_update_historic_denomination_revenue;
+
+
+  plugin->delete_denomination_pending = &TAH_PG_del_denomination_pending;
+  plugin->insert_denomination_pending = &TAH_PG_insert_denomination_pending;
+  plugin->get_denomination_pending = &TAH_PG_get_denomination_pending;
+  plugin->update_denomination_pending = &TAH_PG_update_denomination_pending;
+
+
+  plugin->delete_historic_reserve_summary =
+    &TAH_PG_del_historic_reserve_summary;
+  plugin->insert_historic_reserve_summary =
+    &TAH_PG_insert_historic_reserve_summary;
+  plugin->get_historic_reserve_summary = &TAH_PG_get_historic_reserve_summary;
+  plugin->update_historic_reserve_summary =
+    &TAH_PG_update_historic_reserve_summary;
+
+
+  plugin->delete_exchange_signkeys = &TAH_PG_del_exchange_signkeys;
+  plugin->insert_exchange_signkeys = &TAH_PG_insert_exchange_signkeys;
+  plugin->get_exchange_signkeys = &TAH_PG_get_exchange_signkeys;
+  plugin->update_exchange_signkeys = &TAH_PG_update_exchange_signkeys;
+
+
+  plugin->delete_wire_format_inconsistency =
+    &TAH_PG_del_wire_format_inconsistency;
+  plugin->insert_wire_format_inconsistency =
+    &TAH_PG_insert_wire_format_inconsistency;
+  plugin->get_wire_format_inconsistency = &TAH_PG_get_wire_format_inconsistency;
+  plugin->update_wire_format_inconsistency =
+    &TAH_PG_update_wire_format_inconsistency;
+
+
+  plugin->delete_wire_out_inconsistency = &TAH_PG_del_wire_out_inconsistency;
+  plugin->insert_wire_out_inconsistency = &TAH_PG_insert_wire_out_inconsistency;
+  plugin->get_wire_out_inconsistency = &TAH_PG_get_wire_out_inconsistency;
+  plugin->update_wire_out_inconsistency = &TAH_PG_update_wire_out_inconsistency;
+
+
+  plugin->delete_reserve_balance_summary_wrong_inconsistency =
+    &TAH_PG_del_reserve_balance_summary_wrong_inconsistency;
+  plugin->insert_reserve_balance_summary_wrong_inconsistency =
+    &TAH_PG_insert_reserve_balance_summary_wrong_inconsistency;
+  plugin->get_reserve_balance_summary_wrong_inconsistency =
+    &TAH_PG_get_reserve_balance_summary_wrong_inconsistency;
+  plugin->update_reserve_balance_summary_wrong_inconsistency =
+    &TAH_PG_update_reserve_balance_summary_wrong_inconsistency;
+
+
+  plugin->delete_row_minor_inconsistencies =
+    &TAH_PG_del_row_minor_inconsistencies;
+  plugin->insert_row_minor_inconsistencies =
+    &TAH_PG_insert_row_minor_inconsistencies;
+  plugin->get_row_minor_inconsistencies = &TAH_PG_get_row_minor_inconsistencies;
+  plugin->update_row_minor_inconsistencies =
+    &TAH_PG_update_row_minor_inconsistencies;
+
+  plugin->delete_fee_time_inconsistency = &TAH_PG_del_fee_time_inconsistency;
+  plugin->insert_fee_time_inconsistency = &TAH_PG_insert_fee_time_inconsistency;
+  plugin->get_fee_time_inconsistency = &TAH_PG_get_fee_time_inconsistency;
+  plugin->update_fee_time_inconsistency = &TAH_PG_update_fee_time_inconsistency;
+
+  plugin->delete_balances = &TAH_PG_del_balances;
+  plugin->insert_balances = &TAH_PG_insert_balances;
+  plugin->get_balances = &TAH_PG_get_balances;
+  plugin->update_balances = &TAH_PG_update_balances;
+
+  plugin->update_deposit_confirmations = &TAH_PG_update_deposit_confirmations;
+  plugin->update_amount_arithmetic_inconsistency =
+    &TAH_PG_update_amount_arithmetic_inconsistency;
+
   return plugin;
 }