Line data    Source code

       1              : /*
       2              :   This file is part of TALER
       3              :   (C) 2025 Taler Systems SA
       4              : 
       5              :   TALER is free software; you can redistribute it and/or modify it under the
       6              :   terms of the GNU Affero 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 Affero General Public License for more
      12              :   details.
      13              : 
      14              :   You should have received a copy of the GNU Affero General Public License
      15              :   along with TALER; see the file COPYING.  If not, see
      16              :   <http://www.gnu.org/licenses/>
      17              : */
      18              : /**
      19              :  * @file src/backend/taler-merchant-httpd_get-private-reports.c
      20              :  * @brief implementation of GET /private/reports
      21              :  * @author Christian Grothoff
      22              :  */
      23              : #include "platform.h"
      24              : #include "taler-merchant-httpd_get-private-reports.h"
      25              : #include <taler/taler_json_lib.h>
      26              : #include <taler/taler_dbevents.h>
      27              : #include "merchant-database/iterate_reports.h"
      28              : 
      29              : 
      30              : /**
      31              :  * Sensible bound on the limit.
      32              :  */
      33              : #define MAX_DELTA 1024
      34              : 
      35              : 
      36              : /**
      37              :  * Callback for listing reports.
      38              :  *
      39              :  * @param cls closure with a `json_t *`
      40              :  * @param report_id unique identifier of the report
      41              :  * @param report_description human-readable description
      42              :  * @param frequency how often the report is generated
      43              :  */
      44              : static void
      45            0 : add_report (void *cls,
      46              :             uint64_t report_id,
      47              :             const char *report_description,
      48              :             struct GNUNET_TIME_Relative frequency)
      49              : {
      50            0 :   json_t *reports = cls;
      51              :   json_t *entry;
      52              : 
      53            0 :   entry = GNUNET_JSON_PACK (
      54              :     GNUNET_JSON_pack_uint64 ("report_serial",
      55              :                              report_id),
      56              :     GNUNET_JSON_pack_string ("description",
      57              :                              report_description),
      58              :     GNUNET_JSON_pack_time_rel ("report_frequency",
      59              :                                frequency));
      60            0 :   GNUNET_assert (NULL != entry);
      61            0 :   GNUNET_assert (0 ==
      62              :                  json_array_append_new (reports,
      63              :                                         entry));
      64            0 : }
      65              : 
      66              : 
      67              : enum MHD_Result
      68            0 : TMH_private_get_reports (const struct TMH_RequestHandler *rh,
      69              :                          struct MHD_Connection *connection,
      70              :                          struct TMH_HandlerContext *hc)
      71              : {
      72            0 :   int64_t limit = -20;
      73              :   uint64_t offset;
      74              :   enum GNUNET_DB_QueryStatus qs;
      75              :   json_t *reports;
      76              : 
      77              :   (void) rh;
      78            0 :   TALER_MHD_parse_request_snumber (connection,
      79              :                                    "limit",
      80              :                                    &limit);
      81            0 :   if (limit > 0)
      82            0 :     offset = 0;
      83              :   else
      84            0 :     offset = INT64_MAX;
      85            0 :   TALER_MHD_parse_request_number (connection,
      86              :                                   "offset",
      87              :                                   &offset);
      88            0 :   if ( (-MAX_DELTA > limit) ||
      89            0 :        (limit > MAX_DELTA) )
      90              :   {
      91            0 :     GNUNET_break_op (0);
      92            0 :     return TALER_MHD_reply_with_error (connection,
      93              :                                        MHD_HTTP_BAD_REQUEST,
      94              :                                        TALER_EC_GENERIC_PARAMETER_MALFORMED,
      95              :                                        "limit");
      96              :   }
      97              : 
      98            0 :   reports = json_array ();
      99            0 :   GNUNET_assert (NULL != reports);
     100            0 :   qs = TALER_MERCHANTDB_iterate_reports (TMH_db,
     101            0 :                                          hc->instance->settings.id,
     102              :                                          limit,
     103              :                                          offset,
     104              :                                          &add_report,
     105              :                                          reports);
     106            0 :   if (qs < 0)
     107              :   {
     108            0 :     json_decref (reports);
     109            0 :     return TALER_MHD_reply_with_error (connection,
     110              :                                        MHD_HTTP_INTERNAL_SERVER_ERROR,
     111              :                                        TALER_EC_GENERIC_DB_FETCH_FAILED,
     112              :                                        "iterate_reports");
     113              :   }
     114              : 
     115            0 :   return TALER_MHD_REPLY_JSON_PACK (
     116              :     connection,
     117              :     MHD_HTTP_OK,
     118              :     GNUNET_JSON_pack_array_steal ("reports",
     119              :                                   reports));
     120              : }