diff options
author | Christian Grothoff <christian@grothoff.org> | 2024-07-29 18:15:30 +0200 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2024-07-29 18:15:30 +0200 |
commit | 67b42cf8eb0ab06eaa1f4d21e0182f7062337994 (patch) | |
tree | 82fc2407a053fb9883b5bfa552fef8c970ff8f7c | |
parent | 3b39ad1e7b01a3001372823c98603c45c25d520f (diff) |
DCE
97 files changed, 413 insertions, 4697 deletions
diff --git a/src/auditor/Makefile.am b/src/auditor/Makefile.am index cc1cd3979..866f5992e 100644 --- a/src/auditor/Makefile.am +++ b/src/auditor/Makefile.am @@ -173,31 +173,22 @@ taler_auditor_httpd_SOURCES = \ taler-auditor-httpd_coin-inconsistency-del.c taler-auditor-httpd_coin-inconsistency-del.h \ taler-auditor-httpd_row-inconsistency-del.c taler-auditor-httpd_row-inconsistency-del.h \ taler-auditor-httpd_amount-arithmetic-inconsistency-upd.c taler-auditor-httpd_amount-arithmetic-inconsistency-upd.h \ - taler-auditor-httpd_coin-inconsistency-put.c taler-auditor-httpd_coin-inconsistency-put.h \ - taler-auditor-httpd_row-inconsistency-put.c taler-auditor-httpd_row-inconsistency-put.h \ - taler-auditor-httpd_emergency-put.c taler-auditor-httpd_emergency-put.h \ taler-auditor-httpd_emergency-get.c taler-auditor-httpd_emergency-get.h \ taler-auditor-httpd_emergency-del.c taler-auditor-httpd_emergency-del.h \ - taler-auditor-httpd_emergency-by-count-put.c taler-auditor-httpd_emergency-by-count-put.h \ taler-auditor-httpd_emergency-by-count-get.c taler-auditor-httpd_emergency-by-count-get.h \ taler-auditor-httpd_emergency-by-count-del.c taler-auditor-httpd_emergency-by-count-del.h \ - taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.c taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.h \ taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-get.c taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-get.h \ taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-del.c taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-del.h \ - taler-auditor-httpd_purse-not-closed-inconsistencies-put.c taler-auditor-httpd_purse-not-closed-inconsistencies-put.h \ taler-auditor-httpd_purse-not-closed-inconsistencies-get.c taler-auditor-httpd_purse-not-closed-inconsistencies-get.h \ taler-auditor-httpd_purse-not-closed-inconsistencies-del.c taler-auditor-httpd_purse-not-closed-inconsistencies-del.h \ - taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.c taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.h \ taler-auditor-httpd_reserve-balance-insufficient-inconsistency-get.c taler-auditor-httpd_reserve-balance-insufficient-inconsistency-get.h \ taler-auditor-httpd_reserve-balance-insufficient-inconsistency-del.c taler-auditor-httpd_reserve-balance-insufficient-inconsistency-del.h \ taler-auditor-httpd_bad-sig-losses-get.c taler-auditor-httpd_bad-sig-losses-get.h \ taler-auditor-httpd_bad-sig-losses-del.c taler-auditor-httpd_bad-sig-losses-del.h \ taler-auditor-httpd_bad-sig-losses-upd.c taler-auditor-httpd_bad-sig-losses-upd.h \ - taler-auditor-httpd_closure-lags-put.c taler-auditor-httpd_closure-lags-put.h \ taler-auditor-httpd_closure-lags-get.c taler-auditor-httpd_closure-lags-get.h \ taler-auditor-httpd_closure-lags-del.c taler-auditor-httpd_closure-lags-del.h \ taler-auditor-httpd_progress-get.c taler-auditor-httpd_progress-get.h \ - taler-auditor-httpd_refreshes-hanging-put.c taler-auditor-httpd_refreshes-hanging-put.h \ taler-auditor-httpd_refreshes-hanging-get.c taler-auditor-httpd_refreshes-hanging-get.h \ taler-auditor-httpd_refreshes-hanging-del.c taler-auditor-httpd_refreshes-hanging-del.h \ taler-auditor-httpd_emergency-by-count-upd.c taler-auditor-httpd_emergency-by-count-upd.h \ @@ -210,47 +201,37 @@ taler_auditor_httpd_SOURCES = \ taler-auditor-httpd_emergency-upd.c taler-auditor-httpd_emergency-upd.h \ taler-auditor-httpd_closure-lags-upd.c taler-auditor-httpd_closure-lags-upd.h \ taler-auditor-httpd_reserve-in-inconsistency-del.c taler-auditor-httpd_reserve-in-inconsistency-del.h \ - taler-auditor-httpd_reserve-in-inconsistency-put.c taler-auditor-httpd_reserve-in-inconsistency-put.h \ taler-auditor-httpd_reserve-in-inconsistency-get.c taler-auditor-httpd_reserve-in-inconsistency-get.h \ taler-auditor-httpd_reserve-in-inconsistency-upd.c taler-auditor-httpd_reserve-in-inconsistency-upd.h \ taler-auditor-httpd_reserve-not-closed-inconsistency-del.c taler-auditor-httpd_reserve-not-closed-inconsistency-del.h \ - taler-auditor-httpd_reserve-not-closed-inconsistency-put.c taler-auditor-httpd_reserve-not-closed-inconsistency-put.h \ taler-auditor-httpd_reserve-not-closed-inconsistency-get.c taler-auditor-httpd_reserve-not-closed-inconsistency-get.h \ taler-auditor-httpd_reserve-not-closed-inconsistency-upd.c taler-auditor-httpd_reserve-not-closed-inconsistency-upd.h \ taler-auditor-httpd_denominations-without-sigs-del.c taler-auditor-httpd_denominations-without-sigs-del.h \ - taler-auditor-httpd_denominations-without-sigs-put.c taler-auditor-httpd_denominations-without-sigs-put.h \ taler-auditor-httpd_denominations-without-sigs-get.c taler-auditor-httpd_denominations-without-sigs-get.h \ taler-auditor-httpd_denominations-without-sigs-upd.c taler-auditor-httpd_denominations-without-sigs-upd.h \ taler-auditor-httpd_misattribution-in-inconsistency-del.c taler-auditor-httpd_misattribution-in-inconsistency-del.h \ - taler-auditor-httpd_misattribution-in-inconsistency-put.c taler-auditor-httpd_misattribution-in-inconsistency-put.h \ taler-auditor-httpd_misattribution-in-inconsistency-get.c taler-auditor-httpd_misattribution-in-inconsistency-get.h \ taler-auditor-httpd_misattribution-in-inconsistency-upd.c taler-auditor-httpd_misattribution-in-inconsistency-upd.h \ taler-auditor-httpd_reserves-get.c taler-auditor-httpd_reserves-get.h \ taler-auditor-httpd_purses-get.c taler-auditor-httpd_purses-get.h \ taler-auditor-httpd_historic-denomination-revenue-get.c taler-auditor-httpd_historic-denomination-revenue-get.h \ taler-auditor-httpd_denomination-pending-del.c taler-auditor-httpd_denomination-pending-del.h \ - taler-auditor-httpd_denomination-pending-put.c taler-auditor-httpd_denomination-pending-put.h \ taler-auditor-httpd_denomination-pending-get.c taler-auditor-httpd_denomination-pending-get.h \ taler-auditor-httpd_denomination-pending-upd.c taler-auditor-httpd_denomination-pending-upd.h \ taler-auditor-httpd_historic-reserve-summary-get.c taler-auditor-httpd_historic-reserve-summary-get.h \ taler-auditor-httpd_wire-format-inconsistency-del.c taler-auditor-httpd_wire-format-inconsistency-del.h \ - taler-auditor-httpd_wire-format-inconsistency-put.c taler-auditor-httpd_wire-format-inconsistency-put.h \ taler-auditor-httpd_wire-format-inconsistency-get.c taler-auditor-httpd_wire-format-inconsistency-get.h \ taler-auditor-httpd_wire-format-inconsistency-upd.c taler-auditor-httpd_wire-format-inconsistency-upd.h \ taler-auditor-httpd_wire-out-inconsistency-del.c taler-auditor-httpd_wire-out-inconsistency-del.h \ - taler-auditor-httpd_wire-out-inconsistency-put.c taler-auditor-httpd_wire-out-inconsistency-put.h \ taler-auditor-httpd_wire-out-inconsistency-get.c taler-auditor-httpd_wire-out-inconsistency-get.h \ taler-auditor-httpd_wire-out-inconsistency-upd.c taler-auditor-httpd_wire-out-inconsistency-upd.h \ taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-del.c taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-del.h \ - taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.c taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.h \ taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-get.c taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-get.h \ taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-upd.c taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-upd.h \ taler-auditor-httpd_row-minor-inconsistencies-del.c taler-auditor-httpd_row-minor-inconsistencies-del.h \ - taler-auditor-httpd_row-minor-inconsistencies-put.c taler-auditor-httpd_row-minor-inconsistencies-put.h \ taler-auditor-httpd_row-minor-inconsistencies-get.c taler-auditor-httpd_row-minor-inconsistencies-get.h \ taler-auditor-httpd_row-minor-inconsistencies-upd.c taler-auditor-httpd_row-minor-inconsistencies-upd.h \ taler-auditor-httpd_fee-time-inconsistency-del.c taler-auditor-httpd_fee-time-inconsistency-del.h \ - taler-auditor-httpd_fee-time-inconsistency-put.c taler-auditor-httpd_fee-time-inconsistency-put.h \ taler-auditor-httpd_fee-time-inconsistency-get.c taler-auditor-httpd_fee-time-inconsistency-get.h \ taler-auditor-httpd_fee-time-inconsistency-upd.c taler-auditor-httpd_fee-time-inconsistency-upd.h \ taler-auditor-httpd_balances-get.c taler-auditor-httpd_balances-get.h \ diff --git a/src/auditor/taler-auditor-httpd.c b/src/auditor/taler-auditor-httpd.c index 722d82946..48667390d 100644 --- a/src/auditor/taler-auditor-httpd.c +++ b/src/auditor/taler-auditor-httpd.c @@ -37,33 +37,25 @@ #include "taler-auditor-httpd_amount-arithmetic-inconsistency-del.h" #include "taler-auditor-httpd_amount-arithmetic-inconsistency-upd.h" #include "taler-auditor-httpd_coin-inconsistency-get.h" -#include "taler-auditor-httpd_coin-inconsistency-put.h" #include "taler-auditor-httpd_coin-inconsistency-del.h" #include "taler-auditor-httpd_row-inconsistency-get.h" -#include "taler-auditor-httpd_row-inconsistency-put.h" #include "taler-auditor-httpd_row-inconsistency-del.h" #include "taler-auditor-httpd_emergency-get.h" -#include "taler-auditor-httpd_emergency-put.h" #include "taler-auditor-httpd_emergency-del.h" #include "taler-auditor-httpd_emergency-by-count-get.h" -#include "taler-auditor-httpd_emergency-by-count-put.h" #include "taler-auditor-httpd_emergency-by-count-del.h" #include \ "taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-get.h" #include \ - "taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.h" -#include \ "taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-del.h" #include "taler-auditor-httpd_purse-not-closed-inconsistencies-get.h" -#include "taler-auditor-httpd_purse-not-closed-inconsistencies-put.h" #include "taler-auditor-httpd_purse-not-closed-inconsistencies-del.h" #include "taler-auditor-httpd_reserve-balance-insufficient-inconsistency-get.h" -#include "taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.h" #include "taler-auditor-httpd_reserve-balance-insufficient-inconsistency-del.h" #include "taler-auditor-httpd_bad-sig-losses-get.h" @@ -71,13 +63,11 @@ #include "taler-auditor-httpd_bad-sig-losses-upd.h" #include "taler-auditor-httpd_closure-lags-get.h" -#include "taler-auditor-httpd_closure-lags-put.h" #include "taler-auditor-httpd_closure-lags-del.h" #include "taler-auditor-httpd_progress-get.h" #include "taler-auditor-httpd_refreshes-hanging-get.h" -#include "taler-auditor-httpd_refreshes-hanging-put.h" #include "taler-auditor-httpd_refreshes-hanging-del.h" #include "taler-auditor-httpd_mhd.h" @@ -96,22 +86,18 @@ #include "taler-auditor-httpd_row-minor-inconsistencies-upd.h" #include "taler-auditor-httpd_reserve-in-inconsistency-del.h" -#include "taler-auditor-httpd_reserve-in-inconsistency-put.h" #include "taler-auditor-httpd_reserve-in-inconsistency-get.h" #include "taler-auditor-httpd_reserve-in-inconsistency-upd.h" #include "taler-auditor-httpd_reserve-not-closed-inconsistency-del.h" -#include "taler-auditor-httpd_reserve-not-closed-inconsistency-put.h" #include "taler-auditor-httpd_reserve-not-closed-inconsistency-get.h" #include "taler-auditor-httpd_reserve-not-closed-inconsistency-upd.h" #include "taler-auditor-httpd_denominations-without-sigs-del.h" -#include "taler-auditor-httpd_denominations-without-sigs-put.h" #include "taler-auditor-httpd_denominations-without-sigs-get.h" #include "taler-auditor-httpd_denominations-without-sigs-upd.h" #include "taler-auditor-httpd_misattribution-in-inconsistency-del.h" -#include "taler-auditor-httpd_misattribution-in-inconsistency-put.h" #include "taler-auditor-httpd_misattribution-in-inconsistency-get.h" #include "taler-auditor-httpd_misattribution-in-inconsistency-upd.h" @@ -122,32 +108,26 @@ #include "taler-auditor-httpd_historic-reserve-summary-get.h" #include "taler-auditor-httpd_denomination-pending-del.h" -#include "taler-auditor-httpd_denomination-pending-put.h" #include "taler-auditor-httpd_denomination-pending-get.h" #include "taler-auditor-httpd_denomination-pending-upd.h" #include "taler-auditor-httpd_wire-format-inconsistency-del.h" -#include "taler-auditor-httpd_wire-format-inconsistency-put.h" #include "taler-auditor-httpd_wire-format-inconsistency-get.h" #include "taler-auditor-httpd_wire-format-inconsistency-upd.h" #include "taler-auditor-httpd_wire-out-inconsistency-del.h" -#include "taler-auditor-httpd_wire-out-inconsistency-put.h" #include "taler-auditor-httpd_wire-out-inconsistency-get.h" #include "taler-auditor-httpd_wire-out-inconsistency-upd.h" #include "taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-del.h" -#include "taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.h" #include "taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-get.h" #include "taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-upd.h" #include "taler-auditor-httpd_row-minor-inconsistencies-del.h" -#include "taler-auditor-httpd_row-minor-inconsistencies-put.h" #include "taler-auditor-httpd_row-minor-inconsistencies-get.h" #include "taler-auditor-httpd_row-minor-inconsistencies-upd.h" #include "taler-auditor-httpd_fee-time-inconsistency-del.h" -#include "taler-auditor-httpd_fee-time-inconsistency-put.h" #include "taler-auditor-httpd_fee-time-inconsistency-get.h" #include "taler-auditor-httpd_fee-time-inconsistency-upd.h" @@ -457,10 +437,6 @@ handle_mhd_request (void *cls, "application/json", NULL, 0, &TAH_COIN_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/coin-inconsistency", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_COIN_INCONSISTENCY_PUT_handler, MHD_HTTP_OK, true }, { "/monitoring/coin-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -473,10 +449,6 @@ handle_mhd_request (void *cls, "application/json", NULL, 0, &TAH_ROW_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/row-inconsistency", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_ROW_INCONSISTENCY_PUT_handler, MHD_HTTP_OK, true }, { "/monitoring/row-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -505,11 +477,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_CLOSURE_LAGS_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/closure-lags", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_CLOSURE_LAGS_PUT_handler, - MHD_HTTP_OK, true }, { "/monitoring/closure-lags", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -525,11 +492,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_EMERGENCY_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/emergency", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_EMERGENCY_PUT_handler, - MHD_HTTP_OK, true }, { "/monitoring/emergency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -545,11 +507,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_REFRESHES_HANGING_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/refreshes-hanging", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_REFRESHES_HANGING_PUT_handler, - MHD_HTTP_OK, true }, { "/monitoring/refreshes-hanging", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -567,12 +524,6 @@ handle_mhd_request (void *cls, &TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, { "/monitoring/denomination-key-validity-withdraw-inconsistency", - MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_handler, - MHD_HTTP_OK, true }, - { "/monitoring/denomination-key-validity-withdraw-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -596,12 +547,6 @@ handle_mhd_request (void *cls, &TAH_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, { "/monitoring/reserve-balance-insufficient-inconsistency", - MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_handler_put, - MHD_HTTP_OK, true }, - { "/monitoring/reserve-balance-insufficient-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -618,11 +563,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_PURSE_NOT_CLOSED_INCONSISTENCIES_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/purse-not-closed-inconsistencies", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_handler, - MHD_HTTP_OK, true }, { "/monitoring/purse-not-closed-inconsistencies", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -638,11 +578,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_EMERGENCY_BY_COUNT_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/emergency-by-count", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_EMERGENCY_BY_COUNT_PUT_handler, - MHD_HTTP_OK, true }, { "/monitoring/emergency-by-count", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -658,11 +593,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_RESERVE_IN_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/reserve-in-inconsistency", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_RESERVE_IN_INCONSISTENCY_handler_put, - MHD_HTTP_OK, true }, { "/monitoring/reserve-in-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -678,11 +608,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_RESERVE_NOT_CLOSED_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/reserve-not-closed-inconsistency", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_RESERVE_NOT_CLOSED_INCONSISTENCY_handler_put, - MHD_HTTP_OK, true }, { "/monitoring/reserve-not-closed-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -698,11 +623,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_DENOMINATIONS_WITHOUT_SIGS_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/denominations-without-sigs", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_DENOMINATIONS_WITHOUT_SIGS_handler_put, - MHD_HTTP_OK, true }, { "/monitoring/denominations-without-sigs", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -718,11 +638,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_MISATTRIBUTION_IN_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/misattribution-in-inconsistency", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_MISATTRIBUTION_IN_INCONSISTENCY_handler_put, - MHD_HTTP_OK, true }, { "/monitoring/misattribution-in-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -753,11 +668,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_DENOMINATION_PENDING_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/denomination-pending", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_DENOMINATION_PENDING_handler_put, - MHD_HTTP_OK, true }, { "/monitoring/denomination-pending", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -773,11 +683,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_WIRE_FORMAT_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/wire-format-inconsistency", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_WIRE_FORMAT_INCONSISTENCY_handler_put, - MHD_HTTP_OK, true }, { "/monitoring/wire-format-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -793,11 +698,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_WIRE_OUT_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/wire-out-inconsistency", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_WIRE_OUT_INCONSISTENCY_handler_put, - MHD_HTTP_OK, true }, { "/monitoring/wire-out-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -815,12 +715,6 @@ handle_mhd_request (void *cls, &TAH_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, { "/monitoring/reserve-balance-summary-wrong-inconsistency", - MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_handler_put, - MHD_HTTP_OK, true }, - { "/monitoring/reserve-balance-summary-wrong-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -837,11 +731,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_ROW_MINOR_INCONSISTENCIES_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/row-minor-inconsistencies", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_ROW_MINOR_INCONSISTENCIES_handler_put, - MHD_HTTP_OK, true }, { "/monitoring/row-minor-inconsistencies", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, @@ -857,11 +746,6 @@ handle_mhd_request (void *cls, NULL, 0, &TAH_FEE_TIME_INCONSISTENCY_handler_get, MHD_HTTP_OK, true }, - { "/monitoring/fee-time-inconsistency", MHD_HTTP_METHOD_PUT, - "application/json", - NULL, 0, - &TAH_FEE_TIME_INCONSISTENCY_handler_put, - MHD_HTTP_OK, true }, { "/monitoring/fee-time-inconsistency", MHD_HTTP_METHOD_DELETE, "application/json", NULL, 0, diff --git a/src/auditor/taler-auditor-httpd_amount-arithmetic-inconsistency-upd.h b/src/auditor/taler-auditor-httpd_amount-arithmetic-inconsistency-upd.h index ee2418927..bbda9d3cd 100644 --- a/src/auditor/taler-auditor-httpd_amount-arithmetic-inconsistency-upd.h +++ b/src/auditor/taler-auditor-httpd_amount-arithmetic-inconsistency-upd.h @@ -22,13 +22,12 @@ #include "taler-auditor-httpd.h" MHD_RESULT -TAH_AMOUNT_ARITHMETIC_INCONSISTENCY_handler_update (struct - TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_AMOUNT_ARITHMETIC_INCONSISTENCY_UPD_H +TAH_AMOUNT_ARITHMETIC_INCONSISTENCY_handler_update ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_bad-sig-losses-del.h b/src/auditor/taler-auditor-httpd_bad-sig-losses-del.h index c55477849..9073aa216 100644 --- a/src/auditor/taler-auditor-httpd_bad-sig-losses-del.h +++ b/src/auditor/taler-auditor-httpd_bad-sig-losses-del.h @@ -46,13 +46,13 @@ TEAH_BAD_SIG_LOSSES_DELETE_done (void); * @return MHD result code */ MHD_RESULT -TAH_BAD_SIG_LOSSES_handler_delete (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_BAD_SIG_LOSSES_handler_delete ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); #endif diff --git a/src/auditor/taler-auditor-httpd_bad-sig-losses-get.h b/src/auditor/taler-auditor-httpd_bad-sig-losses-get.h index 81c98d818..78bf18e55 100644 --- a/src/auditor/taler-auditor-httpd_bad-sig-losses-get.h +++ b/src/auditor/taler-auditor-httpd_bad-sig-losses-get.h @@ -46,13 +46,13 @@ TEAH_BAD_SIG_LOSSES_GET_done (void); * @return MHD result code */ MHD_RESULT -TAH_BAD_SIG_LOSSES_handler_get (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_BAD_SIG_LOSSES_handler_get ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); #endif diff --git a/src/auditor/taler-auditor-httpd_balances-get.h b/src/auditor/taler-auditor-httpd_balances-get.h index d9d062b86..8bc8b97e0 100644 --- a/src/auditor/taler-auditor-httpd_balances-get.h +++ b/src/auditor/taler-auditor-httpd_balances-get.h @@ -15,7 +15,7 @@ */ - #ifndef SRC_TALER_AUDITOR_HTTPD_BALANCES_GET_H +#ifndef SRC_TALER_AUDITOR_HTTPD_BALANCES_GET_H #define SRC_TALER_AUDITOR_HTTPD_BALANCES_GET_H #include <gnunet/gnunet_util_lib.h> @@ -45,13 +45,13 @@ TEAH_BAD_BALANCES_GET_done (void); * @return MHD result code */ MHD_RESULT -TAH_BALANCES_handler_get (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_BALANCES_handler_get ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_BALANCES_GET_H +#endif diff --git a/src/auditor/taler-auditor-httpd_closure-lags-del.h b/src/auditor/taler-auditor-httpd_closure-lags-del.h index 65d6eb17d..fbc2b03e1 100644 --- a/src/auditor/taler-auditor-httpd_closure-lags-del.h +++ b/src/auditor/taler-auditor-httpd_closure-lags-del.h @@ -35,24 +35,24 @@ void TEAH_CLOSURE_LAGS_DELETE_done (void); /** -* Handle a "/closure-lags" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ + * Handle a "/closure-lags" request. Parses the JSON, and, if + * successful, checks the signatures and stores the result in the DB. + * + * @param rh context of the handler + * @param connection the MHD connection to handle + * @param[in,out] connection_cls the connection's closure (can be updated) + * @param upload_data upload data + * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' + * @return MHD result code + */ MHD_RESULT -TAH_CLOSURE_LAGS_handler_delete (struct - TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_CLOSURE_LAGS_DEL_H +TAH_CLOSURE_LAGS_handler_delete ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_closure-lags-get.h b/src/auditor/taler-auditor-httpd_closure-lags-get.h index 0d9ae88f5..5092bbec1 100644 --- a/src/auditor/taler-auditor-httpd_closure-lags-get.h +++ b/src/auditor/taler-auditor-httpd_closure-lags-get.h @@ -29,29 +29,30 @@ void TEAH_CLOSURE_LAGS_GET_init (void); /** -* Shut down subsystem. -*/ + * Shut down subsystem. + */ void TEAH_CLOSURE_LAGS_GET_done (void); /** -* Handle a "/closure-lags" request. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ + * Handle a "/closure-lags" request. + * + * @param rh context of the handler + * @param connection the MHD connection to handle + * @param[in,out] connection_cls the connection's closure (can be updated) + * @param upload_data upload data + * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' + * @return MHD result code + */ MHD_RESULT -TAH_CLOSURE_LAGS_handler_get (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_CLOSURE_LAGS_handler_get ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_CLOSURE_LAGS_GET_H +#endif diff --git a/src/auditor/taler-auditor-httpd_closure-lags-put.c b/src/auditor/taler-auditor-httpd_closure-lags-put.c deleted file mode 100644 index e57740efc..000000000 --- a/src/auditor/taler-auditor-httpd_closure-lags-put.c +++ /dev/null @@ -1,158 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_closure-lags-put.h" - -/** -* We have parsed the JSON information about the closure-lags, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the closure-lags -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_ClosureLags *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_auditor_closure_lags (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /closure-lags in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "closure-lags"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "CLOSURE_LAGS_OK")); -} - - -MHD_RESULT -TAH_CLOSURE_LAGS_PUT_handler ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_ClosureLags dc; - - struct GNUNET_TIME_Timestamp d = { 0 }; - - struct GNUNET_JSON_Specification spec[] = { - - TALER_JSON_spec_amount ("amount", TAH_currency, &dc.amount), - GNUNET_JSON_spec_timestamp ("deadline", &d), - GNUNET_JSON_spec_fixed_auto ("wtid", &dc.wtid), - GNUNET_JSON_spec_string ("account", (const char **) &dc.account), - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - dc.deadline = d.abs_time; - - MHD_RESULT res; - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_CLOSURE_LAGS_PUT_init (void) -{ - -} - - -void -TEAH_CLOSURE_LAGS_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_closure-lags-put.h b/src/auditor/taler-auditor-httpd_closure-lags-put.h deleted file mode 100644 index 683aaed91..000000000 --- a/src/auditor/taler-auditor-httpd_closure-lags-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_CLOSURE_LAGS_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_CLOSURE_LAGS_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_CLOSURE_LAGS_PUT_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_CLOSURE_LAGS_PUT_done (void); - - -/** -* Handle a "/closure-lags" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_CLOSURE_LAGS_PUT_handler (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_CLOSURE_LAGS_PUT_H diff --git a/src/auditor/taler-auditor-httpd_closure-lags-upd.h b/src/auditor/taler-auditor-httpd_closure-lags-upd.h index b53f103c8..b77146d12 100644 --- a/src/auditor/taler-auditor-httpd_closure-lags-upd.h +++ b/src/auditor/taler-auditor-httpd_closure-lags-upd.h @@ -23,12 +23,12 @@ #include "taler-auditor-httpd.h" MHD_RESULT -TAH_CLOSURE_LAGS_handler_update (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_CLOSURE_LAGS_UPD_H +TAH_CLOSURE_LAGS_handler_update ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_coin-inconsistency-del.h b/src/auditor/taler-auditor-httpd_coin-inconsistency-del.h index 57752297b..65fabd05a 100644 --- a/src/auditor/taler-auditor-httpd_coin-inconsistency-del.h +++ b/src/auditor/taler-auditor-httpd_coin-inconsistency-del.h @@ -43,15 +43,17 @@ TEAH_COIN_INCONSISTENCY_DELETE_done (void); * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' * @return MHD result code - */ + */ MHD_RESULT -TAH_COIN_INCONSISTENCY_handler_delete (struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_COIN_INCONSISTENCY_handler_delete ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_COIN_INCONSISTENCY_DEL_H +#endif diff --git a/src/auditor/taler-auditor-httpd_coin-inconsistency-get.h b/src/auditor/taler-auditor-httpd_coin-inconsistency-get.h index 659455852..1434700fc 100644 --- a/src/auditor/taler-auditor-httpd_coin-inconsistency-get.h +++ b/src/auditor/taler-auditor-httpd_coin-inconsistency-get.h @@ -41,16 +41,17 @@ TEAH_COIN_INCONSISTENCY_GET_done (void); * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' * @return MHD result code - */ + */ MHD_RESULT -TAH_COIN_INCONSISTENCY_handler_get (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_COIN_INCONSISTENCY_handler_get ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_COIN_INCONSISTENCY_GET_H +#endif diff --git a/src/auditor/taler-auditor-httpd_coin-inconsistency-put.c b/src/auditor/taler-auditor-httpd_coin-inconsistency-put.c deleted file mode 100644 index 4e4661573..000000000 --- a/src/auditor/taler-auditor-httpd_coin-inconsistency-put.c +++ /dev/null @@ -1,158 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_coin-inconsistency-put.h" - -/** - * We have parsed the JSON information about the deposit, do some - * basic sanity checks (especially that the signature on the coin is - * valid, and that this type of coin exists) and then execute the - * deposit. - * - * @param connection the MHD connection to handle - * @param dc information about the deposit confirmation - * @param es information about the exchange's signing key - * @return MHD result code - */ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_CoinInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_coin_inconsistency (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /insert-coin in database\n"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "insert coin"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "INSERT_COIN_OK")); -} - - -MHD_RESULT -TAH_COIN_INCONSISTENCY_PUT_handler ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_CoinInconsistency dc; - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_string ("operation", (const char **) &dc.operation), - TALER_JSON_spec_amount ("exchange_amount", TAH_currency, - &dc.exchange_amount), - TALER_JSON_spec_amount ("auditor_amount", TAH_currency,&dc.auditor_amount), - GNUNET_JSON_spec_fixed_auto ("coin_pub", &dc.coin_pub), - GNUNET_JSON_spec_bool ("profitable", &dc.profitable), - - GNUNET_JSON_spec_end () - }; - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - - GNUNET_JSON_parse_free (spec); - json_decref (json); - return res; - -} - - -void -TEAH_COIN_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_COIN_INCONSISTENCY_PUT_done (void) -{ - -}
\ No newline at end of file diff --git a/src/auditor/taler-auditor-httpd_coin-inconsistency-put.h b/src/auditor/taler-auditor-httpd_coin-inconsistency-put.h deleted file mode 100644 index 4e8e1024a..000000000 --- a/src/auditor/taler-auditor-httpd_coin-inconsistency-put.h +++ /dev/null @@ -1,57 +0,0 @@ -/* - 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/> - */ - -#ifndef SRC_TALER_AUDITOR_HTTPD_COIN_INCONSISTENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_COIN_INCONSISTENCY_PUT_H - - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** - * Initialize subsystem. - */ -void -TEAH_COIN_INCONSISTENCY_PUT_init (void); - -/** - * Shut down subsystem. - */ -void -TEAH_COIN_INCONSISTENCY_PUT_done (void); - - -/** - * Handle a "/deposit-confirmation" request. Parses the JSON, and, if - * successful, checks the signatures and stores the result in the DB. - * - * @param rh context of the handler - * @param connection the MHD connection to handle - * @param[in,out] connection_cls the connection's closure (can be updated) - * @param upload_data upload data - * @param[in,out] upload_data_size number of bytes (left) in @a upload_data - * @return MHD result code - */ -MHD_RESULT -TAH_COIN_INCONSISTENCY_PUT_handler (struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_COIN_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_coin-inconsistency-upd.h b/src/auditor/taler-auditor-httpd_coin-inconsistency-upd.h index edcf17387..f7a179ddf 100644 --- a/src/auditor/taler-auditor-httpd_coin-inconsistency-upd.h +++ b/src/auditor/taler-auditor-httpd_coin-inconsistency-upd.h @@ -23,12 +23,12 @@ #include "taler-auditor-httpd.h" MHD_RESULT -TAH_COIN_INCONSISTENCY_handler_update (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_COIN_INCONSISTENCY_UPD_H +TAH_COIN_INCONSISTENCY_handler_update ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-del.h b/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-del.h index 2c266d266..ce0df1f09 100644 --- a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-del.h +++ b/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-del.h @@ -17,7 +17,7 @@ #ifndef \ SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_DEL_H #define \ - SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_DEL_H + SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_DEL_H #include <microhttpd.h> @@ -44,26 +44,17 @@ TEAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_DELETE_done (void); * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' * @return MHD result code - */ + */ MHD_RESULT -TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_handler_delete (struct - TAH_RequestHandler - *rh, - struct - MHD_Connection - * - connection, - void ** - connection_cls, - const char - * - upload_data, - size_t * - upload_data_size, - const char - *const - args[]); +TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_handler_delete ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_DEL_H +#endif diff --git a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-get.h b/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-get.h index e33620390..2d3bce575 100644 --- a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-get.h +++ b/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-get.h @@ -18,7 +18,7 @@ #ifndef \ SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_GET_H #define \ - SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_GET_H + SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_GET_H #include <gnunet/gnunet_util_lib.h> #include <microhttpd.h> @@ -37,31 +37,24 @@ void TEAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_GET_done (void); /** -* Handle a "/denomination-key-validity-withdraw-inconsistency" request. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ + * Handle a "/denomination-key-validity-withdraw-inconsistency" request. + * + * @param rh context of the handler + * @param connection the MHD connection to handle + * @param[in,out] connection_cls the connection's closure (can be updated) + * @param upload_data upload data + * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' + * @return MHD result code + */ MHD_RESULT -TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_handler_get (struct - TAH_RequestHandler - *rh, - struct - MHD_Connection - * - connection, - void ** - connection_cls, - const char * - upload_data, - size_t * - upload_data_size, - const char * - const args[]); +TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_handler_get ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char * const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_GET_H +#endif diff --git a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.c b/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.c deleted file mode 100644 index 016350e18..000000000 --- a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.c +++ /dev/null @@ -1,159 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include \ - "taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.h" - -/** -* We have parsed the JSON information about the denomination-key-validity-withdraw-inconsistency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the denomination-key-validity-withdraw-inconsistency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_DenominationKeyValidityWithdrawInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_denomination_key_validity_withdraw_inconsistency ( - TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /denomination-key-validity-withdraw-inconsistency in database "); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "denomination-key-validity-withdraw-inconsistency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_OK")); -} - - -MHD_RESULT -TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_handler ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_DenominationKeyValidityWithdrawInconsistency dc; - - struct GNUNET_TIME_Timestamp ed = { 0 }; - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_timestamp ("execution_date", &ed), - GNUNET_JSON_spec_fixed_auto ("reserve_pub", &dc.reserve_pub), - GNUNET_JSON_spec_fixed_auto ("denompub_h", &dc.denompub_h), - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - dc.execution_date = ed.abs_time; - - MHD_RESULT res; - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.h b/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.h deleted file mode 100644 index 6b7b00273..000000000 --- a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-put.h +++ /dev/null @@ -1,68 +0,0 @@ -/* - 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/> - */ - - -#ifndef \ - SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_H -#define \ - SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_done (void); - - -/** -* Handle a "/denomination-key-validity-withdraw-inconsistency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_handler (struct - TAH_RequestHandler - *rh, - struct - MHD_Connection - * - connection, - void ** - connection_cls, - const char * - upload_data, - size_t * - upload_data_size, - const char * - const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-upd.h b/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-upd.h index a7ef2179c..32267bf64 100644 --- a/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-upd.h +++ b/src/auditor/taler-auditor-httpd_denomination-key-validity-withdraw-inconsistency-upd.h @@ -18,29 +18,19 @@ #ifndef \ SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_UPD_H #define \ - SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_UPD_H + SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_UPD_H #include <microhttpd.h> #include "taler-auditor-httpd.h" MHD_RESULT -TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_handler_update (struct - TAH_RequestHandler - *rh, - struct - MHD_Connection - * - connection, - void ** - connection_cls, - const char - * - upload_data, - size_t * - upload_data_size, - const char - *const - args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_UPD_H +TAH_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_handler_update ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_denomination-pending-del.h b/src/auditor/taler-auditor-httpd_denomination-pending-del.h index e7a320fa7..4def8a5e7 100644 --- a/src/auditor/taler-auditor-httpd_denomination-pending-del.h +++ b/src/auditor/taler-auditor-httpd_denomination-pending-del.h @@ -43,16 +43,17 @@ TEAH_DENOMINATION_PENDING_DELETE_done (void); * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' * @return MHD result code - */ + */ MHD_RESULT -TAH_DENOMINATION_PENDING_handler_delete (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_DENOMINATION_PENDING_handler_delete ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATION_PENDING_DEL_H +#endif diff --git a/src/auditor/taler-auditor-httpd_denomination-pending-get.h b/src/auditor/taler-auditor-httpd_denomination-pending-get.h index eac6dd9bb..ae7de9f5b 100644 --- a/src/auditor/taler-auditor-httpd_denomination-pending-get.h +++ b/src/auditor/taler-auditor-httpd_denomination-pending-get.h @@ -29,29 +29,30 @@ void TEAH_DENOMINATION_PENDING_GET_init (void); /** -* Shut down subsystem. -*/ + * Shut down subsystem. + */ void TEAH_BAD_DENOMINATION_PENDING_GET_done (void); /** -* Handle a "/denomination-pending" request. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ + * Handle a "/denomination-pending" request. + * + * @param rh context of the handler + * @param connection the MHD connection to handle + * @param[in,out] connection_cls the connection's closure (can be updated) + * @param upload_data upload data + * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' + * @return MHD result code + */ MHD_RESULT -TAH_DENOMINATION_PENDING_handler_get (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_DENOMINATION_PENDING_handler_get ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATION_PENDING_GET_H +#endif diff --git a/src/auditor/taler-auditor-httpd_denomination-pending-put.c b/src/auditor/taler-auditor-httpd_denomination-pending-put.c deleted file mode 100644 index f5c095a3a..000000000 --- a/src/auditor/taler-auditor-httpd_denomination-pending-put.c +++ /dev/null @@ -1,159 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_denomination-pending-put.h" - -/** -* We have parsed the JSON information about the denomination-pending, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the denomination-pending -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_DenominationPending *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_denomination_pending (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /denomination-pending in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "denomination-pending"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "DENOMINATION_PENDING_OK")); -} - - -MHD_RESULT -TAH_DENOMINATION_PENDING_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_DenominationPending dc; - - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_fixed_auto ("denom_pub_hash", &dc.denom_pub_hash), - TALER_JSON_spec_amount ("denom_balance", TAH_currency, &dc.denom_balance), - TALER_JSON_spec_amount ("denom_loss", TAH_currency, &dc.denom_loss), - GNUNET_JSON_spec_int64 ("num_issued", &dc.num_issued), - TALER_JSON_spec_amount ("denom_risk", TAH_currency, &dc.denom_risk), - TALER_JSON_spec_amount ("recoup_loss", TAH_currency, &dc.recoup_loss), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_DENOMINATION_PENDING_PUT_init (void) -{ - -} - - -void -TEAH_DENOMINATION_PENDING_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_denomination-pending-put.h b/src/auditor/taler-auditor-httpd_denomination-pending-put.h deleted file mode 100644 index 415f386da..000000000 --- a/src/auditor/taler-auditor-httpd_denomination-pending-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_DENOMINATION_PENDING_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_DENOMINATION_PENDING_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_BAD_DENOMINATION_PENDING_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_BAD_DENOMINATION_PENDING_done (void); - - -/** -* Handle a "/denomination-pending" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_DENOMINATION_PENDING_handler_put (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATION_PENDING_PUT_H diff --git a/src/auditor/taler-auditor-httpd_denomination-pending-upd.h b/src/auditor/taler-auditor-httpd_denomination-pending-upd.h index 457974d69..54800ad43 100644 --- a/src/auditor/taler-auditor-httpd_denomination-pending-upd.h +++ b/src/auditor/taler-auditor-httpd_denomination-pending-upd.h @@ -23,12 +23,12 @@ #include "taler-auditor-httpd.h" MHD_RESULT -TAH_DENOMINATION_PENDING_handler_update (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATION_PENDING_UPD_H +TAH_DENOMINATION_PENDING_handler_update ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_denominations-without-sigs-del.h b/src/auditor/taler-auditor-httpd_denominations-without-sigs-del.h index 9dad4a972..b7d8786ef 100644 --- a/src/auditor/taler-auditor-httpd_denominations-without-sigs-del.h +++ b/src/auditor/taler-auditor-httpd_denominations-without-sigs-del.h @@ -43,16 +43,17 @@ TEAH_DENOMINATIONS_WITHOUT_SIGS_DELETE_done (void); * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' * @return MHD result code - */ + */ MHD_RESULT -TAH_DENOMINATIONS_WITHOUT_SIGS_handler_delete (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_DENOMINATIONS_WITHOUT_SIGS_handler_delete ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATIONS_WITHOUT_SIGS_DEL_H +#endif diff --git a/src/auditor/taler-auditor-httpd_denominations-without-sigs-get.h b/src/auditor/taler-auditor-httpd_denominations-without-sigs-get.h index 111d48ee4..be2e14a60 100644 --- a/src/auditor/taler-auditor-httpd_denominations-without-sigs-get.h +++ b/src/auditor/taler-auditor-httpd_denominations-without-sigs-get.h @@ -46,13 +46,13 @@ TEAH_BAD_DENOMINATIONS_WITHOUT_SIGS_GET_done (void); * @return MHD result code */ MHD_RESULT -TAH_DENOMINATIONS_WITHOUT_SIGS_handler_get (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_DENOMINATIONS_WITHOUT_SIGS_handler_get ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATIONS_WITHOUT_SIGS_GET_H +#endif diff --git a/src/auditor/taler-auditor-httpd_denominations-without-sigs-put.c b/src/auditor/taler-auditor-httpd_denominations-without-sigs-put.c deleted file mode 100644 index ace1c2cd9..000000000 --- a/src/auditor/taler-auditor-httpd_denominations-without-sigs-put.c +++ /dev/null @@ -1,162 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_denominations-without-sigs-put.h" - -/** -* We have parsed the JSON information about the denominations-without-sigs, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the denominations-without-sigs -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_DenominationsWithoutSigs *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_denominations_without_sigs (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /denominations-without-sigs in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "denominations-without-sigs"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "DENOMINATIONS_WITHOUT_SIGS_OK")); -} - - -MHD_RESULT -TAH_DENOMINATIONS_WITHOUT_SIGS_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_DenominationsWithoutSigs dc; - - struct GNUNET_TIME_Timestamp st = { 0 }; - struct GNUNET_TIME_Timestamp ed = { 0 }; - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_fixed_auto ("denompub_h", &dc.denompub_h), - TALER_JSON_spec_amount ("value", TAH_currency, &dc.value), - GNUNET_JSON_spec_timestamp ("start_time", &st), - GNUNET_JSON_spec_timestamp ("end_time", &ed), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - dc.end_time = ed.abs_time; - dc.start_time = st.abs_time; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_DENOMINATIONS_WITHOUT_SIGS_PUT_init (void) -{ - -} - - -void -TEAH_DENOMINATIONS_WITHOUT_SIGS_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_denominations-without-sigs-put.h b/src/auditor/taler-auditor-httpd_denominations-without-sigs-put.h deleted file mode 100644 index def5dfef8..000000000 --- a/src/auditor/taler-auditor-httpd_denominations-without-sigs-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_DENOMINATIONS_WITHOUT_SIGS_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_DENOMINATIONS_WITHOUT_SIGS_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_BAD_DENOMINATIONS_WITHOUT_SIGS_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_BAD_DENOMINATIONS_WITHOUT_SIGS_done (void); - - -/** -* Handle a "/denominations-without-sigs" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_DENOMINATIONS_WITHOUT_SIGS_handler_put (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATIONS_WITHOUT_SIGS_PUT_H diff --git a/src/auditor/taler-auditor-httpd_denominations-without-sigs-upd.h b/src/auditor/taler-auditor-httpd_denominations-without-sigs-upd.h index e1feff28e..df2980ecf 100644 --- a/src/auditor/taler-auditor-httpd_denominations-without-sigs-upd.h +++ b/src/auditor/taler-auditor-httpd_denominations-without-sigs-upd.h @@ -23,12 +23,12 @@ #include "taler-auditor-httpd.h" MHD_RESULT -TAH_DENOMINATIONS_WITHOUT_SIGS_handler_update (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_DENOMINATIONS_WITHOUT_SIGS_UPD_H +TAH_DENOMINATIONS_WITHOUT_SIGS_handler_update ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_deposit-confirmation-del.h b/src/auditor/taler-auditor-httpd_deposit-confirmation-del.h index bca6d0295..032fd8aac 100644 --- a/src/auditor/taler-auditor-httpd_deposit-confirmation-del.h +++ b/src/auditor/taler-auditor-httpd_deposit-confirmation-del.h @@ -50,12 +50,13 @@ TEAH_DEPOSIT_CONFIRMATION_DELETE_done (void); * @return MHD result code */ MHD_RESULT -TAH_DEPOSIT_CONFIRMATION_handler_delete (struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_DEPOSIT_CONFIRMATION_handler_delete ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); #endif diff --git a/src/auditor/taler-auditor-httpd_deposit-confirmation-get.h b/src/auditor/taler-auditor-httpd_deposit-confirmation-get.h index 0698a0d0a..0f0efd6ac 100644 --- a/src/auditor/taler-auditor-httpd_deposit-confirmation-get.h +++ b/src/auditor/taler-auditor-httpd_deposit-confirmation-get.h @@ -45,15 +45,17 @@ TEAH_DEPOSIT_CONFIRMATION_GET_done (void); * @param[in,out] connection_cls the connection's closure (can be updated)
* @param upload_data upload data
* @param[in,out] upload_data_size number of bytes (left) in @a upload_data
+ * @param args NULL-terminated array of remaining parts of the URI broken up at '/'
* @return MHD result code
- */
+ */
MHD_RESULT
-TAH_DEPOSIT_CONFIRMATION_handler_get (struct TAH_RequestHandler *rh,
- struct MHD_Connection *connection,
- void **connection_cls,
- const char *upload_data,
- size_t *upload_data_size,
- const char *const args[]);
+TAH_DEPOSIT_CONFIRMATION_handler_get (
+ struct TAH_RequestHandler *rh,
+ struct MHD_Connection *connection,
+ void **connection_cls,
+ const char *upload_data,
+ size_t *upload_data_size,
+ const char *const args[]);
#endif
diff --git a/src/auditor/taler-auditor-httpd_deposit-confirmation-upd.h b/src/auditor/taler-auditor-httpd_deposit-confirmation-upd.h index f74ee4c9c..764af917b 100644 --- a/src/auditor/taler-auditor-httpd_deposit-confirmation-upd.h +++ b/src/auditor/taler-auditor-httpd_deposit-confirmation-upd.h @@ -23,12 +23,12 @@ #include "taler-auditor-httpd.h" MHD_RESULT -TAH_DEPOSIT_CONFIRMATION_handler_update (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_DEPOSIT_CONFIRMATION_UPD_H +TAH_DEPOSIT_CONFIRMATION_handler_update ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_deposit-confirmation.h b/src/auditor/taler-auditor-httpd_deposit-confirmation.h index 473d6541b..e7ca23d15 100644 --- a/src/auditor/taler-auditor-httpd_deposit-confirmation.h +++ b/src/auditor/taler-auditor-httpd_deposit-confirmation.h @@ -47,15 +47,17 @@ TEAH_DEPOSIT_CONFIRMATION_done (void); * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' * @return MHD result code - */ + */ MHD_RESULT -TAH_DEPOSIT_CONFIRMATION_handler (struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_DEPOSIT_CONFIRMATION_handler ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); #endif diff --git a/src/auditor/taler-auditor-httpd_emergency-by-count-del.h b/src/auditor/taler-auditor-httpd_emergency-by-count-del.h index ab50fa4bc..f8cd7bd00 100644 --- a/src/auditor/taler-auditor-httpd_emergency-by-count-del.h +++ b/src/auditor/taler-auditor-httpd_emergency-by-count-del.h @@ -43,16 +43,16 @@ TEAH_EMERGENCY_BY_COUNT_DELETE_done (void); * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' * @return MHD result code */ MHD_RESULT -TAH_EMERGENCY_BY_COUNT_handler_delete (struct - TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_EMERGENCY_BY_COUNT_DEL_H +TAH_EMERGENCY_BY_COUNT_handler_delete ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_emergency-by-count-get.h b/src/auditor/taler-auditor-httpd_emergency-by-count-get.h index d5de67c30..c04bfbffe 100644 --- a/src/auditor/taler-auditor-httpd_emergency-by-count-get.h +++ b/src/auditor/taler-auditor-httpd_emergency-by-count-get.h @@ -35,23 +35,24 @@ void TEAH_EMERGENCY_BY_COUNT_GET_done (void); /** -* Handle a "/emergency-by-count" request. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ + * Handle a "/emergency-by-count" request. + * + * @param rh context of the handler + * @param connection the MHD connection to handle + * @param[in,out] connection_cls the connection's closure (can be updated) + * @param upload_data upload data + * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' + * @return MHD result code + */ MHD_RESULT -TAH_EMERGENCY_BY_COUNT_handler_get (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_EMERGENCY_BY_COUNT_handler_get ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_EMERGENCY_BY_COUNT_GET_H +#endif diff --git a/src/auditor/taler-auditor-httpd_emergency-by-count-put.c b/src/auditor/taler-auditor-httpd_emergency-by-count-put.c deleted file mode 100644 index 1a7147900..000000000 --- a/src/auditor/taler-auditor-httpd_emergency-by-count-put.c +++ /dev/null @@ -1,167 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_emergency-by-count-put.h" - -/** -* We have parsed the JSON information about the emergency-by-count, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the emergency-by-count -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_EmergenciesByCount *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_emergency_by_count (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /emergency-by-count in database\n"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "emergency-by-count"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "EMERGENCY_BY_COUNT_OK")); -} - - -MHD_RESULT -TAH_EMERGENCY_BY_COUNT_PUT_handler ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_EmergenciesByCount dc; - - - struct GNUNET_TIME_Timestamp ts_s = { 0 }; - struct GNUNET_TIME_Timestamp ts_de = { 0 }; - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_fixed_auto ("denompub_h", &dc.denompub_h), - GNUNET_JSON_spec_int64 ("num_issued", &dc.num_issued), - GNUNET_JSON_spec_int64 ("num_known", &dc.num_known), - TALER_JSON_spec_amount ("risk", TAH_currency, &dc.risk), - GNUNET_JSON_spec_timestamp ("start", &ts_s), - GNUNET_JSON_spec_timestamp ("deposit_end",&ts_de), - TALER_JSON_spec_amount ("value", TAH_currency, &dc.value), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - - dc.start = ts_de.abs_time; - dc.deposit_end = ts_de.abs_time; - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_EMERGENCY_BY_COUNT_PUT_init (void) -{ - -} - - -void -TEAH_EMERGENCY_BY_COUNT_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_emergency-by-count-put.h b/src/auditor/taler-auditor-httpd_emergency-by-count-put.h deleted file mode 100644 index 511c6cc50..000000000 --- a/src/auditor/taler-auditor-httpd_emergency-by-count-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_EMERGENCY_BY_COUNT_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_EMERGENCY_BY_COUNT_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_EMERGENCY_BY_COUNT_PUT_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_EMERGENCY_BY_COUNT_PUT_done (void); - - -/** -* Handle a "/emergency-by-count" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_EMERGENCY_BY_COUNT_PUT_handler (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_EMERGENCY_BY_COUNT_PUT_H diff --git a/src/auditor/taler-auditor-httpd_emergency-by-count-upd.h b/src/auditor/taler-auditor-httpd_emergency-by-count-upd.h index c2993d52e..15be00a9c 100644 --- a/src/auditor/taler-auditor-httpd_emergency-by-count-upd.h +++ b/src/auditor/taler-auditor-httpd_emergency-by-count-upd.h @@ -23,12 +23,12 @@ #include "taler-auditor-httpd.h" MHD_RESULT -TAH_EMERGENCY_BY_COUNT_handler_update (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_EMERGENCY_BY_COUNT_UPD_H +TAH_EMERGENCY_BY_COUNT_handler_update ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_emergency-del.h b/src/auditor/taler-auditor-httpd_emergency-del.h index 2fabf6777..16928dee7 100644 --- a/src/auditor/taler-auditor-httpd_emergency-del.h +++ b/src/auditor/taler-auditor-httpd_emergency-del.h @@ -35,24 +35,24 @@ void TEAH_EMERGENCY_DELETE_done (void); /** -* Handle a "/emergency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ + * Handle a "/emergency" request. Parses the JSON, and, if + * successful, checks the signatures and stores the result in the DB. + * + * @param rh context of the handler + * @param connection the MHD connection to handle + * @param[in,out] connection_cls the connection's closure (can be updated) + * @param upload_data upload data + * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' + * @return MHD result code + */ MHD_RESULT -TAH_EMERGENCY_handler_delete (struct - TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - -#endif // SRC_TALER_AUDITOR_HTTPD_EMERGENCY_DEL_H +TAH_EMERGENCY_handler_delete ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); + +#endif diff --git a/src/auditor/taler-auditor-httpd_emergency-get.h b/src/auditor/taler-auditor-httpd_emergency-get.h index 7fc1e0553..47c04f11d 100644 --- a/src/auditor/taler-auditor-httpd_emergency-get.h +++ b/src/auditor/taler-auditor-httpd_emergency-get.h @@ -35,23 +35,24 @@ void TEAH_EMERGENCY_GET_done (void); /** -* Handle a "/emergency" request. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ + * Handle a "/emergency" request. + * + * @param rh context of the handler + * @param connection the MHD connection to handle + * @param[in,out] connection_cls the connection's closure (can be updated) + * @param upload_data upload data + * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' + * @return MHD result code + */ MHD_RESULT -TAH_EMERGENCY_handler_get (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); +TAH_EMERGENCY_handler_get ( + struct TAH_RequestHandler *rh, + struct MHD_Connection *connection, + void **connection_cls, + const char *upload_data, + size_t *upload_data_size, + const char *const args[]); -#endif // SRC_TALER_AUDITOR_HTTPD_EMERGENCY_GET_H +#endif diff --git a/src/auditor/taler-auditor-httpd_emergency-put.c b/src/auditor/taler-auditor-httpd_emergency-put.c deleted file mode 100644 index a47556449..000000000 --- a/src/auditor/taler-auditor-httpd_emergency-put.c +++ /dev/null @@ -1,167 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_emergency-put.h" - -/** -* We have parsed the JSON information about the emergency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the emergency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_Emergency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_emergency (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /emergency in database\n"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "emergency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "EMERGENCY_OK")); -} - - -MHD_RESULT -TAH_EMERGENCY_PUT_handler ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_Emergency dc; - - struct GNUNET_TIME_Timestamp ds = { 0 }; - struct GNUNET_TIME_Timestamp de = { 0 }; - - struct GNUNET_JSON_Specification spec[] = { - - - GNUNET_JSON_spec_fixed_auto ("denompub_h", &dc.denompub_h), - - TALER_JSON_spec_amount ("denom_risk",TAH_currency, &dc.denom_risk), - TALER_JSON_spec_amount ("denom_loss", TAH_currency,&dc.denom_loss), - - GNUNET_JSON_spec_timestamp ("deposit_start", &ds), - GNUNET_JSON_spec_timestamp ("deposit_end", &de), - - TALER_JSON_spec_amount ("value", TAH_currency,&dc.value), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - dc.deposit_start = ds.abs_time; - dc.deposit_end = de.abs_time; - - MHD_RESULT res; - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_EMERGENCY_PUT_init (void) -{ - -} - - -void -TEAH_EMERGENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_emergency-put.h b/src/auditor/taler-auditor-httpd_emergency-put.h deleted file mode 100644 index db4ab77dc..000000000 --- a/src/auditor/taler-auditor-httpd_emergency-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_EMERGENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_EMERGENCY_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_EMERGENCY_PUT_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_EMERGENCY_PUT_done (void); - - -/** -* Handle a "/emergency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_EMERGENCY_PUT_handler (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_EMERGENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_fee-time-inconsistency-put.c b/src/auditor/taler-auditor-httpd_fee-time-inconsistency-put.c deleted file mode 100644 index f0d5e2a73..000000000 --- a/src/auditor/taler-auditor-httpd_fee-time-inconsistency-put.c +++ /dev/null @@ -1,159 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_fee-time-inconsistency-put.h" - -/** -* We have parsed the JSON information about the fee-time-inconsistency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the fee-time-inconsistency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_FeeTimeInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_fee_time_inconsistency (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /fee-time-inconsistency in database\n"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "fee-time-inconsistency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "FEE_TIME_INCONSISTENCY_OK")); -} - - -MHD_RESULT -TAH_FEE_TIME_INCONSISTENCY_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_FeeTimeInconsistency dc; - - struct GNUNET_TIME_Timestamp t = { 0 }; - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_string ("type", (const char **) &dc.type), - GNUNET_JSON_spec_timestamp ("time", &t), - GNUNET_JSON_spec_string ("diagnostic", (const char **) &dc.diagnostic), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - dc.time = t.abs_time; - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_FEE_TIME_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_FEE_TIME_INCONSISTENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_fee-time-inconsistency-put.h b/src/auditor/taler-auditor-httpd_fee-time-inconsistency-put.h deleted file mode 100644 index 3deae033b..000000000 --- a/src/auditor/taler-auditor-httpd_fee-time-inconsistency-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_FEE_TIME_INCONSISTENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_FEE_TIME_INCONSISTENCY_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_FEE_TIME_INCONSISTENCY_PUT_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_FEE_TIME_INCONSISTENCY_PUT_done (void); - - -/** -* Handle a "/fee-time-inconsistency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_FEE_TIME_INCONSISTENCY_handler_put (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_FEE_TIME_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_mhd.h b/src/auditor/taler-auditor-httpd_mhd.h index bb1fde2d3..5278b5c4c 100644 --- a/src/auditor/taler-auditor-httpd_mhd.h +++ b/src/auditor/taler-auditor-httpd_mhd.h @@ -37,6 +37,7 @@ * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' * @return MHD result code */ MHD_RESULT @@ -57,6 +58,7 @@ TAH_MHD_handler_static_response (struct TAH_RequestHandler *rh, * @param[in,out] connection_cls the connection's closure (can be updated) * @param upload_data upload data * @param[in,out] upload_data_size number of bytes (left) in @a upload_data + * @param args NULL-terminated array of remaining parts of the URI broken up at '/' * @return MHD result code */ MHD_RESULT diff --git a/src/auditor/taler-auditor-httpd_misattribution-in-inconsistency-put.c b/src/auditor/taler-auditor-httpd_misattribution-in-inconsistency-put.c deleted file mode 100644 index d2d4e286f..000000000 --- a/src/auditor/taler-auditor-httpd_misattribution-in-inconsistency-put.c +++ /dev/null @@ -1,156 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_misattribution-in-inconsistency-put.h" - -/** -* We have parsed the JSON information about the misattribution-in-inconsistency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the misattribution-in-inconsistency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_MisattributionInInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_misattribution_in_inconsistency (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /misattribution-in-inconsistency in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "misattribution-in-inconsistency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "MISATTRIBUTION_IN_INCONSISTENCY_OK")); -} - - -MHD_RESULT -TAH_MISATTRIBUTION_IN_INCONSISTENCY_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_MisattributionInInconsistency dc; - - - struct GNUNET_JSON_Specification spec[] = { - - TALER_JSON_spec_amount ("amount", TAH_currency, &dc.amount), - GNUNET_JSON_spec_int64 ("bank_row", &dc.bank_row), - GNUNET_JSON_spec_fixed_auto ("reserve_pub", &dc.reserve_pub), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_MISATTRIBUTION_IN_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_MISATTRIBUTION_IN_INCONSISTENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_misattribution-in-inconsistency-put.h b/src/auditor/taler-auditor-httpd_misattribution-in-inconsistency-put.h deleted file mode 100644 index 92d35f05c..000000000 --- a/src/auditor/taler-auditor-httpd_misattribution-in-inconsistency-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_MISATTRIBUTION_IN_INCONSISTENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_MISATTRIBUTION_IN_INCONSISTENCY_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_BAD_MISATTRIBUTION_IN_INCONSISTENCY_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_BAD_MISATTRIBUTION_IN_INCONSISTENCY_done (void); - - -/** -* Handle a "/misattribution-in-inconsistency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_MISATTRIBUTION_IN_INCONSISTENCY_handler_put (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_MISATTRIBUTION_IN_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_purse-not-closed-inconsistencies-put.c b/src/auditor/taler-auditor-httpd_purse-not-closed-inconsistencies-put.c deleted file mode 100644 index aa06d759e..000000000 --- a/src/auditor/taler-auditor-httpd_purse-not-closed-inconsistencies-put.c +++ /dev/null @@ -1,159 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_purse-not-closed-inconsistencies-put.h" - -/** -* We have parsed the JSON information about the purse-not-closed-inconsistencies, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the purse-not-closed-inconsistencies -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_PurseNotClosedInconsistencies *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_purse_not_closed_inconsistencies (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /purse-not-closed-inconsistencies in database\n"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "purse-not-closed-inconsistencies"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "PURSE_NOT_CLOSED_INCONSISTENCIES_OK")); -} - - -MHD_RESULT -TAH_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_handler ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_PurseNotClosedInconsistencies dc; - - struct GNUNET_TIME_Timestamp ed = { 0 }; - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_fixed_auto ("purse_pub", &dc.purse_pub), - TALER_JSON_spec_amount ("amount", TAH_currency, &dc.amount), - GNUNET_JSON_spec_timestamp ("progress_offset", &ed), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - dc.expiration_date = ed.abs_time; - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_init (void) -{ - -} - - -void -TEAH_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_purse-not-closed-inconsistencies-put.h b/src/auditor/taler-auditor-httpd_purse-not-closed-inconsistencies-put.h deleted file mode 100644 index 19d7fd7b2..000000000 --- a/src/auditor/taler-auditor-httpd_purse-not-closed-inconsistencies-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_done (void); - - -/** -* Handle a "/purse-not-closed-inconsistencies" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_handler (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_PURSE_NOT_CLOSED_INCONSISTENCIES_PUT_H diff --git a/src/auditor/taler-auditor-httpd_refreshes-hanging-put.c b/src/auditor/taler-auditor-httpd_refreshes-hanging-put.c deleted file mode 100644 index 9c617a4f2..000000000 --- a/src/auditor/taler-auditor-httpd_refreshes-hanging-put.c +++ /dev/null @@ -1,154 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_refreshes-hanging-put.h" - -/** -* We have parsed the JSON information about the refreshes-hanging, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the refreshes-hanging -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_RefreshesHanging *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_refreshes_hanging (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /refreshes-hanging in database\n"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "refreshes-hanging"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "REFRESHES_HANGING_OK")); -} - - -MHD_RESULT -TAH_REFRESHES_HANGING_PUT_handler ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_RefreshesHanging dc; - - - struct GNUNET_JSON_Specification spec[] = { - - TALER_JSON_spec_amount ("amount", TAH_currency, &dc.amount), - GNUNET_JSON_spec_fixed_auto ("coin_pub", &dc.coin_pub), - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_REFRESHES_HANGING_PUT_init (void) -{ - -} - - -void -TEAH_REFRESHES_HANGING_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_refreshes-hanging-put.h b/src/auditor/taler-auditor-httpd_refreshes-hanging-put.h deleted file mode 100644 index 90fde33b1..000000000 --- a/src/auditor/taler-auditor-httpd_refreshes-hanging-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_REFRESHES_HANGING_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_REFRESHES_HANGING_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_REFRESHES_HANGING_PUT_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_REFRESHES_HANGING_PUT_done (void); - - -/** -* Handle a "/refreshes-hanging" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_REFRESHES_HANGING_PUT_handler (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_REFRESHES_HANGING_PUT_H diff --git a/src/auditor/taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.c b/src/auditor/taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.c deleted file mode 100644 index a8e12c010..000000000 --- a/src/auditor/taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.c +++ /dev/null @@ -1,158 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.h" - -/** -* We have parsed the JSON information about the reserve-balance-insufficient-inconsistency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the reserve-balance-insufficient-inconsistency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_ReserveBalanceInsufficientInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_reserve_balance_insufficient_inconsistency ( - TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /reserve-balance-insufficient-inconsistency in database\n"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "reserve-balance-insufficient-inconsistency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_OK")); -} - - -MHD_RESULT -TAH_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_ReserveBalanceInsufficientInconsistency dc; - - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_fixed_auto ("reserve_pub", &dc.reserve_pub), - GNUNET_JSON_spec_bool ("inconsistency_gain", &dc.inconsistency_gain), - TALER_JSON_spec_amount ("inconsistency_amount", TAH_currency, - &dc.inconsistency_amount), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.h b/src/auditor/taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.h deleted file mode 100644 index eeead65d9..000000000 --- a/src/auditor/taler-auditor-httpd_reserve-balance-insufficient-inconsistency-put.h +++ /dev/null @@ -1,64 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_PUT_H - -#include <gnunet/gnunet_util_lib.h> -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_PUT_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_PUT_done (void); - -/** -* Handle a "/reserve-balance-insufficient-inconsistency" request. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_handler_put (struct - TAH_RequestHandler * - rh, - struct - MHD_Connection * - connection, - void ** - connection_cls, - const char * - upload_data, - size_t * - upload_data_size, - const char *const - args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.c b/src/auditor/taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.c deleted file mode 100644 index 231daf569..000000000 --- a/src/auditor/taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.c +++ /dev/null @@ -1,158 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.h" - -/** -* We have parsed the JSON information about the reserve-balance-summary-wrong-inconsistency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the reserve-balance-summary-wrong-inconsistency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_ReserveBalanceSummaryWrongInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_reserve_balance_summary_wrong_inconsistency ( - TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /reserve-balance-summary-wrong-inconsistency in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "reserve-balance-summary-wrong-inconsistency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_OK")); -} - - -MHD_RESULT -TAH_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_ReserveBalanceSummaryWrongInconsistency dc; - - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_fixed_auto ("reserve_pub", &dc.reserve_pub), - TALER_JSON_spec_amount ("exchange_amount", TAH_currency, - &dc.exchange_amount), - TALER_JSON_spec_amount ("auditor_amount", TAH_currency, &dc.auditor_amount), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.h b/src/auditor/taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.h deleted file mode 100644 index 69c592249..000000000 --- a/src/auditor/taler-auditor-httpd_reserve-balance-summary-wrong-inconsistency-put.h +++ /dev/null @@ -1,67 +0,0 @@ -/* - 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/> - */ - - -#ifndef \ - SRC_TALER_AUDITOR_HTTPD_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_PUT_H -#define \ - SRC_TALER_AUDITOR_HTTPD_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_BAD_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_BAD_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_done (void); - - -/** -* Handle a "/reserve-balance-summary-wrong-inconsistency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_handler_put (struct - TAH_RequestHandler - *rh, - struct - MHD_Connection * - connection, - void ** - connection_cls, - const char * - upload_data, - size_t * - upload_data_size, - const char *const - args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_reserve-in-inconsistency-put.c b/src/auditor/taler-auditor-httpd_reserve-in-inconsistency-put.c deleted file mode 100644 index e2e9ba23f..000000000 --- a/src/auditor/taler-auditor-httpd_reserve-in-inconsistency-put.c +++ /dev/null @@ -1,162 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_reserve-in-inconsistency-put.h" - -/** -* We have parsed the JSON information about the reserve-in-inconsistency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the reserve-in-inconsistency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_ReserveInInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_reserve_in_inconsistency (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /reserve-in-inconsistency in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "reserve-in-inconsistency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "RESERVE_IN_INCONSISTENCY_OK")); -} - - -MHD_RESULT -TAH_RESERVE_IN_INCONSISTENCY_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_ReserveInInconsistency dc; - - struct GNUNET_TIME_Timestamp t = { 0 }; - - struct GNUNET_JSON_Specification spec[] = { - - TALER_JSON_spec_amount ("amount_exchange_expected", TAH_currency, - &dc.amount_exchange_expected), - TALER_JSON_spec_amount ("amount_wired", TAH_currency, &dc.amount_wired), - GNUNET_JSON_spec_fixed_auto ("reserve_pub", &dc.reserve_pub), - GNUNET_JSON_spec_timestamp ("timestamp", &t), - GNUNET_JSON_spec_fixed_auto ("account", &dc.account), - GNUNET_JSON_spec_fixed_auto ("diagnostic", &dc.diagnostic), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - dc.timestamp = t.abs_time; - - MHD_RESULT res; - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_RESERVE_IN_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_RESERVE_IN_INCONSISTENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_reserve-in-inconsistency-put.h b/src/auditor/taler-auditor-httpd_reserve-in-inconsistency-put.h deleted file mode 100644 index 6892e0362..000000000 --- a/src/auditor/taler-auditor-httpd_reserve-in-inconsistency-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_RESERVE_IN_INCONSISTENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_RESERVE_IN_INCONSISTENCY_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_BAD_RESERVE_IN_INCONSISTENCY_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_BAD_RESERVE_IN_INCONSISTENCY_done (void); - - -/** -* Handle a "/reserve-in-inconsistency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_RESERVE_IN_INCONSISTENCY_handler_put (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_RESERVE_IN_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_reserve-not-closed-inconsistency-put.c b/src/auditor/taler-auditor-httpd_reserve-not-closed-inconsistency-put.c deleted file mode 100644 index aefe9bef1..000000000 --- a/src/auditor/taler-auditor-httpd_reserve-not-closed-inconsistency-put.c +++ /dev/null @@ -1,160 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_reserve-not-closed-inconsistency-put.h" - -/** -* We have parsed the JSON information about the reserve-not-closed-inconsistency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the reserve-not-closed-inconsistency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_ReserveNotClosedInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_reserve_not_closed_inconsistency (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /reserve-not-closed-inconsistency in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "reserve-not-closed-inconsistency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "RESERVE_NOT_CLOSED_INCONSISTENCY_OK")); -} - - -MHD_RESULT -TAH_RESERVE_NOT_CLOSED_INCONSISTENCY_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_ReserveNotClosedInconsistency dc; - - struct GNUNET_TIME_Timestamp et = { 0 }; - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_fixed_auto ("reserve_pub", &dc.reserve_pub), - TALER_JSON_spec_amount ("balance", TAH_currency, &dc.balance), - GNUNET_JSON_spec_timestamp ("expiration_time", &et), - GNUNET_JSON_spec_fixed_auto ("diagnostic", &dc.diagnostic), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - dc.expiration_time = et.abs_time; - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_RESERVE_NOT_CLOSED_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_RESERVE_NOT_CLOSED_INCONSISTENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_reserve-not-closed-inconsistency-put.h b/src/auditor/taler-auditor-httpd_reserve-not-closed-inconsistency-put.h deleted file mode 100644 index 9e1d822bd..000000000 --- a/src/auditor/taler-auditor-httpd_reserve-not-closed-inconsistency-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_RESERVE_NOT_CLOSED_INCONSISTENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_RESERVE_NOT_CLOSED_INCONSISTENCY_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_BAD_RESERVE_NOT_CLOSED_INCONSISTENCY_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_BAD_RESERVE_NOT_CLOSED_INCONSISTENCY_done (void); - - -/** -* Handle a "/reserve-not-closed-inconsistency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_RESERVE_NOT_CLOSED_INCONSISTENCY_handler_put (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_RESERVE_NOT_CLOSED_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_row-inconsistency-put.c b/src/auditor/taler-auditor-httpd_row-inconsistency-put.c deleted file mode 100644 index ee33deb4a..000000000 --- a/src/auditor/taler-auditor-httpd_row-inconsistency-put.c +++ /dev/null @@ -1,156 +0,0 @@ -/* - 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/> - */ - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_row-inconsistency-put.h" - - -/** - * We have parsed the JSON information about the deposit, do some - * basic sanity checks (especially that the signature on the coin is - * valid, and that this type of coin exists) and then execute the - * deposit. - * - * @param connection the MHD connection to handle - * @param dc information about the deposit confirmation - * @param es information about the exchange's signing key - * @return MHD result code - */ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_RowInconsistency *dc) -{ - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_row_inconsistency (TAH_plugin->cls, - dc); - - - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /insert-row in database\n"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "insert row"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "INSERT_ROW_OK")); -} - - -MHD_RESULT -TAH_ROW_INCONSISTENCY_PUT_handler ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_RowInconsistency dc; - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_string ("row_table", (const char **) &dc.row_table), - GNUNET_JSON_spec_string ("diagnostic", (const char **) &dc.diagnostic), - GNUNET_JSON_spec_end () - - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - - GNUNET_JSON_parse_free (spec); - json_decref (json); - return res; - -} - - -void -TEAH_ROW_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_ROW_INCONSISTENCY_PUT_done (void) -{ - -}
\ No newline at end of file diff --git a/src/auditor/taler-auditor-httpd_row-inconsistency-put.h b/src/auditor/taler-auditor-httpd_row-inconsistency-put.h deleted file mode 100644 index 5c1f70e50..000000000 --- a/src/auditor/taler-auditor-httpd_row-inconsistency-put.h +++ /dev/null @@ -1,57 +0,0 @@ -/* - 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/> - */ - -#ifndef SRC_TALER_AUDITOR_HTTPD_ROW_INCONSISTENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_ROW_INCONSISTENCY_PUT_H - - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** - * Initialize subsystem. - */ -void -TEAH_ROW_INCONSISTENCY_PUT_init (void); - -/** - * Shut down subsystem. - */ -void -TEAH_ROW_INCONSISTENCY_PUT_done (void); - - -/** - * Handle a "/deposit-confirmation" request. Parses the JSON, and, if - * successful, checks the signatures and stores the result in the DB. - * - * @param rh context of the handler - * @param connection the MHD connection to handle - * @param[in,out] connection_cls the connection's closure (can be updated) - * @param upload_data upload data - * @param[in,out] upload_data_size number of bytes (left) in @a upload_data - * @return MHD result code - */ -MHD_RESULT -TAH_ROW_INCONSISTENCY_PUT_handler (struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_ROW_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_row-minor-inconsistencies-put.c b/src/auditor/taler-auditor-httpd_row-minor-inconsistencies-put.c deleted file mode 100644 index a0eab0c69..000000000 --- a/src/auditor/taler-auditor-httpd_row-minor-inconsistencies-put.c +++ /dev/null @@ -1,155 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_row-minor-inconsistencies-put.h" - -/** -* We have parsed the JSON information about the row-minor-inconsistencies, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the row-minor-inconsistencies -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_RowMinorInconsistencies *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_row_minor_inconsistencies (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /row-minor-inconsistencies in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "row-minor-inconsistencies"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "ROW_MINOR_INCONSISTENCIES_OK")); -} - - -MHD_RESULT -TAH_ROW_MINOR_INCONSISTENCIES_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_RowMinorInconsistencies dc; - - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_fixed_auto ("row_table", &dc.row_table), - GNUNET_JSON_spec_fixed_auto ("diagnostic", &dc.diagnostic), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_ROW_MINOR_INCONSISTENCIES_PUT_init (void) -{ - -} - - -void -TEAH_ROW_MINOR_INCONSISTENCIES_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_row-minor-inconsistencies-put.h b/src/auditor/taler-auditor-httpd_row-minor-inconsistencies-put.h deleted file mode 100644 index 6ab10bb77..000000000 --- a/src/auditor/taler-auditor-httpd_row-minor-inconsistencies-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_ROW_MINOR_INCONSISTENCIES_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_ROW_MINOR_INCONSISTENCIES_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_BAD_ROW_MINOR_INCONSISTENCIES_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_BAD_ROW_MINOR_INCONSISTENCIES_done (void); - - -/** -* Handle a "/row-minor-inconsistencies" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_ROW_MINOR_INCONSISTENCIES_handler_put (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_ROW_MINOR_INCONSISTENCIES_PUT_H diff --git a/src/auditor/taler-auditor-httpd_wire-format-inconsistency-put.c b/src/auditor/taler-auditor-httpd_wire-format-inconsistency-put.c deleted file mode 100644 index 8c5bf6a39..000000000 --- a/src/auditor/taler-auditor-httpd_wire-format-inconsistency-put.c +++ /dev/null @@ -1,156 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_wire-format-inconsistency-put.h" - -/** -* We have parsed the JSON information about the wire-format-inconsistency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the wire-format-inconsistency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_WireFormatInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_wire_format_inconsistency (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /wire-format-inconsistency in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "wire-format-inconsistency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "WIRE_FORMAT_INCONSISTENCY_OK")); -} - - -MHD_RESULT -TAH_WIRE_FORMAT_INCONSISTENCY_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_WireFormatInconsistency dc; - - - struct GNUNET_JSON_Specification spec[] = { - - TALER_JSON_spec_amount ("amount", TAH_currency, &dc.amount), - GNUNET_JSON_spec_int64 ("wire_offset", &dc.wire_offset), - GNUNET_JSON_spec_fixed_auto ("diagnostic", &dc.diagnostic), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_WIRE_FORMAT_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_WIRE_FORMAT_INCONSISTENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_wire-format-inconsistency-put.h b/src/auditor/taler-auditor-httpd_wire-format-inconsistency-put.h deleted file mode 100644 index 0a2addfe1..000000000 --- a/src/auditor/taler-auditor-httpd_wire-format-inconsistency-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_WIRE_FORMAT_INCONSISTENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_WIRE_FORMAT_INCONSISTENCY_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_BAD_WIRE_FORMAT_INCONSISTENCY_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_BAD_WIRE_FORMAT_INCONSISTENCY_done (void); - - -/** -* Handle a "/wire-format-inconsistency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_WIRE_FORMAT_INCONSISTENCY_handler_put (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_WIRE_FORMAT_INCONSISTENCY_PUT_H diff --git a/src/auditor/taler-auditor-httpd_wire-out-inconsistency-put.c b/src/auditor/taler-auditor-httpd_wire-out-inconsistency-put.c deleted file mode 100644 index 2c0f9061d..000000000 --- a/src/auditor/taler-auditor-httpd_wire-out-inconsistency-put.c +++ /dev/null @@ -1,158 +0,0 @@ -/* - 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/> - */ - - -#include "platform.h" -#include <gnunet/gnunet_util_lib.h> -#include <gnunet/gnunet_json_lib.h> -#include <jansson.h> -#include <microhttpd.h> -#include <pthread.h> -#include "taler_json_lib.h" -#include "taler_mhd_lib.h" -#include "taler-auditor-httpd.h" -#include "taler-auditor-httpd_wire-out-inconsistency-put.h" - -/** -* We have parsed the JSON information about the wire-out-inconsistency, do some -* basic sanity checks and then execute the -* transaction. -* -* @param connection the MHD connection to handle -* @param dc information about the wire-out-inconsistency -* @return MHD result code -*/ -static MHD_RESULT -process_inconsistency ( - struct MHD_Connection *connection, - const struct TALER_AUDITORDB_WireOutInconsistency *dc) -{ - - enum GNUNET_DB_QueryStatus qs; - - if (GNUNET_SYSERR == - TAH_plugin->preflight (TAH_plugin->cls)) - { - GNUNET_break (0); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_SETUP_FAILED, - NULL); - } - - /* execute transaction */ - qs = TAH_plugin->insert_wire_out_inconsistency (TAH_plugin->cls, - dc); - if (0 > qs) - { - GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs); - TALER_LOG_WARNING ( - "Failed to store /wire-out-inconsistency in database"); - return TALER_MHD_reply_with_error (connection, - MHD_HTTP_INTERNAL_SERVER_ERROR, - TALER_EC_GENERIC_DB_STORE_FAILED, - "wire-out-inconsistency"); - } - return TALER_MHD_REPLY_JSON_PACK (connection, - MHD_HTTP_OK, - GNUNET_JSON_pack_string ("status", - "WIRE_OUT_INCONSISTENCY_OK")); -} - - -MHD_RESULT -TAH_WIRE_OUT_INCONSISTENCY_handler_put ( - struct TAH_RequestHandler *rh, - struct MHD_Connection *connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]) -{ - - struct TALER_AUDITORDB_WireOutInconsistency dc; - - - struct GNUNET_JSON_Specification spec[] = { - - GNUNET_JSON_spec_string ("destination_account", (const - char **) &dc. - destination_account), - TALER_JSON_spec_amount ("expected", TAH_currency, &dc.expected), - TALER_JSON_spec_amount ("claimed", TAH_currency, &dc.claimed), - - - GNUNET_JSON_spec_end () - }; - - - json_t *json; - - (void) rh; - (void) connection_cls; - (void) upload_data; - (void) upload_data_size; - { - enum GNUNET_GenericReturnValue res; - - res = TALER_MHD_parse_post_json (connection, - connection_cls, - upload_data, - upload_data_size, - &json); - if (GNUNET_SYSERR == res) - return MHD_NO; - if ((GNUNET_NO == res) || - (NULL == json)) - return MHD_YES; - res = TALER_MHD_parse_json_data (connection, - json, - spec); - if (GNUNET_SYSERR == res) - { - json_decref (json); - return MHD_NO; /* hard failure */ - } - if (GNUNET_NO == res) - { - json_decref (json); - return MHD_YES; /* failure */ - } - } - - MHD_RESULT res; - - res = process_inconsistency (connection, &dc); - GNUNET_JSON_parse_free (spec); - - json_decref (json); - return res; - -} - - -void -TEAH_WIRE_OUT_INCONSISTENCY_PUT_init (void) -{ - -} - - -void -TEAH_WIRE_OUT_INCONSISTENCY_PUT_done (void) -{ - -} diff --git a/src/auditor/taler-auditor-httpd_wire-out-inconsistency-put.h b/src/auditor/taler-auditor-httpd_wire-out-inconsistency-put.h deleted file mode 100644 index a9e4ebc88..000000000 --- a/src/auditor/taler-auditor-httpd_wire-out-inconsistency-put.h +++ /dev/null @@ -1,58 +0,0 @@ -/* - 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/> - */ - - -#ifndef SRC_TALER_AUDITOR_HTTPD_WIRE_OUT_INCONSISTENCY_PUT_H -#define SRC_TALER_AUDITOR_HTTPD_WIRE_OUT_INCONSISTENCY_PUT_H - -#include <microhttpd.h> -#include "taler-auditor-httpd.h" - -/** -* Initialize subsystem. -*/ -void -TEAH_BAD_WIRE_OUT_INCONSISTENCY_init (void); - -/** -* Shut down subsystem. -*/ -void -TEAH_BAD_WIRE_OUT_INCONSISTENCY_done (void); - - -/** -* Handle a "/wire-out-inconsistency" request. Parses the JSON, and, if -* successful, checks the signatures and stores the result in the DB. -* -* @param rh context of the handler -* @param connection the MHD connection to handle -* @param[in,out] connection_cls the connection's closure (can be updated) -* @param upload_data upload data -* @param[in,out] upload_data_size number of bytes (left) in @a upload_data -* @return MHD result code -*/ -MHD_RESULT -TAH_WIRE_OUT_INCONSISTENCY_handler_put (struct TAH_RequestHandler *rh, - struct MHD_Connection * - connection, - void **connection_cls, - const char *upload_data, - size_t *upload_data_size, - const char *const args[]); - - -#endif // SRC_TALER_AUDITOR_HTTPD_WIRE_OUT_INCONSISTENCY_PUT_H diff --git a/src/auditordb/pg_get_amount_arithmetic_inconsistency.h b/src/auditordb/pg_get_amount_arithmetic_inconsistency.h index 7cf4260fe..02f55b24c 100644 --- a/src/auditordb/pg_get_amount_arithmetic_inconsistency.h +++ b/src/auditordb/pg_get_amount_arithmetic_inconsistency.h @@ -24,8 +24,8 @@ * Get information about deposit confirmations from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -40,4 +40,4 @@ TAH_PG_get_amount_arithmetic_inconsistency ( TALER_AUDITORDB_AmountArithmeticInconsistencyCallback cb, void *cb_cls); -#endif // SRC_PG_GET_AMOUNT_ARITHMETIC_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_auditor_closure_lags.h b/src/auditordb/pg_get_auditor_closure_lags.h index 03822864e..7c1148575 100644 --- a/src/auditordb/pg_get_auditor_closure_lags.h +++ b/src/auditordb/pg_get_auditor_closure_lags.h @@ -28,6 +28,8 @@ * @param cls the @e cls of this struct with the plugin-specific state * @param start_id row/serial ID where to start the iteration (0 from * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +44,4 @@ TAH_PG_get_auditor_closure_lags ( TALER_AUDITORDB_ClosureLagsCallback cb, void *cb_cls); -#endif // SRC_PG_GET_AUDITOR_CLOSURE_LAGS_H +#endif diff --git a/src/auditordb/pg_get_bad_sig_losses.h b/src/auditordb/pg_get_bad_sig_losses.h index 5694458d3..8cf04eddd 100644 --- a/src/auditordb/pg_get_bad_sig_losses.h +++ b/src/auditordb/pg_get_bad_sig_losses.h @@ -25,9 +25,12 @@ * Get information about bad signature losses from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? + * @param filter_spec_pub filter by @a op_spec_pub + * @param op_spec_pub public key to filter by; FIXME: replace by pointer + * @param op operation to filter by * @param cb function to call with results * @param cb_cls closure for @a cb * @return query result status @@ -44,4 +47,4 @@ TAH_PG_get_bad_sig_losses ( TALER_AUDITORDB_BadSigLossesCallback cb, void *cb_cls); -#endif // SRC_PG_GET_BAD_SIG_LOSSES_H +#endif diff --git a/src/auditordb/pg_get_balances.h b/src/auditordb/pg_get_balances.h index 48c9287b1..4507c277f 100644 --- a/src/auditordb/pg_get_balances.h +++ b/src/auditordb/pg_get_balances.h @@ -22,18 +22,21 @@ #include "taler_json_lib.h" #include "taler_auditordb_plugin.h" + /** * Get information about balances from the database. * * @param cls the @e cls of this struct with the plugin-specific state * @param start_id row/serial ID where to start the iteration (0 from * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? + * @param balance_key key to look for * @param cb function to call with results * @param cb_cls closure for @a cb * @return query result status */ - enum GNUNET_DB_QueryStatus TAH_PG_get_balances ( void *cls, @@ -44,4 +47,4 @@ TAH_PG_get_balances ( TALER_AUDITORDB_BalancesCallback cb, void *cb_cls); -#endif // SRC_PG_GET_BALANCES_H +#endif diff --git a/src/auditordb/pg_get_coin_inconsistency.h b/src/auditordb/pg_get_coin_inconsistency.h index 9bff05397..00e700e42 100644 --- a/src/auditordb/pg_get_coin_inconsistency.h +++ b/src/auditordb/pg_get_coin_inconsistency.h @@ -24,8 +24,8 @@ * Get information about deposit confirmations from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -41,4 +41,4 @@ TAH_PG_get_coin_inconsistency ( void *cb_cls); -#endif // SRC_PG_GET_COIN_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_denomination_key_validity_withdraw_inconsistency.h b/src/auditordb/pg_get_denomination_key_validity_withdraw_inconsistency.h index 199e2c364..1f0b375a8 100644 --- a/src/auditordb/pg_get_denomination_key_validity_withdraw_inconsistency.h +++ b/src/auditordb/pg_get_denomination_key_validity_withdraw_inconsistency.h @@ -24,8 +24,8 @@ * Get information about denominations key validity withdraw inconsistency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -40,4 +40,4 @@ TAH_PG_get_denomination_key_validity_withdraw_inconsistency ( TALER_AUDITORDB_DenominationKeyValidityWithdrawInconsistencyCallback cb, void *cb_cls); -#endif // SRC_PG_GET_DENOMINATION_KEY_VALIDITY_WITHDRAW_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_denomination_pending.h b/src/auditordb/pg_get_denomination_pending.h index f1578553b..478c3248c 100644 --- a/src/auditordb/pg_get_denomination_pending.h +++ b/src/auditordb/pg_get_denomination_pending.h @@ -26,8 +26,8 @@ * Get information about denomination-pending from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_denomination_pending ( TALER_AUDITORDB_DenominationPendingCallback cb, void *cb_cls); -#endif // SRC_PG_GET_DENOMINATION_PENDING_H +#endif diff --git a/src/auditordb/pg_get_denominations_without_sigs.h b/src/auditordb/pg_get_denominations_without_sigs.h index 63bb54583..bfbec7aa3 100644 --- a/src/auditordb/pg_get_denominations_without_sigs.h +++ b/src/auditordb/pg_get_denominations_without_sigs.h @@ -26,8 +26,8 @@ * Get information about denominations-without-sigs from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_denominations_without_sigs ( TALER_AUDITORDB_DenominationsWithoutSigsCallback cb, void *cb_cls); -#endif // SRC_PG_GET_DENOMINATIONS_WITHOUT_SIGS_H +#endif diff --git a/src/auditordb/pg_get_deposit_confirmations.h b/src/auditordb/pg_get_deposit_confirmations.h index 141f2a276..299bd02dc 100644 --- a/src/auditordb/pg_get_deposit_confirmations.h +++ b/src/auditordb/pg_get_deposit_confirmations.h @@ -30,8 +30,8 @@ * Get information about deposit confirmations from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb diff --git a/src/auditordb/pg_get_emergency.h b/src/auditordb/pg_get_emergency.h index 09530920e..df4b7da7f 100644 --- a/src/auditordb/pg_get_emergency.h +++ b/src/auditordb/pg_get_emergency.h @@ -24,8 +24,8 @@ * Get information about emergency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -40,4 +40,4 @@ TAH_PG_get_emergency ( TALER_AUDITORDB_EmergencyCallback cb, void *cb_cls); -#endif // SRC_PG_GET_EMERGENCY_H +#endif diff --git a/src/auditordb/pg_get_emergency_by_count.h b/src/auditordb/pg_get_emergency_by_count.h index 2054e2aee..5961fd68f 100644 --- a/src/auditordb/pg_get_emergency_by_count.h +++ b/src/auditordb/pg_get_emergency_by_count.h @@ -24,8 +24,8 @@ * Get information about emergency by count from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -40,4 +40,4 @@ TAH_PG_get_emergency_by_count ( TALER_AUDITORDB_EmergenciesByCountCallback cb, void *cb_cls); -#endif // SRC_PG_GET_EMERGENCY_BY_COUNT_H +#endif diff --git a/src/auditordb/pg_get_exchange_signkeys.h b/src/auditordb/pg_get_exchange_signkeys.h index e30602c48..58d7e1411 100644 --- a/src/auditordb/pg_get_exchange_signkeys.h +++ b/src/auditordb/pg_get_exchange_signkeys.h @@ -26,8 +26,8 @@ * Get information about exchange-signkeys from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_exchange_signkeys ( TALER_AUDITORDB_ExchangeSignkeysCallback cb, void *cb_cls); -#endif // SRC_PG_GET_EXCHANGE_SIGNKEYS_H +#endif diff --git a/src/auditordb/pg_get_fee_time_inconsistency.h b/src/auditordb/pg_get_fee_time_inconsistency.h index 8874cffff..cb84d6712 100644 --- a/src/auditordb/pg_get_fee_time_inconsistency.h +++ b/src/auditordb/pg_get_fee_time_inconsistency.h @@ -24,8 +24,8 @@ * Get information about fee time inconsistency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -40,4 +40,4 @@ TAH_PG_get_fee_time_inconsistency ( TALER_AUDITORDB_FeeTimeInconsistencyCallback cb, void *cb_cls); -#endif // SRC_PG_GET_FEE_TIME_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_historic_denomination_revenue.h b/src/auditordb/pg_get_historic_denomination_revenue.h index c5847c667..01e2820ea 100644 --- a/src/auditordb/pg_get_historic_denomination_revenue.h +++ b/src/auditordb/pg_get_historic_denomination_revenue.h @@ -26,8 +26,8 @@ * Get information about historic-denomination-revenue from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_historic_denomination_revenue ( TALER_AUDITORDB_HistoricDenominationRevenueCallback cb, void *cb_cls); -#endif // SRC_PG_GET_HISTORIC_DENOMINATION_REVENUE_H +#endif diff --git a/src/auditordb/pg_get_historic_reserve_summary.h b/src/auditordb/pg_get_historic_reserve_summary.h index 2d4f16dbe..70b5dd59e 100644 --- a/src/auditordb/pg_get_historic_reserve_summary.h +++ b/src/auditordb/pg_get_historic_reserve_summary.h @@ -26,8 +26,8 @@ * Get information about historic-reserve-summary from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_historic_reserve_summary ( TALER_AUDITORDB_HistoricReserveSummaryCallback cb, void *cb_cls); -#endif // SRC_PG_GET_HISTORIC_RESERVE_SUMMARY_H +#endif diff --git a/src/auditordb/pg_get_misattribution_in_inconsistency.h b/src/auditordb/pg_get_misattribution_in_inconsistency.h index e8f7d4bf7..a6ac0bb0d 100644 --- a/src/auditordb/pg_get_misattribution_in_inconsistency.h +++ b/src/auditordb/pg_get_misattribution_in_inconsistency.h @@ -26,8 +26,8 @@ * Get information about misattribution-in-inconsistency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_misattribution_in_inconsistency ( TALER_AUDITORDB_MisattributionInInconsistencyCallback cb, void *cb_cls); -#endif // SRC_PG_GET_MISATTRIBUTION_IN_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_purse_not_closed_inconsistencies.h b/src/auditordb/pg_get_purse_not_closed_inconsistencies.h index ef7bdb3ae..b68c5cfe7 100644 --- a/src/auditordb/pg_get_purse_not_closed_inconsistencies.h +++ b/src/auditordb/pg_get_purse_not_closed_inconsistencies.h @@ -24,8 +24,8 @@ * Get information about purse not closed inconsistencies from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -40,4 +40,4 @@ TAH_PG_get_purse_not_closed_inconsistencies ( TALER_AUDITORDB_PurseNotClosedInconsistenciesCallback cb, void *cb_cls); -#endif // SRC_PG_GET_PURSE_NOT_CLOSED_INCONSISTENCIES_H +#endif diff --git a/src/auditordb/pg_get_purses.h b/src/auditordb/pg_get_purses.h index b0dc3183b..5ee19bf2e 100644 --- a/src/auditordb/pg_get_purses.h +++ b/src/auditordb/pg_get_purses.h @@ -26,8 +26,8 @@ * Get information about purses from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_purses ( TALER_AUDITORDB_PursesCallback cb, void *cb_cls); -#endif // SRC_PG_GET_PURSES_H +#endif diff --git a/src/auditordb/pg_get_refreshes_hanging.h b/src/auditordb/pg_get_refreshes_hanging.h index b4fd26708..566704a8d 100644 --- a/src/auditordb/pg_get_refreshes_hanging.h +++ b/src/auditordb/pg_get_refreshes_hanging.h @@ -24,8 +24,8 @@ * Get information about hanging refreshes from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -40,4 +40,4 @@ TAH_PG_get_refreshes_hanging ( TALER_AUDITORDB_RefreshesHangingCallback cb, void *cb_cls); -#endif // SRC_PG_GET_REFRESHES_HANGING_H +#endif diff --git a/src/auditordb/pg_get_reserve_balance_insufficient_inconsistency.h b/src/auditordb/pg_get_reserve_balance_insufficient_inconsistency.h index d2e0fa3ed..e9a4dceb5 100644 --- a/src/auditordb/pg_get_reserve_balance_insufficient_inconsistency.h +++ b/src/auditordb/pg_get_reserve_balance_insufficient_inconsistency.h @@ -24,8 +24,8 @@ * Get information about reserve balance insufficient inconsistency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -40,4 +40,4 @@ TAH_PG_get_reserve_balance_insufficient_inconsistency ( TALER_AUDITORDB_ReserveBalanceInsufficientInconsistencyCallback cb, void *cb_cls); -#endif // SRC_PG_GET_RESERVE_BALANCE_INSUFFICIENT_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_reserve_balance_summary_wrong_inconsistency.h b/src/auditordb/pg_get_reserve_balance_summary_wrong_inconsistency.h index 8cafd4f44..69f36af75 100644 --- a/src/auditordb/pg_get_reserve_balance_summary_wrong_inconsistency.h +++ b/src/auditordb/pg_get_reserve_balance_summary_wrong_inconsistency.h @@ -26,8 +26,8 @@ * Get information about reserve-balance-summary-wrong-inconsistency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_reserve_balance_summary_wrong_inconsistency ( TALER_AUDITORDB_ReserveBalanceSummaryWrongInconsistencyCallback cb, void *cb_cls); -#endif // SRC_PG_GET_RESERVE_BALANCE_SUMMARY_WRONG_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_reserve_in_inconsistency.h b/src/auditordb/pg_get_reserve_in_inconsistency.h index 26244f67c..335b067af 100644 --- a/src/auditordb/pg_get_reserve_in_inconsistency.h +++ b/src/auditordb/pg_get_reserve_in_inconsistency.h @@ -26,8 +26,8 @@ * Get information about reserve-in-inconsistency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_reserve_in_inconsistency ( TALER_AUDITORDB_ReserveInInconsistencyCallback cb, void *cb_cls); -#endif // SRC_PG_GET_RESERVE_IN_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_reserve_not_closed_inconsistency.h b/src/auditordb/pg_get_reserve_not_closed_inconsistency.h index 623c98b89..2ef001d3b 100644 --- a/src/auditordb/pg_get_reserve_not_closed_inconsistency.h +++ b/src/auditordb/pg_get_reserve_not_closed_inconsistency.h @@ -26,8 +26,8 @@ * Get information about reserve-not-closed-inconsistency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_reserve_not_closed_inconsistency ( TALER_AUDITORDB_ReserveNotClosedInconsistencyCallback cb, void *cb_cls); -#endif // SRC_PG_GET_RESERVE_NOT_CLOSED_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_reserves.h b/src/auditordb/pg_get_reserves.h index 1af347a3e..6c07233b3 100644 --- a/src/auditordb/pg_get_reserves.h +++ b/src/auditordb/pg_get_reserves.h @@ -26,8 +26,8 @@ * Get information about reserves from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_reserves ( TALER_AUDITORDB_ReservesCallback cb, void *cb_cls); -#endif // SRC_PG_GET_RESERVES_H +#endif diff --git a/src/auditordb/pg_get_row_inconsistency.h b/src/auditordb/pg_get_row_inconsistency.h index 4aa13e36d..cef52b114 100644 --- a/src/auditordb/pg_get_row_inconsistency.h +++ b/src/auditordb/pg_get_row_inconsistency.h @@ -24,8 +24,8 @@ * Get information about deposit confirmations from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -41,4 +41,4 @@ TAH_PG_get_row_inconsistency ( void *cb_cls); -#endif // SRC_PG_GET_ROW_INCONSISTENCY_H +#endif diff --git a/src/auditordb/pg_get_row_minor_inconsistencies.h b/src/auditordb/pg_get_row_minor_inconsistencies.h index 0fee08db2..18928ad8d 100644 --- a/src/auditordb/pg_get_row_minor_inconsistencies.h +++ b/src/auditordb/pg_get_row_minor_inconsistencies.h @@ -26,8 +26,8 @@ * Get information about row-minor-inconsistencies from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb @@ -42,4 +42,4 @@ TAH_PG_get_row_minor_inconsistencies ( TALER_AUDITORDB_RowMinorInconsistenciesCallback cb, void *cb_cls); -#endif // SRC_PG_GET_ROW_MINOR_INCONSISTENCIES_H +#endif diff --git a/src/auditordb/pg_get_wire_format_inconsistency.h b/src/auditordb/pg_get_wire_format_inconsistency.h index 87ba9d14b..321d562f0 100644 --- a/src/auditordb/pg_get_wire_format_inconsistency.h +++ b/src/auditordb/pg_get_wire_format_inconsistency.h @@ -26,8 +26,8 @@ * Get information about wire-format-inconsistency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb diff --git a/src/auditordb/pg_get_wire_out_inconsistency.h b/src/auditordb/pg_get_wire_out_inconsistency.h index 619f755a1..2bbc2c3c5 100644 --- a/src/auditordb/pg_get_wire_out_inconsistency.h +++ b/src/auditordb/pg_get_wire_out_inconsistency.h @@ -26,8 +26,8 @@ * Get information about wire-out-inconsistency from the database. * * @param cls the @e cls of this struct with the plugin-specific state - * @param start_id row/serial ID where to start the iteration (0 from - * the start, exclusive, i.e. serial_ids must start from 1) + * @param limit number of records to return, negative for descending + * @param offset table row to start from, exclusive, direction determined by @a limit * @param return_suppressed should suppressed rows be returned anyway? * @param cb function to call with results * @param cb_cls closure for @a cb |