fix cyclic dependency by combining exchange-lib and auditor-lib directories

1 files changed, 0 insertions, 576 deletions

diff --git a/src/exchange-lib/testing_api_cmd_deposit.c b/src/exchange-lib/testing_api_cmd_deposit.c
deleted file mode 100644
index 6fa2310d3..000000000
--- a/src/exchange-lib/testing_api_cmd_deposit.c
+++ /dev/null
@@ -1,576 +0,0 @@
-/*
-  This file is part of TALER
-  Copyright (C) 2018 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/>
-*/
-
-/**
- * @file exchange-lib/testing_api_cmd_deposit.c
- * @brief command for testing /deposit.
- * @author Marcello Stanisci
- */
-
-#include "platform.h"
-#include "taler_json_lib.h"
-#include <gnunet/gnunet_curl_lib.h>
-#include "exchange_api_handle.h"
-#include "taler_testing_lib.h"
-#include "taler_signatures.h"
-#include "backoff.h"
-
-
-/**
- * State for a "deposit" CMD.
- */
-struct DepositState
-{
-
-  /**
-   * Amount to deposit.
-   */
-  const char *amount;
-
-  /**
-   * Reference to any command that is able to provide a coin.
-   */
-  const char *coin_reference;
-
-  /**
-   * If @e coin_reference refers to an operation that generated
-   * an array of coins, this value determines which coin to pick.
-   */
-  unsigned int coin_index;
-
-  /**
-   * Wire details of who is depositing -- this would be merchant
-   * wire details in a normal scenario.
-   */
-  json_t *wire_details;
-
-  /**
-   * JSON string describing what a proposal is about.
-   */
-  json_t *contract_terms;
-
-  /**
-   * Relative time (to add to 'now') to compute the refund
-   * deadline.  Zero for no refunds.
-   */
-  struct GNUNET_TIME_Relative refund_deadline;
-
-  /**
-   * Set (by the interpreter) to a fresh private key.  This
-   * key will be used to sign the deposit request.
-   */
-  struct TALER_MerchantPrivateKeyP merchant_priv;
-
-  /**
-   * Deposit handle while operation is running.
-   */
-  struct TALER_EXCHANGE_DepositHandle *dh;
-
-  /**
-   * Interpreter state.
-   */
-  struct TALER_TESTING_Interpreter *is;
-
-  /**
-   * Task scheduled to try later.
-   */
-  struct GNUNET_SCHEDULER_Task *retry_task;
-
-  /**
-   * How long do we wait until we retry?
-   */
-  struct GNUNET_TIME_Relative backoff;
-
-  /**
-   * Expected HTTP response code.
-   */
-  unsigned int expected_response_code;
-
-  /**
-   * Should we retry on (transient) failures?
-   */
-  int do_retry;
-
-  /**
-   * Set to #GNUNET_YES if the /deposit succeeded
-   * and we now can provide the resulting traits.
-   */
-  int traits_ready;
-
-  /**
-   * Signing key used by the exchange to sign the
-   * deposit confirmation.
-   */
-  struct TALER_ExchangePublicKeyP exchange_pub;
-
-  /**
-   * Signature from the exchange on the
-   * deposit confirmation.
-   */
-  struct TALER_ExchangeSignatureP exchange_sig;
-};
-
-
-/**
- * Run the command.
- *
- * @param cls closure.
- * @param cmd the command to execute.
- * @param is the interpreter state.
- */
-static void
-deposit_run (void *cls,
-             const struct TALER_TESTING_Command *cmd,
-             struct TALER_TESTING_Interpreter *is);
-
-
-/**
- * Task scheduled to re-try #deposit_run.
- *
- * @param cls a `struct DepositState`
- */
-static void
-do_retry (void *cls)
-{
-  struct DepositState *ds = cls;
-
-  ds->retry_task = NULL;
-  deposit_run (ds,
-               NULL,
-               ds->is);
-}
-
-
-/**
- * Callback to analyze the /deposit response, just used to
- * check if the response code is acceptable.
- *
- * @param cls closure.
- * @param http_status HTTP response code.
- * @param ec taler-specific error code.
- * @param exchange_sig signature provided by the exchange
- *        (NULL on errors)
- * @param exchange_pub public key of the exchange,
- *        used for signing the response.
- * @param obj raw response from the exchange.
- */
-static void
-deposit_cb (void *cls,
-            unsigned int http_status,
-            enum TALER_ErrorCode ec,
-            const struct TALER_ExchangeSignatureP *exchange_sig,
-            const struct TALER_ExchangePublicKeyP *exchange_pub,
-            const json_t *obj)
-{
-  struct DepositState *ds = cls;
-
-  ds->dh = NULL;
-  if (ds->expected_response_code != http_status)
-  {
-    if (GNUNET_YES == ds->do_retry)
-    {
-      if ( (0 == http_status) ||
-           (TALER_EC_DB_COMMIT_FAILED_ON_RETRY == ec) ||
-	   (MHD_HTTP_INTERNAL_SERVER_ERROR == http_status) )
-      {
-        GNUNET_log (GNUNET_ERROR_TYPE_INFO,
-                    "Retrying deposit failed with %u/%d\n",
-                    http_status,
-                    (int) ec);
-	/* on DB conflicts, do not use backoff */
-	if (TALER_EC_DB_COMMIT_FAILED_ON_RETRY == ec)
-	  ds->backoff = GNUNET_TIME_UNIT_ZERO;
-	else
-	  ds->backoff = EXCHANGE_LIB_BACKOFF (ds->backoff);
-	ds->retry_task
-	  = GNUNET_SCHEDULER_add_delayed (ds->backoff,
-					  &do_retry,
-					  ds);
-        return;
-      }
-    }
-    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
-                "Unexpected response code %u to command %s in %s:%u\n",
-                http_status,
-                ds->is->commands[ds->is->ip].label,
-                __FILE__,
-                __LINE__);
-    json_dumpf (obj, stderr, 0);
-    TALER_TESTING_interpreter_fail (ds->is);
-    return;
-  }
-  if (MHD_HTTP_OK == http_status)
-  {
-    ds->traits_ready = GNUNET_YES;
-    ds->exchange_pub = *exchange_pub;
-    ds->exchange_sig = *exchange_sig;
-  }
-  TALER_TESTING_interpreter_next (ds->is);
-}
-
-
-/**
- * Run the command.
- *
- * @param cls closure.
- * @param cmd the command to execute.
- * @param is the interpreter state.
- */
-static void
-deposit_run (void *cls,
-             const struct TALER_TESTING_Command *cmd,
-             struct TALER_TESTING_Interpreter *is)
-{
-  struct DepositState *ds = cls;
-  const struct TALER_TESTING_Command *coin_cmd;
-  struct TALER_TESTING_Command *this_cmd;
-  const struct TALER_CoinSpendPrivateKeyP *coin_priv;
-  struct TALER_CoinSpendPublicKeyP coin_pub;
-  const struct TALER_EXCHANGE_DenomPublicKey *denom_pub;
-  const struct TALER_DenominationSignature *denom_pub_sig;
-  struct TALER_CoinSpendSignatureP coin_sig;
-  struct GNUNET_TIME_Absolute refund_deadline;
-  struct GNUNET_TIME_Absolute wire_deadline;
-  struct GNUNET_TIME_Absolute timestamp;
-  struct GNUNET_CRYPTO_EddsaPrivateKey *merchant_priv;
-  struct TALER_MerchantPublicKeyP merchant_pub;
-  struct GNUNET_HashCode h_contract_terms;
-  struct TALER_Amount amount;
-
-  ds->is = is;
-  this_cmd = &is->commands[is->ip];
-
-  GNUNET_assert (ds->coin_reference);
-  coin_cmd = TALER_TESTING_interpreter_lookup_command
-    (is,
-     ds->coin_reference);
-  if (NULL == coin_cmd)
-  {
-    GNUNET_break (0);
-    TALER_TESTING_interpreter_fail (is);
-    return;
-  }
-
-  /* Fixme: do prefer "interpreter fail" over assertions,
-   * as the former takes care of shutting down processes  too */
-  GNUNET_assert (NULL != coin_cmd);
-
-  GNUNET_assert (GNUNET_OK
-    == TALER_TESTING_get_trait_coin_priv (coin_cmd,
-                                          ds->coin_index,
-                                          &coin_priv));
-
-  GNUNET_assert (GNUNET_OK
-    == TALER_TESTING_get_trait_denom_pub (coin_cmd,
-                                          ds->coin_index,
-                                          &denom_pub));
-
-  GNUNET_assert (GNUNET_OK
-    == TALER_TESTING_get_trait_denom_sig (coin_cmd,
-                                          ds->coin_index,
-                                          &denom_pub_sig));
-  if (GNUNET_OK !=
-      TALER_string_to_amount (ds->amount,
-                              &amount))
-  {
-    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
-                "Failed to parse amount `%s' at '%u/%s'\n",
-                 ds->amount, is->ip, this_cmd->label);
-    TALER_TESTING_interpreter_fail (is);
-    return;
-  }
-
-  GNUNET_assert (GNUNET_OK ==
-                 TALER_JSON_hash (ds->contract_terms,
-                                  &h_contract_terms));
-
-  GNUNET_CRYPTO_eddsa_key_get_public (&coin_priv->eddsa_priv,
-                                      &coin_pub.eddsa_pub);
-
-  merchant_priv = GNUNET_CRYPTO_eddsa_key_create ();
-  ds->merchant_priv.eddsa_priv = *merchant_priv;
-  GNUNET_free (merchant_priv);
-
-  if (0 != ds->refund_deadline.rel_value_us)
-  {
-    refund_deadline = GNUNET_TIME_relative_to_absolute
-      (ds->refund_deadline);
-    wire_deadline = GNUNET_TIME_relative_to_absolute
-    (GNUNET_TIME_relative_multiply
-      (ds->refund_deadline, 2));
-  }
-  else
-  {
-    refund_deadline = GNUNET_TIME_UNIT_ZERO_ABS;
-    wire_deadline = GNUNET_TIME_relative_to_absolute
-      (GNUNET_TIME_UNIT_ZERO);
-  }
-  GNUNET_CRYPTO_eddsa_key_get_public
-    (&ds->merchant_priv.eddsa_priv,
-     &merchant_pub.eddsa_pub);
-
-  timestamp = GNUNET_TIME_absolute_get ();
-  GNUNET_TIME_round_abs (&timestamp);
-  GNUNET_TIME_round_abs (&refund_deadline);
-  GNUNET_TIME_round_abs (&wire_deadline);
-
-  {
-    struct TALER_DepositRequestPS dr;
-
-    memset (&dr, 0, sizeof (dr));
-    dr.purpose.size = htonl
-      (sizeof (struct TALER_DepositRequestPS));
-    dr.purpose.purpose = htonl
-      (TALER_SIGNATURE_WALLET_COIN_DEPOSIT);
-    dr.h_contract_terms = h_contract_terms;
-    GNUNET_assert
-      (GNUNET_OK ==
-       TALER_JSON_merchant_wire_signature_hash (ds->wire_details,
-                                                &dr.h_wire));
-    dr.timestamp = GNUNET_TIME_absolute_hton (timestamp);
-    dr.refund_deadline = GNUNET_TIME_absolute_hton
-      (refund_deadline);
-    TALER_amount_hton (&dr.amount_with_fee, &amount);
-    TALER_amount_hton
-      (&dr.deposit_fee, &denom_pub->fee_deposit);
-    dr.merchant = merchant_pub;
-    dr.coin_pub = coin_pub;
-    GNUNET_assert (GNUNET_OK == GNUNET_CRYPTO_eddsa_sign
-      (&coin_priv->eddsa_priv,
-       &dr.purpose,
-       &coin_sig.eddsa_signature));
-  }
-  ds->dh = TALER_EXCHANGE_deposit
-    (is->exchange,
-     &amount,
-     wire_deadline,
-     ds->wire_details,
-     &h_contract_terms,
-     &coin_pub,
-     denom_pub_sig,
-     &denom_pub->key,
-     timestamp,
-     &merchant_pub,
-     refund_deadline,
-     &coin_sig,
-     &deposit_cb,
-     ds);
-
-  if (NULL == ds->dh)
-  {
-    GNUNET_break (0);
-    TALER_TESTING_interpreter_fail (is);
-    return;
-  }
-  return;
-}
-
-
-/**
- * Free the state of a "deposit" CMD, and possibly cancel a
- * pending operation thereof.
- *
- * @param cls closure, typically a #struct WireState.
- * @param cmd the command which is being cleaned up.
- */
-static void
-deposit_cleanup (void *cls,
-                 const struct TALER_TESTING_Command *cmd)
-{
-  struct DepositState *ds = cls;
-
-  if (NULL != ds->dh)
-  {
-    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
-                "Command %u (%s) did not complete\n",
-                ds->is->ip,
-                cmd->label);
-    TALER_EXCHANGE_deposit_cancel (ds->dh);
-    ds->dh = NULL;
-  }
-  if (NULL != ds->retry_task)
-  {
-    GNUNET_SCHEDULER_cancel (ds->retry_task);
-    ds->retry_task = NULL;
-  }
-  json_decref (ds->wire_details);
-  json_decref (ds->contract_terms);
-  GNUNET_free (ds);
-}
-
-
-/**
- * Offer internal data from a "deposit" CMD, to other commands.
- *
- * @param cls closure.
- * @param ret[out] result.
- * @param trait name of the trait.
- * @param index index number of the object to offer.
- *
- * @return #GNUNET_OK on success.
- */
-static int
-deposit_traits (void *cls,
-                const void **ret,
-                const char *trait,
-                unsigned int index)
-{
-  struct DepositState *ds = cls;
-  const struct TALER_TESTING_Command *coin_cmd;
-  /* Will point to coin cmd internals. */
-  const struct TALER_CoinSpendPrivateKeyP *coin_spent_priv;
-
-  coin_cmd = TALER_TESTING_interpreter_lookup_command
-    (ds->is,
-     ds->coin_reference);
-
-  if (NULL == coin_cmd)
-  {
-    GNUNET_break (0);
-    TALER_TESTING_interpreter_fail (ds->is);
-    return GNUNET_NO;
-  }
-
-  if (GNUNET_OK !=
-      TALER_TESTING_get_trait_coin_priv (coin_cmd,
-					 ds->coin_index,
-					 &coin_spent_priv))
-  {
-    GNUNET_break (0);
-    TALER_TESTING_interpreter_fail (ds->is);
-    return GNUNET_NO;
-  }
-
-  struct TALER_TESTING_Trait traits[] = {
-    /* First two traits are only available if
-       ds->traits is #GNUNET_YES */
-    TALER_TESTING_make_trait_exchange_pub (0,
-					   &ds->exchange_pub),
-    TALER_TESTING_make_trait_exchange_sig (0,
-					   &ds->exchange_sig),
-    /* These traits are always available */
-    TALER_TESTING_make_trait_coin_priv (0,
-					coin_spent_priv),
-    TALER_TESTING_make_trait_wire_details (0,
-					   ds->wire_details),
-    TALER_TESTING_make_trait_contract_terms (0,
-					     ds->contract_terms),
-    TALER_TESTING_make_trait_peer_key (0,
-				       &ds->merchant_priv.eddsa_priv),
-    TALER_TESTING_make_trait_amount (0,
-                                     ds->amount),
-    TALER_TESTING_trait_end ()
-  };
-
-  return TALER_TESTING_get_trait ((ds->traits_ready)
-				  ? traits
-				  : &traits[2],
-                                  ret,
-                                  trait,
-                                  index);
-}
-
-/**
- * Create a "deposit" command.
- *
- * @param label command label.
- * @param coin_reference reference to any operation that can
- *        provide a coin.
- * @param coin_index if @a withdraw_reference offers an array of
- *        coins, this parameter selects which one in that array.
- *        This value is currently ignored, as only one-coin
- *        withdrawals are implemented.
- * @param wire_details wire details associated with the "deposit"
- *        request.
- * @param contract_terms contract terms to be signed over by the
- *        coin.
- * @param refund_deadline refund deadline, zero means 'no refunds'.
- *        Note, if time were absolute, then it would have come
- *        one day and disrupt tests meaning.
- * @param amount how much is going to be deposited.
- * @param expected_response_code expected HTTP response code.
- *
- * @return the command.
- */
-struct TALER_TESTING_Command
-TALER_TESTING_cmd_deposit
-  (const char *label,
-   const char *coin_reference,
-   unsigned int coin_index,
-   json_t *wire_details,
-   const char *contract_terms,
-   struct GNUNET_TIME_Relative refund_deadline,
-   const char *amount,
-   unsigned int expected_response_code)
-{
-  struct DepositState *ds;
-
-  ds = GNUNET_new (struct DepositState);
-  ds->coin_reference = coin_reference;
-  ds->coin_index = coin_index;
-  ds->wire_details = wire_details;
-  ds->contract_terms = json_loads (contract_terms,
-                                   JSON_REJECT_DUPLICATES,
-                                   NULL);
-  if (NULL == ds->contract_terms)
-  {
-    GNUNET_log
-      (GNUNET_ERROR_TYPE_ERROR,
-       "Failed to parse contract terms `%s' for CMD `%s'\n",
-       contract_terms,
-       label);
-    GNUNET_assert (0);
-  }
-
-  ds->refund_deadline = refund_deadline;
-  ds->amount = amount;
-  ds->expected_response_code = expected_response_code;
-
-  struct TALER_TESTING_Command cmd = {
-    .cls = ds,
-    .label = label,
-    .run = &deposit_run,
-    .cleanup = &deposit_cleanup,
-    .traits = &deposit_traits
-  };
-
-  return cmd;
-}
-
-
-/**
- * Modify a deposit command to enable retries when we get transient
- * errors from the exchange.
- *
- * @param cmd a deposit command
- * @return the command with retries enabled
- */
-struct TALER_TESTING_Command
-TALER_TESTING_cmd_deposit_with_retry (struct TALER_TESTING_Command cmd)
-{
-  struct DepositState *ds;
-
-  GNUNET_assert (&deposit_run == cmd.run);
-  ds = cmd.cls;
-  ds->do_retry = GNUNET_YES;
-  return cmd;
-}
-
-
-/* end of testing_api_cmd_deposit.c */