exchange

Base system with REST service to issue digital coins, run by the payment service provider
Log | Files | Refs | Submodules | README | LICENSE

taler-auditor-httpd_get-monitoring-reserves.c (4662B)

      1 /*
      2    This file is part of TALER
      3    Copyright (C) 2024 Taler Systems SA
      4 
      5    TALER is free software; you can redistribute it and/or modify it under the
      6    terms of the GNU General Public License as published by the Free Software
      7    Foundation; either version 3, or (at your option) any later version.
      8 
      9    TALER is distributed in the hope that it will be useful, but WITHOUT ANY
     10    WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
     11    A PARTICULAR PURPOSE.  See the GNU General Public License for more details.
     12 
     13    You should have received a copy of the GNU General Public License along with
     14    TALER; see the file COPYING.  If not, see <http://www.gnu.org/licenses/>
     15  */
     16 #include <gnunet/gnunet_util_lib.h>
     17 #include <gnunet/gnunet_json_lib.h>
     18 #include <jansson.h>
     19 #include <microhttpd.h>
     20 #include <pthread.h>
     21 #include "taler/taler_json_lib.h"
     22 #include "taler/taler_mhd_lib.h"
     23 #include "taler-auditor-httpd.h"
     24 #include "taler-auditor-httpd_get-monitoring-reserves.h"
     25 #include "auditor-database/get_reserves.h"
     26 #include "auditor-database/preflight.h"
     27 
     28 
     29 /**
     30  * Add reserves to the list.
     31  *
     32  * @param[in,out] cls a `json_t *` array to extend
     33  * @param serial_id location of the @a dc in the database
     34  * @param dc struct of inconsistencies
     35  * @return #GNUNET_OK to continue to iterate, #GNUNET_SYSERR to stop iterating
     36  */
     37 static enum GNUNET_GenericReturnValue
     38 process_reserves (
     39   void *cls,
     40   uint64_t serial_id,
     41   const struct TALER_AUDITORDB_Reserves *dc)
     42 {
     43   json_t *list = cls;
     44   json_t *obj;
     45 
     46   obj = GNUNET_JSON_PACK (
     47     GNUNET_JSON_pack_int64 ("auditor_reserves_rowid",
     48                             dc->auditor_reserves_rowid),
     49     GNUNET_JSON_pack_data_auto ("reserve_pub",
     50                                 &dc->reserve_pub),
     51     TALER_JSON_pack_amount ("reserve_balance",
     52                             &dc->reserve_balance),
     53     TALER_JSON_pack_amount ("reserve_loss",
     54                             &dc->reserve_loss),
     55     TALER_JSON_pack_amount ("withdraw_fee_balance",
     56                             &dc->withdraw_fee_balance),
     57     TALER_JSON_pack_amount ("close_fee_balance",
     58                             &dc->close_fee_balance),
     59     TALER_JSON_pack_amount ("purse_fee_balance",
     60                             &dc->purse_fee_balance),
     61     TALER_JSON_pack_amount ("open_fee_balance",
     62                             &dc->open_fee_balance),
     63     TALER_JSON_pack_amount ("history_fee_balance",
     64                             &dc->history_fee_balance),
     65     TALER_JSON_pack_time_abs_human ("expiration_date",
     66                                     dc->expiration_date),
     67     GNUNET_JSON_pack_allow_null (
     68       TALER_JSON_pack_full_payto ("origin_account",
     69                                   dc->origin_account))
     70     );
     71   GNUNET_break (0 ==
     72                 json_array_append_new (list,
     73                                        obj));
     74   return GNUNET_OK;
     75 }
     76 
     77 
     78 enum MHD_Result
     79 TAH_get_monitoring_reserves (
     80   struct TAH_RequestHandler *rh,
     81   struct MHD_Connection *connection,
     82   void **connection_cls,
     83   const char *upload_data,
     84   size_t *upload_data_size,
     85   const char *const args[])
     86 {
     87   json_t *ja;
     88   enum GNUNET_DB_QueryStatus qs;
     89   int64_t limit = -20;
     90   uint64_t offset;
     91 
     92   (void) rh;
     93   (void) connection_cls;
     94   (void) upload_data;
     95   (void) upload_data_size;
     96   if (GNUNET_SYSERR ==
     97       TALER_AUDITORDB_preflight (TAH_apg))
     98   {
     99     GNUNET_break (0);
    100     return TALER_MHD_reply_with_error (connection,
    101                                        MHD_HTTP_INTERNAL_SERVER_ERROR,
    102                                        TALER_EC_GENERIC_DB_SETUP_FAILED,
    103                                        NULL);
    104   }
    105   TALER_MHD_parse_request_snumber (connection,
    106                                    "limit",
    107                                    &limit);
    108 
    109   if (limit < 0)
    110     offset = INT64_MAX;
    111   else
    112     offset = 0;
    113   TALER_MHD_parse_request_number (connection,
    114                                   "offset",
    115                                   &offset);
    116   ja = json_array ();
    117   GNUNET_break (NULL != ja);
    118   qs = TALER_AUDITORDB_get_reserves (
    119     TAH_apg,
    120     limit,
    121     offset,
    122     &process_reserves,
    123     ja);
    124   if (0 > qs)
    125   {
    126     GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR == qs);
    127     json_decref (ja);
    128     TALER_LOG_WARNING (
    129       "Failed to handle GET /reserves");
    130     return TALER_MHD_reply_with_error (connection,
    131                                        MHD_HTTP_INTERNAL_SERVER_ERROR,
    132                                        TALER_EC_GENERIC_DB_FETCH_FAILED,
    133                                        "reserves");
    134   }
    135   return TALER_MHD_REPLY_JSON_PACK (
    136     connection,
    137     MHD_HTTP_OK,
    138     GNUNET_JSON_pack_array_steal ("reserves",
    139                                   ja));
    140 }