commit 94d8d6b48e7fdaf7c7caf47a39faa8a33a72915f
parent 535a0c9988d7b6ecbd8352808ad5e0918fdc056e
Author: Christian Grothoff <christian@grothoff.org>
Date: Sun, 5 Jun 2016 11:29:16 +0200
split /track handlers into two files
Diffstat:
8 files changed, 922 insertions(+), 836 deletions(-)
diff --git a/src/backend/Makefile.am b/src/backend/Makefile.am
@@ -21,7 +21,8 @@ taler_merchant_httpd_SOURCES = \
taler-merchant-httpd_exchanges.c taler-merchant-httpd_exchanges.h \
taler-merchant-httpd_contract.c taler-merchant-httpd_contract.h \
taler-merchant-httpd_pay.c taler-merchant-httpd_pay.h \
- taler-merchant-httpd_track.c taler-merchant-httpd_track.h
+ taler-merchant-httpd_track-deposit.c taler-merchant-httpd_track-deposit.h \
+ taler-merchant-httpd_track-transaction.c taler-merchant-httpd_track-transaction.h
taler_merchant_httpd_LDADD = \
diff --git a/src/backend/taler-merchant-httpd.c b/src/backend/taler-merchant-httpd.c
@@ -37,7 +37,8 @@
#include "taler-merchant-httpd_exchanges.h"
#include "taler-merchant-httpd_contract.h"
#include "taler-merchant-httpd_pay.h"
-#include "taler-merchant-httpd_track.h"
+#include "taler-merchant-httpd_track-deposit.h"
+#include "taler-merchant-httpd_track-transaction.h"
/**
diff --git a/src/backend/taler-merchant-httpd_track-deposit.c b/src/backend/taler-merchant-httpd_track-deposit.c
@@ -0,0 +1,237 @@
+/*
+ This file is part of TALER
+ (C) 2014, 2015, 2016 INRIA
+
+ TALER is free software; you can redistribute it and/or modify it under the
+ terms of the GNU Affero 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, If not, see <http://www.gnu.org/licenses/>
+*/
+/**
+ * @file backend/taler-merchant-httpd_track-deposit.c
+ * @brief implement API for tracking deposits and wire transfers
+ * @author Marcello Stanisci
+ * @author Christian Grothoff
+ */
+#include "platform.h"
+#include <jansson.h>
+#include <taler/taler_signatures.h>
+#include <taler/taler_json_lib.h>
+#include "taler-merchant-httpd.h"
+#include "taler-merchant-httpd_mhd.h"
+#include "taler-merchant-httpd_parsing.h"
+#include "taler-merchant-httpd_auditors.h"
+#include "taler-merchant-httpd_exchanges.h"
+#include "taler-merchant-httpd_responses.h"
+#include "taler-merchant-httpd_track_deposit.h"
+
+
+/**
+ * How long to wait before giving up processing with the exchange?
+ */
+#define TRACK_TIMEOUT (GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 30))
+
+extern char *TMH_merchant_currency_string;
+
+
+/**
+ * Context used for handing /track/deposit requests.
+ */
+struct DepositTrackContext
+{
+
+ /**
+ * This MUST be first!
+ */
+ struct TM_HandlerContext hc;
+
+ /**
+ * Handle to the exchange.
+ */
+ struct TALER_EXCHANGE_Handle *eh;
+
+ /**
+ * Handle for the /wire/deposits request.
+ */
+ struct TALER_EXCHANGE_WireDepositsHandle *wdh;
+
+ /**
+ *
+ */
+ struct TALER_WireDepositDetails *details;
+
+ /**
+ * Argument for the /wire/deposits request.
+ */
+ struct TALER_WireTransferIdentifierRawP wtid;
+
+ /**
+ * Length of the @e details array.
+ */
+ unsigned int details_length;
+
+ /**
+ * HTTP connection we are handling.
+ */
+ struct MHD_Connection *connection;
+
+ /**
+ * Response code to return.
+ */
+ unsigned int response_code;
+
+ /**
+ *
+ */
+ json_t *json;
+
+ /**
+ * Error message.
+ */
+ const char *error;
+
+};
+
+
+/**
+ * Function called with detailed wire transfer data, including all
+ * of the coin transactions that were combined into the wire transfer.
+ *
+ * @param cls closure
+ * @param http_status HTTP status code we got, 0 on exchange protocol violation
+ * @param json original json reply (may include signatures, those have then been
+ * validated already)
+ * @param wtid extracted wire transfer identifier, or NULL if the exchange could
+ * not provide any (set only if @a http_status is #MHD_HTTP_OK)
+ * @param total_amount total amount of the wire transfer, or NULL if the exchange could
+ * not provide any @a wtid (set only if @a http_status is #MHD_HTTP_OK)
+ * @param details_length length of the @a details array
+ * @param details array with details about the combined transactions
+ */
+static void
+wire_deposit_cb (void *cls,
+ unsigned int http_status,
+ const json_t *json,
+ const struct GNUNET_HashCode *h_wire,
+ const struct TALER_Amount *total_amount,
+ unsigned int details_length,
+ const struct TALER_WireDepositDetails *details)
+{
+ struct DepositTrackContext *rctx = cls;
+ // unsigned int i;
+
+ rctx->wdh = NULL;
+ if (NULL == total_amount)
+ {
+ rctx->error = "failed to obtain /wire/deposit response from exchange";
+ rctx->json = json_incref ((json_t *) json);
+ rctx->response_code = http_status;
+ MHD_resume_connection (rctx->connection);
+ return;
+ }
+ rctx->details_length = details_length;
+ rctx->details = GNUNET_new_array (details_length,
+ struct TALER_WireDepositDetails);
+ memcpy (rctx->details,
+ details,
+ details_length * sizeof (struct TALER_WireDepositDetails));
+ GNUNET_break (0);
+ /* FIXME: now check that these details match what we have in
+ our database... */
+
+
+}
+
+
+/**
+ * Function called with information about who is auditing
+ * a particular exchange and what key the exchange is using.
+ *
+ * @param cls closure
+ * @param keys information about the various keys used
+ * by the exchange, NULL if /keys failed
+ */
+static void
+cert_cb (void *cls,
+ const struct TALER_EXCHANGE_Keys *keys)
+{
+ struct DepositTrackContext *rctx = cls;
+
+ if (NULL == keys)
+ {
+ rctx->error = "failed to obtain /keys from exchange";
+ rctx->response_code = MHD_HTTP_SERVICE_UNAVAILABLE;
+ MHD_resume_connection (rctx->connection);
+ return;
+ }
+ rctx->wdh = TALER_EXCHANGE_wire_deposits (rctx->eh,
+ &rctx->wtid,
+ &wire_deposit_cb,
+ rctx);
+}
+
+
+/**
+ * Manages a /track/wtid call, thus it calls the /track/deposit
+ * offered by the exchange in order to return the set of deposits
+ * (of coins) associated with a given wire transfer.
+ *
+ * @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
+ */
+int
+MH_handler_track_deposit (struct TMH_RequestHandler *rh,
+ struct MHD_Connection *connection,
+ void **connection_cls,
+ const char *upload_data,
+ size_t *upload_data_size)
+{
+ struct DepositTrackContext *rctx;
+ const char *str;
+ const char *uri;
+
+ rctx = *connection_cls;
+ if (NULL != rctx)
+ {
+ // ...
+ }
+ uri = MHD_lookup_connection_value (connection,
+ MHD_GET_ARGUMENT_KIND,
+ "exchange");
+ if (NULL == uri)
+ return TMH_RESPONSE_reply_external_error (connection,
+ "exchange argument missing");
+ str = MHD_lookup_connection_value (connection,
+ MHD_GET_ARGUMENT_KIND,
+ "wtid");
+ if (NULL == str)
+ return TMH_RESPONSE_reply_external_error (connection,
+ "wtid argument missing");
+ if (GNUNET_OK !=
+ GNUNET_STRINGS_string_to_data (str,
+ strlen (str),
+ &rctx->wtid,
+ sizeof (rctx->wtid)))
+ return TMH_RESPONSE_reply_external_error (connection,
+ "wtid argument malformed");
+ rctx->eh = TALER_EXCHANGE_connect (NULL /* FIXME */,
+ uri,
+ &cert_cb,
+ rctx,
+ TALER_EXCHANGE_OPTION_END);
+
+ GNUNET_break (0);
+ return MHD_NO;
+}
+
+/* end of taler-merchant-httpd_track-deposit.c */
diff --git a/src/backend/taler-merchant-httpd_track-deposit.h b/src/backend/taler-merchant-httpd_track-deposit.h
@@ -0,0 +1,47 @@
+/*
+ This file is part of TALER
+ (C) 2014, 2015 GNUnet e.V.
+
+ 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, If not, see <http://www.gnu.org/licenses/>
+*/
+/**
+ * @file backend/taler-merchant-httpd_track-deposit.h
+ * @brief headers for /track/deposit handler
+ * @author Christian Grothoff
+ * @author Marcello Stanisci
+ */
+#ifndef TALER_MERCHANT_HTTPD_TRACK_DEPOSIT_H
+#define TALER_MERCHANT_HTTPD_TRACK_DEPOSIT_H
+#include <microhttpd.h>
+#include "taler-merchant-httpd.h"
+
+/**
+ * Manages a /track/deposit call, thus it calls the /wire/deposit
+ * offered by the exchange in order to return the set of deposits
+ * (of coins) associated with a given wire transfer
+ *
+ * @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
+ */
+int
+MH_handler_track_deposit (struct TMH_RequestHandler *rh,
+ struct MHD_Connection *connection,
+ void **connection_cls,
+ const char *upload_data,
+ size_t *upload_data_size);
+
+
+#endif
diff --git a/src/backend/taler-merchant-httpd_track-transaction.c b/src/backend/taler-merchant-httpd_track-transaction.c
@@ -0,0 +1,589 @@
+/*
+ This file is part of TALER
+ (C) 2014, 2015, 2016 INRIA
+
+ TALER is free software; you can redistribute it and/or modify it under the
+ terms of the GNU Affero 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, If not, see <http://www.gnu.org/licenses/>
+*/
+/**
+ * @file backend/taler-merchant-httpd_track-transaction.c
+ * @brief implement API for tracking deposits and wire transfers
+ * @author Marcello Stanisci
+ * @author Christian Grothoff
+ */
+#include "platform.h"
+#include <jansson.h>
+#include <taler/taler_signatures.h>
+#include <taler/taler_json_lib.h>
+#include "taler-merchant-httpd.h"
+#include "taler-merchant-httpd_mhd.h"
+#include "taler-merchant-httpd_parsing.h"
+#include "taler-merchant-httpd_auditors.h"
+#include "taler-merchant-httpd_exchanges.h"
+#include "taler-merchant-httpd_responses.h"
+#include "taler-merchant-httpd_track-transaction.h"
+
+
+/**
+ * How long to wait before giving up processing with the exchange?
+ */
+#define TRACK_TIMEOUT (GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 30))
+
+extern char *TMH_merchant_currency_string;
+
+
+
+/**
+ * Information we keep for each coin in a /track/transaction operation.
+ */
+struct TrackCoinContext
+{
+ /**
+ * Kept in a DLL.
+ */
+ struct TrackCoinContext *next;
+
+ /**
+ * Kept in a DLL.
+ */
+ struct TrackCoinContext *prev;
+
+ /**
+ * Public key of the coin.
+ */
+ struct TALER_CoinSpendPublicKeyP coin_pub;
+
+ /**
+ * Handle for the request to resolve the WTID for this coin.
+ */
+ struct TALER_EXCHANGE_DepositWtidHandle *dwh;
+
+};
+
+
+/**
+ * Context for a /track/transaction operation.
+ */
+struct TrackTransactionContext
+{
+
+ /**
+ * This field MUST be first.
+ * FIXME: Explain why!
+ */
+ struct TM_HandlerContext hc;
+
+ /**
+ * HTTP request we are handling.
+ */
+ struct MHD_Connection *connection;
+
+ /**
+ * Kept in a DLL.
+ */
+ struct TrackCoinContext *tcc_head;
+
+ /**
+ * Kept in a DLL.
+ */
+ struct TrackCoinContext *tcc_tail;
+
+ /**
+ * Transaction this request is about.
+ */
+ uint64_t transaction_id;
+
+ /**
+ * Hash of wire details for the transaction.
+ */
+ struct GNUNET_HashCode h_wire;
+
+ /**
+ * Timestamp of the transaction.
+ */
+ struct GNUNET_TIME_Absolute timestamp;
+
+ /**
+ * Refund deadline for the transaction.
+ */
+ struct GNUNET_TIME_Absolute refund_deadline;
+
+ /**
+ * Total value of the transaction.
+ */
+ struct TALER_Amount total_amount;
+
+ /**
+ * Hash of the contract.
+ */
+ struct GNUNET_HashCode h_contract;
+
+ /**
+ * Task run on timeout.
+ */
+ struct GNUNET_SCHEDULER_Task *timeout_task;
+
+ /**
+ * Handle for operation to lookup /keys (and auditors) from
+ * the exchange used for this transaction; NULL if no operation is
+ * pending.
+ */
+ struct TMH_EXCHANGES_FindOperation *fo;
+
+ /**
+ * Handle to our exchange, once we found it.
+ */
+ struct TALER_EXCHANGE_Handle *eh;
+
+ /**
+ * Handle we use to resolve transactions for a given WTID.
+ */
+ struct TALER_EXCHANGE_WireDepositsHandle *wdh;
+
+ /**
+ * Response to return upon resume.
+ */
+ struct MHD_Response *response;
+
+ /**
+ * Response code to return upon resume.
+ */
+ unsigned int response_code;
+
+
+};
+
+
+/**
+ * Free the @a tctx.
+ *
+ * @param tctx data to free
+ */
+static void
+free_tctx (struct TrackTransactionContext *tctx)
+{
+ struct TrackCoinContext *tcc;
+
+ while (NULL != (tcc = tctx->tcc_head))
+ {
+ GNUNET_CONTAINER_DLL_remove (tctx->tcc_head,
+ tctx->tcc_tail,
+ tcc);
+ if (NULL != tcc->dwh)
+ {
+ TALER_EXCHANGE_deposit_wtid_cancel (tcc->dwh);
+ tcc->dwh = NULL;
+ }
+ GNUNET_free (tcc);
+ }
+ if (NULL != tctx->fo)
+ {
+ TMH_EXCHANGES_find_exchange_cancel (tctx->fo);
+ tctx->fo = NULL;
+ }
+ if (NULL != tctx->timeout_task)
+ {
+ GNUNET_SCHEDULER_cancel (tctx->timeout_task);
+ tctx->timeout_task = NULL;
+ }
+ GNUNET_free (tctx);
+}
+
+
+/**
+ * Custom cleanup routine for a `struct TrackTransactionContext`.
+ *
+ * @param hc the `struct PayContext` to clean up.
+ */
+static void
+track_transaction_cleanup (struct TM_HandlerContext *hc)
+{
+ struct TrackTransactionContext *tctx = (struct TrackTransactionContext *) hc;
+
+ free_tctx (tctx);
+}
+
+
+/**
+ * Resume the given pay context and send the given response.
+ * Stores the response in the @a pc and signals MHD to resume
+ * the connection. Also ensures MHD runs immediately.
+ *
+ * @param pc payment context
+ * @param response_code response code to use
+ * @param response response data to send back
+ */
+static void
+resume_track_transaction_with_response (struct TrackTransactionContext *ttc,
+ unsigned int response_code,
+ struct MHD_Response *response)
+{
+ ttc->response_code = response_code;
+ ttc->response = response;
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Resuming /track/transaction handling as exchange interaction is done (%u)\n",
+ response_code);
+ if (NULL != ttc->timeout_task)
+ {
+ GNUNET_SCHEDULER_cancel (ttc->timeout_task);
+ ttc->timeout_task = NULL;
+ }
+ MHD_resume_connection (ttc->connection);
+ TMH_trigger_daemon (); /* we resumed, kick MHD */
+}
+
+
+/**
+ * This function is called to trace the wire transfers for
+ * all of the coins of the transaction of the @a tctx. Once
+ * we have traced all coins, we build the response.
+ *
+ * @param tctx track context with established connection to exchange
+ */
+static void
+trace_coins (struct TrackTransactionContext *tctx);
+
+
+/**
+ * Function called with detailed wire transfer data, including all
+ * of the coin transactions that were combined into the wire transfer.
+ *
+ * We now store this information. Then we check if we still have
+ * any coins of the original wire transfer not taken care of.
+ *
+ * @param cls closure
+ * @param http_status HTTP status code we got, 0 on exchange protocol violation
+ * @param json original json reply (may include signatures, those have then been
+ * validated already)
+ * @param wtid extracted wire transfer identifier, or NULL if the exchange could
+ * not provide any (set only if @a http_status is #MHD_HTTP_OK)
+ * @param total_amount total amount of the wire transfer, or NULL if the exchange could
+ * not provide any @a wtid (set only if @a http_status is #MHD_HTTP_OK)
+ * @param details_length length of the @a details array
+ * @param details array with details about the combined transactions
+ */
+static void
+wire_deposits_cb (void *cls,
+ unsigned int http_status,
+ const json_t *json,
+ const struct GNUNET_HashCode *h_wire,
+ const struct TALER_Amount *total_amount,
+ unsigned int details_length,
+ const struct TALER_WireDepositDetails *details)
+{
+ struct TrackTransactionContext *tctx = cls;
+
+ /* FIXME: store data in database */
+ /* FIXME: check which coins of 'tctx' are now covered */
+ GNUNET_break (0);
+ trace_coins (tctx);
+}
+
+
+
+/**
+ * Function called with detailed wire transfer data.
+ * We were trying to find out in which wire transfer one of the
+ * coins was involved in. Now we know. What we do now is first
+ * obtain the inverse: all other coins of that wire transfer,
+ * which is what we prefer to store.
+ *
+ * @param cls closure
+ * @param http_status HTTP status code we got, 0 on exchange protocol violation
+ * @param json original json reply (may include signatures, those have then been
+ * validated already)
+ * @param wtid wire transfer identifier used by the exchange, NULL if exchange did not
+ * yet execute the transaction
+ * @param execution_time actual or planned execution time for the wire transfer
+ * @param coin_contribution contribution to the @a total_amount of the deposited coin (may be NULL)
+ */
+static void
+wtid_cb (void *cls,
+ unsigned int http_status,
+ const json_t *json,
+ const struct TALER_WireTransferIdentifierRawP *wtid,
+ struct GNUNET_TIME_Absolute execution_time,
+ const struct TALER_Amount *coin_contribution)
+{
+ struct TrackTransactionContext *tctx = cls;
+
+ tctx->wdh = TALER_EXCHANGE_wire_deposits (tctx->eh,
+ wtid,
+ &wire_deposits_cb,
+ tctx);
+}
+
+
+/**
+ * This function is called to trace the wire transfers for
+ * all of the coins of the transaction of the @a tctx. Once
+ * we have traced all coins, we build the response.
+ *
+ * @param tctx track context with established connection to exchange
+ */
+static void
+trace_coins (struct TrackTransactionContext *tctx)
+{
+ GNUNET_assert (NULL != tctx->eh);
+
+ GNUNET_break (0);
+#if ALL_COINS_DONE
+ if (0)
+ {
+ generate_response ();
+ resume_track_transaction_with_response (tctx,
+ MHD_HTTP_OK,
+ response);
+ return;
+ }
+#endif
+#if FOR_NEXT_COIN_IN_ORDER_ONE_AT_A_TIME_UNTIL_ALL_ARE_DONE
+ tctx->dwh = TALER_EXCHANGE_deposit_wtid (eh,
+ merchant_priv,
+ &tctx->h_wire,
+ &tctx->h_contract,
+ &coin_pub,
+ tctx->transaction_id,
+ &wtid_cb,
+ tctx);
+#endif
+}
+
+
+/**
+ * Function called with the result of our exchange lookup.
+ *
+ * @param cls the `struct TrackTransactionContext`
+ * @param eh NULL if exchange was not found to be acceptable
+ * @param exchange_trusted #GNUNET_YES if this exchange is trusted by config
+ */
+static void
+process_track_transaction_with_exchange (void *cls,
+ struct TALER_EXCHANGE_Handle *eh,
+ int exchange_trusted)
+{
+ struct TrackTransactionContext *tctx = cls;
+
+ tctx->fo = NULL;
+ tctx->eh = eh;
+ trace_coins (tctx);
+}
+
+
+/**
+ * Handle a timeout for the processing of the pay request.
+ *
+ * @param cls closure
+ */
+static void
+handle_track_transaction_timeout (void *cls)
+{
+ struct TrackTransactionContext *ttc = cls;
+
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Resuming /track/transaction with error after timeout\n");
+ ttc->timeout_task = NULL;
+
+ if (NULL != ttc->fo)
+ {
+ TMH_EXCHANGES_find_exchange_cancel (ttc->fo);
+ ttc->fo = NULL;
+ }
+ resume_track_transaction_with_response (ttc,
+ MHD_HTTP_SERVICE_UNAVAILABLE,
+ TMH_RESPONSE_make_internal_error ("exchange not reachable"));
+}
+
+
+/**
+ * Function called with information about a transaction.
+ *
+ * @param cls closure
+ * @param transaction_id of the contract
+ * @param h_contract hash of the contract
+ * @param h_wire hash of our wire details
+ * @param timestamp time of the confirmation
+ * @param refund refund deadline
+ * @param total_amount total amount we receive for the contract after fees
+ */
+static void
+transaction_cb (void *cls,
+ uint64_t transaction_id,
+ const struct GNUNET_HashCode *h_contract,
+ const struct GNUNET_HashCode *h_wire,
+ struct GNUNET_TIME_Absolute timestamp,
+ struct GNUNET_TIME_Absolute refund,
+ const struct TALER_Amount *total_amount)
+{
+ struct TrackTransactionContext *ttc = cls;
+
+ ttc->transaction_id = transaction_id;
+ ttc->h_contract = *h_contract;
+ ttc->h_wire = *h_wire;
+ ttc->timestamp = timestamp;
+ ttc->refund_deadline = refund;
+ ttc->total_amount = *total_amount;
+}
+
+
+/**
+ * Function called with information about a coin that was deposited.
+ *
+ * @param cls closure
+ * @param transaction_id of the contract
+ * @param coin_pub public key of the coin
+ * @param amount_with_fee amount the exchange will deposit for this coin
+ * @param deposit_fee fee the exchange will charge for this coin
+ * @param exchange_proof proof from exchange that coin was accepted
+ */
+static void
+coin_cb (void *cls,
+ uint64_t transaction_id,
+ const struct TALER_CoinSpendPublicKeyP *coin_pub,
+ const struct TALER_Amount *amount_with_fee,
+ const struct TALER_Amount *deposit_fee,
+ const json_t *exchange_proof)
+{
+ struct TrackTransactionContext *ttc = cls;
+ struct TrackCoinContext *tcc;
+
+ tcc = GNUNET_new (struct TrackCoinContext);
+ tcc->coin_pub = *coin_pub;
+ GNUNET_CONTAINER_DLL_insert (ttc->tcc_head,
+ ttc->tcc_tail,
+ tcc);
+}
+
+
+/**
+ * Handle a "/track/transaction" 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
+ */
+int
+MH_handler_track_transaction (struct TMH_RequestHandler *rh,
+ struct MHD_Connection *connection,
+ void **connection_cls,
+ const char *upload_data,
+ size_t *upload_data_size)
+{
+ struct TrackTransactionContext *tctx;
+ unsigned long long transaction_id;
+ const char *str;
+ int ret;
+
+ str = MHD_lookup_connection_value (connection,
+ MHD_GET_ARGUMENT_KIND,
+ "id");
+ if (NULL == str)
+ return TMH_RESPONSE_reply_external_error (connection,
+ "id argument missing");
+ if (1 !=
+ sscanf (str,
+ "%llu",
+ &transaction_id))
+ return TMH_RESPONSE_reply_external_error (connection,
+ "id argument must be a number");
+ if (NULL == *connection_cls)
+ {
+ tctx = GNUNET_new (struct TrackTransactionContext);
+ tctx->hc.cc = &track_transaction_cleanup;
+ tctx->connection = connection;
+ *connection_cls = tctx;
+ }
+ else
+ {
+ /* not first call, recover state */
+ tctx = *connection_cls;
+ }
+ if (0 != tctx->response_code)
+ {
+ /* We are *done* processing the request, just queue the response (!) */
+ if (UINT_MAX == tctx->response_code)
+ {
+ GNUNET_break (0);
+ return MHD_NO; /* hard error */
+ }
+ ret = MHD_queue_response (connection,
+ tctx->response_code,
+ tctx->response);
+ if (NULL != tctx->response)
+ {
+ MHD_destroy_response (tctx->response);
+ tctx->response = NULL;
+ }
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Queueing response (%u) for /track/transaction (%s).\n",
+ (unsigned int) tctx->response_code,
+ ret ? "OK" : "FAILED");
+ return ret;
+ }
+
+ ret = db->find_transaction_by_id (db->cls,
+ transaction_id,
+ &transaction_cb,
+ tctx);
+ if (GNUNET_NO == ret)
+ {
+ /* FIXME: generate proper 404 */
+ GNUNET_break (0);
+ free_tctx (tctx);
+ return TMH_RESPONSE_reply_external_error (connection,
+ "Unknown transaction ID");
+ }
+ if ( (GNUNET_SYSERR == ret) ||
+ (tctx->transaction_id != (uint64_t) transaction_id) )
+ {
+ GNUNET_break (0);
+ free_tctx (tctx);
+ return TMH_RESPONSE_reply_internal_error (connection,
+ "Database error");
+ }
+ ret = db->find_payments_by_id (db->cls,
+ transaction_id,
+ &coin_cb,
+ tctx);
+ if (GNUNET_SYSERR == ret)
+ {
+ GNUNET_break (0);
+ return TMH_RESPONSE_reply_internal_error (connection,
+ "Database error");
+ }
+ if (GNUNET_NO == ret)
+ {
+ /* FIXME: generate proper 404 */
+ GNUNET_break (0);
+ free_tctx (tctx);
+ return TMH_RESPONSE_reply_external_error (connection,
+ "No deposits found for transaction ID");
+ }
+ *connection_cls = tctx;
+
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Suspending /track/transaction handling while working with the exchange\n");
+ MHD_suspend_connection (connection);
+ tctx->fo = TMH_EXCHANGES_find_exchange (NULL, /* FIXME: tctx->chosen_exchange */
+ &process_track_transaction_with_exchange,
+ tctx);
+
+ tctx->timeout_task = GNUNET_SCHEDULER_add_delayed (TRACK_TIMEOUT,
+ &handle_track_transaction_timeout,
+ tctx);
+ return MHD_NO;
+}
+
+
+/* end of taler-merchant-httpd_contract.c */
diff --git a/src/backend/taler-merchant-httpd_track-transaction.h b/src/backend/taler-merchant-httpd_track-transaction.h
@@ -0,0 +1,45 @@
+/*
+ This file is part of TALER
+ (C) 2014, 2015 GNUnet e.V.
+
+ 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, If not, see <http://www.gnu.org/licenses/>
+*/
+/**
+ * @file backend/taler-merchant-httpd_track-transaction.h
+ * @brief headers for /track/transaction handler
+ * @author Christian Grothoff
+ * @author Marcello Stanisci
+ */
+#ifndef TALER_MERCHANT_HTTPD_TRACK_TRANSACTION_H
+#define TALER_MERCHANT_HTTPD_TRACK_TRANSACTION_H
+#include <microhttpd.h>
+#include "taler-merchant-httpd.h"
+
+/**
+ * Handle a "/track/transaction" 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
+ */
+int
+MH_handler_track_transaction (struct TMH_RequestHandler *rh,
+ struct MHD_Connection *connection,
+ void **connection_cls,
+ const char *upload_data,
+ size_t *upload_data_size);
+
+
+#endif
diff --git a/src/backend/taler-merchant-httpd_track.c b/src/backend/taler-merchant-httpd_track.c
@@ -1,771 +0,0 @@
-/*
- This file is part of TALER
- (C) 2014, 2015, 2016 INRIA
-
- TALER is free software; you can redistribute it and/or modify it under the
- terms of the GNU Affero 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, If not, see <http://www.gnu.org/licenses/>
-*/
-/**
- * @file backend/taler-merchant-httpd_track.c
- * @brief implement API for tracking deposits and wire transfers
- * @author Marcello Stanisci
- * @author Christian Grothoff
- */
-#include "platform.h"
-#include <jansson.h>
-#include <taler/taler_signatures.h>
-#include <taler/taler_json_lib.h>
-#include "taler-merchant-httpd.h"
-#include "taler-merchant-httpd_mhd.h"
-#include "taler-merchant-httpd_parsing.h"
-#include "taler-merchant-httpd_auditors.h"
-#include "taler-merchant-httpd_exchanges.h"
-#include "taler-merchant-httpd_responses.h"
-#include "taler-merchant-httpd_track.h"
-
-
-/**
- * How long to wait before giving up processing with the exchange?
- */
-#define TRACK_TIMEOUT (GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 30))
-
-extern char *TMH_merchant_currency_string;
-
-
-/**
- * Context used for handing /track/deposit requests.
- */
-struct DepositTrackContext
-{
-
- /**
- * This MUST be first!
- */
- struct TM_HandlerContext hc;
-
- /**
- * Handle to the exchange.
- */
- struct TALER_EXCHANGE_Handle *eh;
-
- /**
- * Handle for the /wire/deposits request.
- */
- struct TALER_EXCHANGE_WireDepositsHandle *wdh;
-
- /**
- *
- */
- struct TALER_WireDepositDetails *details;
-
- /**
- * Argument for the /wire/deposits request.
- */
- struct TALER_WireTransferIdentifierRawP wtid;
-
- /**
- *
- */
- unsigned int details_length;
-
- struct MHD_Connection *connection;
-
- unsigned int response_code;
-
- json_t *json;
-
- const char *error;
-
-};
-
-
-/**
- * Function called with detailed wire transfer data, including all
- * of the coin transactions that were combined into the wire transfer.
- *
- * @param cls closure
- * @param http_status HTTP status code we got, 0 on exchange protocol violation
- * @param json original json reply (may include signatures, those have then been
- * validated already)
- * @param wtid extracted wire transfer identifier, or NULL if the exchange could
- * not provide any (set only if @a http_status is #MHD_HTTP_OK)
- * @param total_amount total amount of the wire transfer, or NULL if the exchange could
- * not provide any @a wtid (set only if @a http_status is #MHD_HTTP_OK)
- * @param details_length length of the @a details array
- * @param details array with details about the combined transactions
- */
-static void
-wire_deposit_cb (void *cls,
- unsigned int http_status,
- const json_t *json,
- const struct GNUNET_HashCode *h_wire,
- const struct TALER_Amount *total_amount,
- unsigned int details_length,
- const struct TALER_WireDepositDetails *details)
-{
- struct DepositTrackContext *rctx = cls;
- // unsigned int i;
-
- rctx->wdh = NULL;
- if (NULL == total_amount)
- {
- rctx->error = "failed to obtain /wire/deposit response from exchange";
- rctx->json = json_incref ((json_t *) json);
- rctx->response_code = http_status;
- MHD_resume_connection (rctx->connection);
- return;
- }
- rctx->details_length = details_length;
- rctx->details = GNUNET_new_array (details_length,
- struct TALER_WireDepositDetails);
- memcpy (rctx->details,
- details,
- details_length * sizeof (struct TALER_WireDepositDetails));
- GNUNET_break (0);
- /* FIXME: now check that these details match what we have in
- our database... */
-
-
-}
-
-
-/**
- * Function called with information about who is auditing
- * a particular exchange and what key the exchange is using.
- *
- * @param cls closure
- * @param keys information about the various keys used
- * by the exchange, NULL if /keys failed
- */
-static void
-cert_cb (void *cls,
- const struct TALER_EXCHANGE_Keys *keys)
-{
- struct DepositTrackContext *rctx = cls;
-
- if (NULL == keys)
- {
- rctx->error = "failed to obtain /keys from exchange";
- rctx->response_code = MHD_HTTP_SERVICE_UNAVAILABLE;
- MHD_resume_connection (rctx->connection);
- return;
- }
- rctx->wdh = TALER_EXCHANGE_wire_deposits (rctx->eh,
- &rctx->wtid,
- &wire_deposit_cb,
- rctx);
-}
-
-
-/**
- * Manages a /track/wtid call, thus it calls the /track/deposit
- * offered by the exchange in order to return the set of deposits
- * (of coins) associated with a given wire transfer.
- *
- * @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
- */
-int
-MH_handler_track_deposit (struct TMH_RequestHandler *rh,
- struct MHD_Connection *connection,
- void **connection_cls,
- const char *upload_data,
- size_t *upload_data_size)
-{
- struct DepositTrackContext *rctx;
- const char *str;
- const char *uri;
-
- rctx = *connection_cls;
- if (NULL != rctx)
- {
- // ...
- }
- uri = MHD_lookup_connection_value (connection,
- MHD_GET_ARGUMENT_KIND,
- "exchange");
- if (NULL == uri)
- return TMH_RESPONSE_reply_external_error (connection,
- "exchange argument missing");
- str = MHD_lookup_connection_value (connection,
- MHD_GET_ARGUMENT_KIND,
- "wtid");
- if (NULL == str)
- return TMH_RESPONSE_reply_external_error (connection,
- "wtid argument missing");
- if (GNUNET_OK !=
- GNUNET_STRINGS_string_to_data (str,
- strlen (str),
- &rctx->wtid,
- sizeof (rctx->wtid)))
- return TMH_RESPONSE_reply_external_error (connection,
- "wtid argument malformed");
- rctx->eh = TALER_EXCHANGE_connect (NULL /* FIXME */,
- uri,
- &cert_cb,
- rctx,
- TALER_EXCHANGE_OPTION_END);
-
- GNUNET_break (0);
- return MHD_NO;
-}
-
-
-/**
- * Information we keep for each coin in a /track/transaction operation.
- */
-struct TrackCoinContext
-{
- /**
- * Kept in a DLL.
- */
- struct TrackCoinContext *next;
-
- /**
- * Kept in a DLL.
- */
- struct TrackCoinContext *prev;
-
- /**
- * Public key of the coin.
- */
- struct TALER_CoinSpendPublicKeyP coin_pub;
-
- /**
- * Handle for the request to resolve the WTID for this coin.
- */
- struct TALER_EXCHANGE_DepositWtidHandle *dwh;
-
-};
-
-
-/**
- * Context for a /track/transaction operation.
- */
-struct TrackTransactionContext
-{
-
- /**
- * This field MUST be first.
- * FIXME: Explain why!
- */
- struct TM_HandlerContext hc;
-
- /**
- * HTTP request we are handling.
- */
- struct MHD_Connection *connection;
-
- /**
- * Kept in a DLL.
- */
- struct TrackCoinContext *tcc_head;
-
- /**
- * Kept in a DLL.
- */
- struct TrackCoinContext *tcc_tail;
-
- /**
- * Transaction this request is about.
- */
- uint64_t transaction_id;
-
- /**
- * Hash of wire details for the transaction.
- */
- struct GNUNET_HashCode h_wire;
-
- /**
- * Timestamp of the transaction.
- */
- struct GNUNET_TIME_Absolute timestamp;
-
- /**
- * Refund deadline for the transaction.
- */
- struct GNUNET_TIME_Absolute refund_deadline;
-
- /**
- * Total value of the transaction.
- */
- struct TALER_Amount total_amount;
-
- /**
- * Hash of the contract.
- */
- struct GNUNET_HashCode h_contract;
-
- /**
- * Task run on timeout.
- */
- struct GNUNET_SCHEDULER_Task *timeout_task;
-
- /**
- * Handle for operation to lookup /keys (and auditors) from
- * the exchange used for this transaction; NULL if no operation is
- * pending.
- */
- struct TMH_EXCHANGES_FindOperation *fo;
-
- /**
- * Handle to our exchange, once we found it.
- */
- struct TALER_EXCHANGE_Handle *eh;
-
- /**
- * Handle we use to resolve transactions for a given WTID.
- */
- struct TALER_EXCHANGE_WireDepositsHandle *wdh;
-
- /**
- * Response to return upon resume.
- */
- struct MHD_Response *response;
-
- /**
- * Response code to return upon resume.
- */
- unsigned int response_code;
-
-
-};
-
-
-/**
- * Free the @a tctx.
- *
- * @param tctx data to free
- */
-static void
-free_tctx (struct TrackTransactionContext *tctx)
-{
- struct TrackCoinContext *tcc;
-
- while (NULL != (tcc = tctx->tcc_head))
- {
- GNUNET_CONTAINER_DLL_remove (tctx->tcc_head,
- tctx->tcc_tail,
- tcc);
- if (NULL != tcc->dwh)
- {
- TALER_EXCHANGE_deposit_wtid_cancel (tcc->dwh);
- tcc->dwh = NULL;
- }
- GNUNET_free (tcc);
- }
- if (NULL != tctx->fo)
- {
- TMH_EXCHANGES_find_exchange_cancel (tctx->fo);
- tctx->fo = NULL;
- }
- if (NULL != tctx->timeout_task)
- {
- GNUNET_SCHEDULER_cancel (tctx->timeout_task);
- tctx->timeout_task = NULL;
- }
- GNUNET_free (tctx);
-}
-
-
-/**
- * Custom cleanup routine for a `struct TrackTransactionContext`.
- *
- * @param hc the `struct PayContext` to clean up.
- */
-static void
-track_transaction_cleanup (struct TM_HandlerContext *hc)
-{
- struct TrackTransactionContext *tctx = (struct TrackTransactionContext *) hc;
-
- free_tctx (tctx);
-}
-
-
-/**
- * Resume the given pay context and send the given response.
- * Stores the response in the @a pc and signals MHD to resume
- * the connection. Also ensures MHD runs immediately.
- *
- * @param pc payment context
- * @param response_code response code to use
- * @param response response data to send back
- */
-static void
-resume_track_transaction_with_response (struct TrackTransactionContext *ttc,
- unsigned int response_code,
- struct MHD_Response *response)
-{
- ttc->response_code = response_code;
- ttc->response = response;
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Resuming /track/transaction handling as exchange interaction is done (%u)\n",
- response_code);
- if (NULL != ttc->timeout_task)
- {
- GNUNET_SCHEDULER_cancel (ttc->timeout_task);
- ttc->timeout_task = NULL;
- }
- MHD_resume_connection (ttc->connection);
- TMH_trigger_daemon (); /* we resumed, kick MHD */
-}
-
-
-/**
- * This function is called to trace the wire transfers for
- * all of the coins of the transaction of the @a tctx. Once
- * we have traced all coins, we build the response.
- *
- * @param tctx track context with established connection to exchange
- */
-static void
-trace_coins (struct TrackTransactionContext *tctx);
-
-
-/**
- * Function called with detailed wire transfer data, including all
- * of the coin transactions that were combined into the wire transfer.
- *
- * We now store this information. Then we check if we still have
- * any coins of the original wire transfer not taken care of.
- *
- * @param cls closure
- * @param http_status HTTP status code we got, 0 on exchange protocol violation
- * @param json original json reply (may include signatures, those have then been
- * validated already)
- * @param wtid extracted wire transfer identifier, or NULL if the exchange could
- * not provide any (set only if @a http_status is #MHD_HTTP_OK)
- * @param total_amount total amount of the wire transfer, or NULL if the exchange could
- * not provide any @a wtid (set only if @a http_status is #MHD_HTTP_OK)
- * @param details_length length of the @a details array
- * @param details array with details about the combined transactions
- */
-static void
-wire_deposits_cb (void *cls,
- unsigned int http_status,
- const json_t *json,
- const struct GNUNET_HashCode *h_wire,
- const struct TALER_Amount *total_amount,
- unsigned int details_length,
- const struct TALER_WireDepositDetails *details)
-{
- struct TrackTransactionContext *tctx = cls;
-
- /* FIXME: store data in database */
- /* FIXME: check which coins of 'tctx' are now covered */
- GNUNET_break (0);
- trace_coins (tctx);
-}
-
-
-
-/**
- * Function called with detailed wire transfer data.
- * We were trying to find out in which wire transfer one of the
- * coins was involved in. Now we know. What we do now is first
- * obtain the inverse: all other coins of that wire transfer,
- * which is what we prefer to store.
- *
- * @param cls closure
- * @param http_status HTTP status code we got, 0 on exchange protocol violation
- * @param json original json reply (may include signatures, those have then been
- * validated already)
- * @param wtid wire transfer identifier used by the exchange, NULL if exchange did not
- * yet execute the transaction
- * @param execution_time actual or planned execution time for the wire transfer
- * @param coin_contribution contribution to the @a total_amount of the deposited coin (may be NULL)
- */
-static void
-wtid_cb (void *cls,
- unsigned int http_status,
- const json_t *json,
- const struct TALER_WireTransferIdentifierRawP *wtid,
- struct GNUNET_TIME_Absolute execution_time,
- const struct TALER_Amount *coin_contribution)
-{
- struct TrackTransactionContext *tctx = cls;
-
- tctx->wdh = TALER_EXCHANGE_wire_deposits (tctx->eh,
- wtid,
- &wire_deposits_cb,
- tctx);
-}
-
-
-/**
- * This function is called to trace the wire transfers for
- * all of the coins of the transaction of the @a tctx. Once
- * we have traced all coins, we build the response.
- *
- * @param tctx track context with established connection to exchange
- */
-static void
-trace_coins (struct TrackTransactionContext *tctx)
-{
- GNUNET_assert (NULL != tctx->eh);
-
- GNUNET_break (0);
-#if ALL_COINS_DONE
- if (0)
- {
- generate_response ();
- resume_track_transaction_with_response (tctx,
- MHD_HTTP_OK,
- response);
- return;
- }
-#endif
-#if FOR_NEXT_COIN_IN_ORDER_ONE_AT_A_TIME_UNTIL_ALL_ARE_DONE
- tctx->dwh = TALER_EXCHANGE_deposit_wtid (eh,
- merchant_priv,
- &tctx->h_wire,
- &tctx->h_contract,
- &coin_pub,
- tctx->transaction_id,
- &wtid_cb,
- tctx);
-#endif
-}
-
-
-/**
- * Function called with the result of our exchange lookup.
- *
- * @param cls the `struct TrackTransactionContext`
- * @param eh NULL if exchange was not found to be acceptable
- * @param exchange_trusted #GNUNET_YES if this exchange is trusted by config
- */
-static void
-process_track_transaction_with_exchange (void *cls,
- struct TALER_EXCHANGE_Handle *eh,
- int exchange_trusted)
-{
- struct TrackTransactionContext *tctx = cls;
-
- tctx->fo = NULL;
- tctx->eh = eh;
- trace_coins (tctx);
-}
-
-
-/**
- * Handle a timeout for the processing of the pay request.
- *
- * @param cls closure
- */
-static void
-handle_track_transaction_timeout (void *cls)
-{
- struct TrackTransactionContext *ttc = cls;
-
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Resuming /track/transaction with error after timeout\n");
- ttc->timeout_task = NULL;
-
- if (NULL != ttc->fo)
- {
- TMH_EXCHANGES_find_exchange_cancel (ttc->fo);
- ttc->fo = NULL;
- }
- resume_track_transaction_with_response (ttc,
- MHD_HTTP_SERVICE_UNAVAILABLE,
- TMH_RESPONSE_make_internal_error ("exchange not reachable"));
-}
-
-
-/**
- * Function called with information about a transaction.
- *
- * @param cls closure
- * @param transaction_id of the contract
- * @param h_contract hash of the contract
- * @param h_wire hash of our wire details
- * @param timestamp time of the confirmation
- * @param refund refund deadline
- * @param total_amount total amount we receive for the contract after fees
- */
-static void
-transaction_cb (void *cls,
- uint64_t transaction_id,
- const struct GNUNET_HashCode *h_contract,
- const struct GNUNET_HashCode *h_wire,
- struct GNUNET_TIME_Absolute timestamp,
- struct GNUNET_TIME_Absolute refund,
- const struct TALER_Amount *total_amount)
-{
- struct TrackTransactionContext *ttc = cls;
-
- ttc->transaction_id = transaction_id;
- ttc->h_contract = *h_contract;
- ttc->h_wire = *h_wire;
- ttc->timestamp = timestamp;
- ttc->refund_deadline = refund;
- ttc->total_amount = *total_amount;
-}
-
-
-/**
- * Function called with information about a coin that was deposited.
- *
- * @param cls closure
- * @param transaction_id of the contract
- * @param coin_pub public key of the coin
- * @param amount_with_fee amount the exchange will deposit for this coin
- * @param deposit_fee fee the exchange will charge for this coin
- * @param exchange_proof proof from exchange that coin was accepted
- */
-static void
-coin_cb (void *cls,
- uint64_t transaction_id,
- const struct TALER_CoinSpendPublicKeyP *coin_pub,
- const struct TALER_Amount *amount_with_fee,
- const struct TALER_Amount *deposit_fee,
- const json_t *exchange_proof)
-{
- struct TrackTransactionContext *ttc = cls;
- struct TrackCoinContext *tcc;
-
- tcc = GNUNET_new (struct TrackCoinContext);
- tcc->coin_pub = *coin_pub;
- GNUNET_CONTAINER_DLL_insert (ttc->tcc_head,
- ttc->tcc_tail,
- tcc);
-}
-
-
-/**
- * Handle a "/track/transaction" 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
- */
-int
-MH_handler_track_transaction (struct TMH_RequestHandler *rh,
- struct MHD_Connection *connection,
- void **connection_cls,
- const char *upload_data,
- size_t *upload_data_size)
-{
- struct TrackTransactionContext *tctx;
- unsigned long long transaction_id;
- const char *str;
- int ret;
-
- str = MHD_lookup_connection_value (connection,
- MHD_GET_ARGUMENT_KIND,
- "id");
- if (NULL == str)
- return TMH_RESPONSE_reply_external_error (connection,
- "id argument missing");
- if (1 !=
- sscanf (str,
- "%llu",
- &transaction_id))
- return TMH_RESPONSE_reply_external_error (connection,
- "id argument must be a number");
- if (NULL == *connection_cls)
- {
- tctx = GNUNET_new (struct TrackTransactionContext);
- tctx->hc.cc = &track_transaction_cleanup;
- tctx->connection = connection;
- *connection_cls = tctx;
- }
- else
- {
- /* not first call, recover state */
- tctx = *connection_cls;
- }
- if (0 != tctx->response_code)
- {
- /* We are *done* processing the request, just queue the response (!) */
- if (UINT_MAX == tctx->response_code)
- {
- GNUNET_break (0);
- return MHD_NO; /* hard error */
- }
- ret = MHD_queue_response (connection,
- tctx->response_code,
- tctx->response);
- if (NULL != tctx->response)
- {
- MHD_destroy_response (tctx->response);
- tctx->response = NULL;
- }
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Queueing response (%u) for /track/transaction (%s).\n",
- (unsigned int) tctx->response_code,
- ret ? "OK" : "FAILED");
- return ret;
- }
-
- ret = db->find_transaction_by_id (db->cls,
- transaction_id,
- &transaction_cb,
- tctx);
- if (GNUNET_NO == ret)
- {
- /* FIXME: generate proper 404 */
- GNUNET_break (0);
- free_tctx (tctx);
- return TMH_RESPONSE_reply_external_error (connection,
- "Unknown transaction ID");
- }
- if ( (GNUNET_SYSERR == ret) ||
- (tctx->transaction_id != (uint64_t) transaction_id) )
- {
- GNUNET_break (0);
- free_tctx (tctx);
- return TMH_RESPONSE_reply_internal_error (connection,
- "Database error");
- }
- ret = db->find_payments_by_id (db->cls,
- transaction_id,
- &coin_cb,
- tctx);
- if (GNUNET_SYSERR == ret)
- {
- GNUNET_break (0);
- return TMH_RESPONSE_reply_internal_error (connection,
- "Database error");
- }
- if (GNUNET_NO == ret)
- {
- /* FIXME: generate proper 404 */
- GNUNET_break (0);
- free_tctx (tctx);
- return TMH_RESPONSE_reply_external_error (connection,
- "No deposits found for transaction ID");
- }
- *connection_cls = tctx;
-
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Suspending /track/transaction handling while working with the exchange\n");
- MHD_suspend_connection (connection);
- tctx->fo = TMH_EXCHANGES_find_exchange (NULL, /* FIXME: tctx->chosen_exchange */
- &process_track_transaction_with_exchange,
- tctx);
-
- tctx->timeout_task = GNUNET_SCHEDULER_add_delayed (TRACK_TIMEOUT,
- &handle_track_transaction_timeout,
- tctx);
- return MHD_NO;
-}
-
-
-/* end of taler-merchant-httpd_contract.c */
diff --git a/src/backend/taler-merchant-httpd_track.h b/src/backend/taler-merchant-httpd_track.h
@@ -1,63 +0,0 @@
-/*
- This file is part of TALER
- (C) 2014, 2015 GNUnet e.V.
-
- 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, If not, see <http://www.gnu.org/licenses/>
-*/
-/**
- * @file backend/taler-merchant-httpd_track.h
- * @brief headers for /track/{deposit,wtid} handler
- * @author Marcello Stanisci
- */
-#ifndef TALER_MERCHANT_HTTPD_TRACK_H
-#define TALER_MERCHANT_HTTPD_TRACK_H
-#include <microhttpd.h>
-#include "taler-merchant-httpd.h"
-
-/**
- * Manages a /track/deposit call, thus it calls the /wire/deposit
- * offered by the exchange in order to return the set of deposits
- * (of coins) associated with a given wire transfer
- *
- * @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
- */
-int
-MH_handler_track_deposit (struct TMH_RequestHandler *rh,
- struct MHD_Connection *connection,
- void **connection_cls,
- const char *upload_data,
- size_t *upload_data_size);
-
-/**
- * Handle a "/track/transaction" 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
- */
-int
-MH_handler_track_transaction (struct TMH_RequestHandler *rh,
- struct MHD_Connection *connection,
- void **connection_cls,
- const char *upload_data,
- size_t *upload_data_size);
-
-
-#endif
