implement wad_in_insert

4 files changed, 29 insertions, 2 deletions

diff --git a/src/exchange/taler-exchange-wirewatch.c b/src/exchange/taler-exchange-wirewatch.c
index 12aebbcae..7db82f7b6 100644
--- a/src/exchange/taler-exchange-wirewatch.c
+++ b/src/exchange/taler-exchange-wirewatch.c
@@ -619,6 +619,7 @@ process_reply (const struct TALER_BANK_CreditDetails *details,
             db_plugin->cls,
             &cd->details.wad.wad_id,
             cd->details.wad.origin_exchange_url,
+            &cd->amount,
             cd->execution_date,
             cd->debit_account_uri,
             ai->section_name,
diff --git a/src/exchangedb/pg_wad_in_insert.c b/src/exchangedb/pg_wad_in_insert.c
index 387273d35..95d792b14 100644
--- a/src/exchangedb/pg_wad_in_insert.c
+++ b/src/exchangedb/pg_wad_in_insert.c
@@ -30,11 +30,33 @@ TEH_PG_wad_in_insert (
   void *cls,
   const struct TALER_WadIdentifierP *wad_id,
   const char *origin_exchange_url,
+  const struct TALER_Amount *amount,
   struct GNUNET_TIME_Timestamp execution_date,
   const char *debit_account_uri,
   const char *section_name,
   uint64_t serial_id)
 {
-  // FIXME: not implemented
-  return -1;
+  struct PostgresClosure *pg = cls;
+  struct GNUNET_PQ_QueryParam params[] = {
+    GNUNET_PQ_query_param_auto_from_type (wad_id),
+    GNUNET_PQ_query_param_string (origin_exchange_url),
+    TALER_PQ_query_param_amount (pg->conn,
+                                 amount),
+    GNUNET_PQ_query_param_timestamp (&execution_date),
+    GNUNET_PQ_query_param_end
+  };
+
+  // FIXME: should we keep the account data + serial_id?
+  PREPARE (pg,
+           "wad_in_insert",
+           "INSERT INTO wads_in "
+           "(wad_id"
+           ",origin_exchange_url"
+           ",amount"
+           ",arrival_time"
+           ") VALUES "
+           "($1, $2, $3, $4);");
+  return GNUNET_PQ_eval_prepared_non_select (pg->conn,
+                                             "wad_in_insert",
+                                             params);
 }
diff --git a/src/exchangedb/pg_wad_in_insert.h b/src/exchangedb/pg_wad_in_insert.h
index 0498412c0..d6c2b25c4 100644
--- a/src/exchangedb/pg_wad_in_insert.h
+++ b/src/exchangedb/pg_wad_in_insert.h
@@ -32,6 +32,7 @@
  * @param cls the @e cls of this struct with the plugin-specific state
  * @param wad_id WAD identifier
  * @param origin_exchange_url exchange base URL originating the transfer
+ * @param amount the amount that was transferred
  * @param execution_date when was the transfer made
  * @param debit_account_uri URI of the debit account
  * @param section_name section of the exchange bank account that received the transfer
@@ -42,6 +43,7 @@ TEH_PG_wad_in_insert (
   void *cls,
   const struct TALER_WadIdentifierP *wad_id,
   const char *origin_exchange_url,
+  const struct TALER_Amount *amount,
   struct GNUNET_TIME_Timestamp execution_date,
   const char *debit_account_uri,
   const char *section_name,
diff --git a/src/include/taler_exchangedb_plugin.h b/src/include/taler_exchangedb_plugin.h
index 0594461d0..7645eb03e 100644
--- a/src/include/taler_exchangedb_plugin.h
+++ b/src/include/taler_exchangedb_plugin.h
@@ -3918,6 +3918,7 @@ struct TALER_EXCHANGEDB_Plugin
    * @param cls the @e cls of this struct with the plugin-specific state
    * @param wad_id WAD identifier
    * @param origin_exchange_url exchange base URL originating the transfer
+   * @param amount the amount that was transferred
    * @param execution_date when was the transfer made
    * @param debit_account_uri URI of the debit account
    * @param section_name section of the exchange bank account that received the transfer
@@ -3928,6 +3929,7 @@ struct TALER_EXCHANGEDB_Plugin
     void *cls,
     const struct TALER_WadIdentifierP *wad_id,
     const char *origin_exchange_url,
+    const struct TALER_Amount *amount,
     struct GNUNET_TIME_Timestamp execution_date,
     const char *debit_account_uri,
     const char *section_name,