fix testcase FTBFS

1 files changed, 123 insertions, 66 deletions

diff --git a/src/mint/test_mint_db.c b/src/mint/test_mint_db.c
index 2bb25aa6a..750303a03 100644
--- a/src/mint/test_mint_db.c
+++ b/src/mint/test_mint_db.c
@@ -13,15 +13,13 @@
   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 mint/test_mint_db.c
  * @brief test cases for DB interaction functions
  * @author Sree Harsha Totakura <sreeharsha@totakura.in>
  */
-
 #include "platform.h"
-#include "mint_db.h"
+#include "plugin.h"
 
 static int result;
 
@@ -45,7 +43,7 @@ static int result;
 /**
  * Checks if the given reserve has the given amount of balance and expiry
  *
- * @param db the database connection
+ * @param session the database connection
  * @param pub the public key of the reserve
  * @param value balance value
  * @param fraction balance fraction
@@ -54,16 +52,21 @@ static int result;
  * @return #GNUNET_OK if the given reserve has the same balance and expiration
  *           as the given parameters; #GNUNET_SYSERR if not
  */
-int
-check_reserve (PGconn *db,
+static int
+check_reserve (struct TALER_MINTDB_Session *session,
                struct GNUNET_CRYPTO_EddsaPublicKey *pub,
-               uint32_t value, uint32_t fraction, const char *currency,
+               uint32_t value,
+               uint32_t fraction,
+               const char *currency,
                uint64_t expiry)
 {
   struct Reserve reserve;
   reserve.pub = pub;
 
-  FAILIF (GNUNET_OK != TALER_MINT_DB_reserve_get (db, &reserve));
+  FAILIF (GNUNET_OK !=
+          plugin->reserve_get (plugin->cls,
+                               session,
+                               &reserve));
   FAILIF (value != reserve.balance.value);
   FAILIF (fraction != reserve.balance.fraction);
   FAILIF (0 != strcmp (currency, reserve.balance.currency));
@@ -81,7 +84,8 @@ struct DenomKeyPair
   struct GNUNET_CRYPTO_rsa_PublicKey *pub;
 };
 
-struct DenomKeyPair *
+
+static struct DenomKeyPair *
 create_denom_key_pair (unsigned int size)
 {
   struct DenomKeyPair *dkp;
@@ -93,6 +97,7 @@ create_denom_key_pair (unsigned int size)
   return dkp;
 }
 
+
 static void
 destroy_denon_key_pair (struct DenomKeyPair *dkp)
 {
@@ -107,13 +112,15 @@ destroy_denon_key_pair (struct DenomKeyPair *dkp)
  * @param cls closure
  * @param args remaining command-line arguments
  * @param cfgfile name of the configuration file used (for saving, can be NULL!)
- * @param config configuration
+ * @param cfg configuration
  */
 static void
-run (void *cls, char *const *args, const char *cfgfile,
-     const struct GNUNET_CONFIGURATION_Handle *config)
+run (void *cls,
+     char *const *args,
+     const char *cfgfile,
+     const struct GNUNET_CONFIGURATION_Handle *cfg)
 {
-  PGconn *db;
+  struct TALER_MINTDB_Session *session;
   struct GNUNET_CRYPTO_EddsaPublicKey reserve_pub;
   struct Reserve reserve;
   struct GNUNET_TIME_Absolute expiry;
@@ -139,23 +146,27 @@ run (void *cls, char *const *args, const char *cfgfile,
 \"address\": \"foobar\"}";
   unsigned int cnt;
 
-  db = NULL;
   dkp = NULL;
   rh = NULL;
   wire = NULL;
   ZR_BLK (&cbc);
   ZR_BLK (&cbc2);
-  if (GNUNET_OK != TALER_MINT_DB_init ("postgres:///taler"))
+  if (GNUNET_OK !=
+      TALER_MINT_plugin_load (cfg))
   {
     result = 1;
     return;
   }
-  if (GNUNET_OK != TALER_MINT_DB_create_tables (GNUNET_YES))
+  if (GNUNET_OK !=
+      plugin->create_tables (plugin->cls,
+                             GNUNET_YES))
   {
     result = 2;
     goto drop;
   }
-  if (NULL == (db = TALER_MINT_DB_get_connection(GNUNET_YES)))
+  if (NULL ==
+      (session = plugin->get_session (plugin->cls,
+                                      GNUNET_YES)))
   {
     result = 3;
     goto drop;
@@ -168,60 +179,85 @@ run (void *cls, char *const *args, const char *cfgfile,
   expiry = GNUNET_TIME_absolute_add (GNUNET_TIME_absolute_get (),
                                      GNUNET_TIME_UNIT_HOURS);
   result = 4;
-  FAILIF (GNUNET_OK != TALER_MINT_DB_reserves_in_insert (db,
-                                                         &reserve,
-                                                         &amount,
-                                                         expiry));
-  FAILIF (GNUNET_OK != check_reserve (db,
-                                      &reserve_pub,
-                                      amount.value,
-                                      amount.fraction,
-                                      amount.currency,
-                                      expiry.abs_value_us));
-  FAILIF (GNUNET_OK != TALER_MINT_DB_reserves_in_insert (db,
-                                                         &reserve,
-                                                         &amount,
-                                                         expiry));
-  FAILIF (GNUNET_OK != check_reserve (db,
-                                      &reserve_pub,
-                                      ++amount.value,
-                                      ++amount.fraction,
-                                      amount.currency,
-                                      expiry.abs_value_us));
+  FAILIF (GNUNET_OK !=
+          plugin->reserves_in_insert (plugin->cls,
+                                      session,
+                                      &reserve,
+                                      &amount,
+                                      expiry));
+  FAILIF (GNUNET_OK !=
+          check_reserve (session,
+                         &reserve_pub,
+                         amount.value,
+                         amount.fraction,
+                         amount.currency,
+                         expiry.abs_value_us));
+  FAILIF (GNUNET_OK !=
+          plugin->reserves_in_insert (plugin->cls,
+                                      session,
+                                      &reserve,
+                                      &amount,
+                                      expiry));
+  FAILIF (GNUNET_OK !=
+          check_reserve (session,
+                         &reserve_pub,
+                         ++amount.value,
+                         ++amount.fraction,
+                         amount.currency,
+                         expiry.abs_value_us));
   dkp = create_denom_key_pair (1024);
   RND_BLK(&h_blind);
   RND_BLK(&cbc.reserve_sig);
   cbc.denom_pub = dkp->pub;
   cbc.sig = GNUNET_CRYPTO_rsa_sign (dkp->priv, &h_blind, sizeof (h_blind));
-  (void) memcpy (&cbc.reserve_pub, &reserve_pub, sizeof (reserve_pub));
+  (void) memcpy (&cbc.reserve_pub,
+                 &reserve_pub,
+                 sizeof (reserve_pub));
   amount.value--;
   amount.fraction--;
-  FAILIF (GNUNET_OK != TALER_MINT_DB_insert_collectable_blindcoin (db,
-                                                                   &h_blind,
-                                                                   amount,
-                                                                   &cbc));
-  FAILIF (GNUNET_OK != check_reserve (db,
-                                      &reserve_pub,
-                                      amount.value,
-                                      amount.fraction,
-                                      amount.currency,
-                                      expiry.abs_value_us));
-  FAILIF (GNUNET_YES != TALER_MINT_DB_get_collectable_blindcoin (db,
-                                                                 &h_blind,
-                                                                 &cbc2));
+  FAILIF (GNUNET_OK !=
+          plugin->insert_collectable_blindcoin (plugin->cls,
+                                                session,
+                                                &h_blind,
+                                                amount,
+                                                &cbc));
+  FAILIF (GNUNET_OK !=
+          check_reserve (session,
+                         &reserve_pub,
+                         amount.value,
+                         amount.fraction,
+                         amount.currency,
+                         expiry.abs_value_us));
+  FAILIF (GNUNET_YES !=
+          plugin->get_collectable_blindcoin (plugin->cls,
+                                             session,
+                                             &h_blind,
+                                             &cbc2));
   FAILIF (NULL == cbc2.denom_pub);
-  FAILIF (0 != memcmp (&cbc2.reserve_sig, &cbc.reserve_sig, sizeof (cbc2.reserve_sig)));
-  FAILIF (0 != memcmp (&cbc2.reserve_pub, &cbc.reserve_pub, sizeof (cbc2.reserve_pub)));
-  FAILIF (GNUNET_OK != GNUNET_CRYPTO_rsa_verify (&h_blind, cbc2.sig, dkp->pub));
-  rh_head = rh = TALER_MINT_DB_get_reserve_history (db, &reserve_pub);
+  FAILIF (0 != memcmp (&cbc2.reserve_sig,
+                       &cbc.reserve_sig,
+                       sizeof (cbc2.reserve_sig)));
+  FAILIF (0 != memcmp (&cbc2.reserve_pub,
+                       &cbc.reserve_pub,
+                       sizeof (cbc2.reserve_pub)));
+  FAILIF (GNUNET_OK !=
+          GNUNET_CRYPTO_rsa_verify (&h_blind,
+                                    cbc2.sig,
+                                    dkp->pub));
+  rh = plugin->get_reserve_history (plugin->cls,
+                                    session,
+                                    &reserve_pub);
   FAILIF (NULL == rh);
+  rh_head = rh;
   for (cnt=0; NULL != rh_head; rh_head=rh_head->next, cnt++)
   {
     switch (rh_head->type)
     {
     case TALER_MINT_DB_RO_BANK_TO_MINT:
       bt = rh_head->details.bank;
-      FAILIF (0 != memcmp (&bt->reserve_pub, &reserve_pub, sizeof (reserve_pub)));
+      FAILIF (0 != memcmp (&bt->reserve_pub,
+                           &reserve_pub,
+                           sizeof (reserve_pub)));
       FAILIF (1 != bt->amount.value);
       FAILIF (1 != bt->amount.fraction);
       FAILIF (0 != strcmp (CURRENCY, bt->amount.currency));
@@ -251,17 +287,35 @@ run (void *cls, char *const *args, const char *cfgfile,
   deposit.transaction_id =
       GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_WEAK, UINT64_MAX);
   deposit.amount = amount;
-  FAILIF (GNUNET_OK != TALER_MINT_DB_insert_deposit (db, &deposit));
-  FAILIF (GNUNET_YES != TALER_MINT_DB_have_deposit (db, &deposit));
-  (void) memcpy (&deposit2, &deposit, sizeof (deposit));
+  FAILIF (GNUNET_OK !=
+          plugin->insert_deposit (plugin->cls,
+                                  session, &deposit));
+  FAILIF (GNUNET_YES !=
+          plugin->have_deposit (plugin->cls,
+                                session,
+                                &deposit));
+  (void) memcpy (&deposit2,
+                 &deposit,
+                 sizeof (deposit));
   deposit2.transaction_id++;     /* should fail if transaction id is different */
-  FAILIF (GNUNET_NO != TALER_MINT_DB_have_deposit (db, &deposit2));
+  FAILIF (GNUNET_NO !=
+          plugin->have_deposit (plugin->cls,
+                                session,
+                                &deposit2));
   deposit2.transaction_id = deposit.transaction_id;
   RND_BLK (&deposit2.merchant_pub); /* should fail if merchant is different */
-  FAILIF (GNUNET_NO != TALER_MINT_DB_have_deposit (db, &deposit2));
-  (void) memcpy (&deposit2.merchant_pub, &deposit.merchant_pub, sizeof (deposit.merchant_pub));
+  FAILIF (GNUNET_NO !=
+          plugin->have_deposit (plugin->cls,
+                                session,
+                                &deposit2));
+  (void) memcpy (&deposit2.merchant_pub,
+                 &deposit.merchant_pub,
+                 sizeof (deposit.merchant_pub));
   RND_BLK (&deposit2.coin.coin_pub); /* should fail if coin is different */
-  FAILIF (GNUNET_NO != TALER_MINT_DB_have_deposit (db, &deposit2));
+  FAILIF (GNUNET_NO !=
+          plugin->have_deposit (plugin->cls,
+                                session,
+                                &deposit2));
   result = 0;
 
  drop:
@@ -270,8 +324,10 @@ run (void *cls, char *const *args, const char *cfgfile,
   if (NULL != rh)
     TALER_MINT_DB_free_reserve_history (rh);
   rh = NULL;
-  if (NULL != db)
-    GNUNET_break (GNUNET_OK == TALER_MINT_DB_drop_temporary (db));
+  if (NULL != session)
+    GNUNET_break (GNUNET_OK ==
+                  plugin->drop_temporary (plugin->cls,
+                                          session));
   if (NULL != dkp)
     destroy_denon_key_pair (dkp);
   if (NULL != cbc.sig)
@@ -285,7 +341,8 @@ run (void *cls, char *const *args, const char *cfgfile,
 
 
 int
-main (int argc, char *const argv[])
+main (int argc,
+      char *const argv[])
 {
    static const struct GNUNET_GETOPT_CommandLineOption options[] = {
     GNUNET_GETOPT_OPTION_END