real-time-auditor

1 files changed, 144 insertions, 0 deletions

diff --git a/src/auditor/taler-auditor-httpd_purse-not-closed-inconsistencies-get.c b/src/auditor/taler-auditor-httpd_purse-not-closed-inconsistencies-get.c
new file mode 100644
index 000000000..f08f02f5c
--- /dev/null
+++ b/src/auditor/taler-auditor-httpd_purse-not-closed-inconsistencies-get.c
@@ -0,0 +1,144 @@
+/*
+   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-get.h"
+
+/**
+* Add purse-not-closed-inconsistencies to the list.
+*
+* @param[in,out] cls a `json_t *` array to extend
+* @param serial_id location of the @a dc in the database
+* @param dc struct of inconsistencies
+* @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
+*/
+static enum GNUNET_GenericReturnValue
+process_purse_not_closed_inconsistencies (void *cls,
+                                          uint64_t serial_id,
+                                          const struct
+                                          TALER_AUDITORDB_PurseNotClosedInconsistencies
+                                          *dc)
+{
+  json_t *list = cls;
+  json_t *obj;
+
+  obj = GNUNET_JSON_PACK (
+
+    GNUNET_JSON_pack_data_auto ("purse_pub", &dc->purse_pub),
+    TALER_JSON_pack_amount ("amount", &dc->amount),
+    TALER_JSON_pack_time_abs_human ("expiration_date", dc->expiration_date)
+
+
+    );
+  GNUNET_break (0 ==
+                json_array_append_new (list,
+                                       obj));
+
+
+  return GNUNET_OK;
+}
+
+
+/**
+*
+* @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_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[])
+{
+  json_t *ja;
+  enum GNUNET_DB_QueryStatus qs;
+
+  (void) rh;
+  (void) connection_cls;
+  (void) upload_data;
+  (void) upload_data_size;
+  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);
+  }
+  ja = json_array ();
+  GNUNET_break (NULL != ja);
+
+  int64_t limit = -20;
+  uint64_t offset;
+
+  TALER_MHD_parse_request_snumber (connection,
+                                   "limit",
+                                   &limit);
+
+  if (limit < 0)
+    offset = INT64_MAX;
+  else
+    offset = 0;
+
+  TALER_MHD_parse_request_number (connection,
+                                  "offset",
+                                  &offset);
+
+  bool return_suppressed = false;
+
+
+  qs = TAH_plugin->get_purse_not_closed_inconsistencies (
+    TAH_plugin->cls,
+    limit,
+    offset,
+    return_suppressed,
+    &process_purse_not_closed_inconsistencies,
+    ja);
+
+  if (0 > qs)
+  {
+    GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs);
+    json_decref (ja);
+    TALER_LOG_WARNING (
+      "Failed to handle GET /purse-not-closed-inconsistencies\n");
+    return TALER_MHD_reply_with_error (connection,
+                                       MHD_HTTP_INTERNAL_SERVER_ERROR,
+                                       TALER_EC_GENERIC_DB_FETCH_FAILED,
+                                       "purse-not-closed-inconsistencies");
+  }
+  return TALER_MHD_REPLY_JSON_PACK (
+    connection,
+    MHD_HTTP_OK,
+    GNUNET_JSON_pack_array_steal ("purse-not-closed-inconsistencies",
+                                  ja));
+}