exchange

commit 2d3e7e86dba75c881dc15a9c76f221e312dd84df
parent ce9de215f728e7734aed98b30c9d41629984848a
Author: Christian Grothoff <christian@grothoff.org>
Date:   Thu, 29 Aug 2024 06:48:31 +0200

-actually call new stored procedure

Diffstat:
M
src/exchangedb/pg_select_aggregations_above_serial.c
 | 
7
+++----

1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/src/exchangedb/pg_select_aggregations_above_serial.c b/src/exchangedb/pg_select_aggregations_above_serial.c
@@ -75,7 +75,7 @@ aggregation_serial_helper_cb (void *cls,
     uint64_t batch_deposit_serial_id;
     struct TALER_Amount amount;
     struct GNUNET_PQ_ResultSpec rs[] = {
-      TALER_PQ_RESULT_SPEC_AMOUNT ("amount",
+      TALER_PQ_RESULT_SPEC_AMOUNT ("total_amount",
                                    &amount),
       GNUNET_PQ_result_spec_uint64 ("aggregation_serial_id",
                                     &tracking_rowid),
@@ -128,9 +128,8 @@ TEH_PG_select_aggregations_above_serial (
            "SELECT"
            " aggregation_serial_id"
            ",batch_deposit_serial_id"
-           " FROM aggregation_tracking"
-           " WHERE aggregation_serial_id>=$1"
-           " ORDER BY aggregation_serial_id ASC;");
+           ",total_amount"
+           " FROM exchange_do_select_aggregations_above_serial($1);");
   qs = GNUNET_PQ_eval_prepared_multi_select (pg->conn,
                                              "select_aggregations_above_serial",
                                              params,