diff options
Diffstat (limited to 'src/tests/test_contract.c')
| -rw-r--r-- | src/tests/test_contract.c | 347 |
1 files changed, 347 insertions, 0 deletions
diff --git a/src/tests/test_contract.c b/src/tests/test_contract.c new file mode 100644 index 00000000..47b3b0e6 --- /dev/null +++ b/src/tests/test_contract.c @@ -0,0 +1,347 @@ +/* + This file is part of TALER + (C) 2014 Christian Grothoff (and other contributing authors) + + 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 merchant/tests/merchant-non-http-test.c +* @brief test for various merchant's capabilities +* @author Marcello Stanisci +*/ + +#include "platform.h" +#include <jansson.h> +#include <gnunet/gnunet_util_lib.h> +#include <taler/taler_json_lib.h> +#include "merchant.h" +#include "merchant_db.h" +#include <taler_merchant_lib.h> + +PGconn *db_conn; + +static int dry; +struct GNUNET_CRYPTO_EddsaPrivateKey *privkey; +char *keyfile; +static int result; +static struct MERCHANT_WIREFORMAT_Sepa *wire; +static struct GNUNET_SCHEDULER_Task *shutdown_task; + +extern +struct MERCHANT_WIREFORMAT_Sepa * +TALER_MERCHANT_parse_wireformat_sepa (const struct GNUNET_CONFIGURATION_Handle *cfg); + +/** + * Shutdown task (magically invoked when the application is being + * quit) + * + * @param cls NULL + * @param tc scheduler task context + */ +static void +do_shutdown (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + + if (NULL != db_conn) + { + MERCHANT_DB_disconnect (db_conn); + db_conn = NULL; + } +} + +extern uint32_t +MERCHANT_DB_get_contract_values (PGconn *conn, + const struct GNUNET_HashCode *h_contract, + uint64_t *nounce, + struct GNUNET_TIME_Absolute *edate); + + +/** + * Main function that will be run by the scheduler. + * + * @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 + */ +static void +run (void *cls, char *const *args, const char *cfgfile, + const struct GNUNET_CONFIGURATION_Handle *config) + +{ + json_t *j_fake_contract; + json_t *j_wire; + json_t *j_details; + json_t *j_mints; + json_t *j_item; + json_t *j_amount; + json_t *j_tax_amount; + json_t *j_item_price; + json_t *j_max_fee; + json_t *j_teatax; + json_t *j_id; // trans id + json_t *j_pid; // product id + json_t *j_quantity; + json_t *j_delloc; + json_t *j_merchant; + json_t *j_merchant_jurisdiction; + json_t *j_merchant_zipcode; + json_t *j_lnames; + json_t *j_deldate; + char *contract_tmp_str; + char *desc; + struct TALER_Amount amount; + int64_t t_id; + int64_t p_id; + #ifdef OBSOLETE + struct ContractNBO contract; + #else + struct Contract contract; + #endif + struct GNUNET_TIME_Absolute edate; + struct GNUNET_TIME_Absolute now; + uint64_t nounce; + struct GNUNET_HashCode h_contract_str; + char *aa; + char *fancy_time; + uint32_t ret; + + db_conn = NULL; + keyfile = NULL; + privkey = NULL; + wire = NULL; + + + db_conn = MERCHANT_DB_connect (config); + if (GNUNET_OK != MERCHANT_DB_initialize (db_conn, GNUNET_NO)) + { + printf ("no db init'd\n"); + result = GNUNET_SYSERR; + } + if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_filename (config, + "merchant", + "KEYFILE", + &keyfile)) + { + printf ("no keyfile entry in cfg file\n"); + result = GNUNET_SYSERR; + } + + privkey = GNUNET_CRYPTO_eddsa_key_create_from_file (keyfile); + wire = TALER_MERCHANT_parse_wireformat_sepa (config); + shutdown_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_FOREVER_REL, + &do_shutdown, NULL); + + /** + * 'Root' object of the contract, leaving some holes to bi filled + * up by the merchant library. + * + */ + + /* Amount */ + TALER_amount_get_zero ("EUR", &amount); + j_amount = TALER_json_from_amount (&amount); + + /* Transaction ID*/ + //t_id = (int32_t) GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_WEAK, UINT64_MAX); + t_id = 321; + + if (t_id < 0) + j_id = json_integer ((-1) * t_id); + else + j_id = json_integer (t_id); + + /** + * Holes: + * + * - 'h_wire' + * - 'timestamp' + * + */ + + /** + * + * Preparing the 'details' sub-object: an array of 'item' objects + * plus some juridical and delivery-aware informations + * + */ + + /** + * + * Preparing a 'item' sub-object + */ + + /* Description */ + desc = "Fake purchase"; + + j_max_fee = TALER_json_from_amount (&amount); + /* Quantity: OPTIONAL FIELD */ + j_quantity = json_integer (3); + + /* item price: OPTIONAL FIELD*/ + j_item_price = TALER_json_from_amount (&amount); + + /* Product ID */ + p_id = (int32_t) GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_WEAK, UINT64_MAX); + + if (p_id < 0) + j_pid = json_integer ((-1) * p_id); + else + j_pid = json_integer (p_id); + + /* Taxes: array of "tax_name" : {tax amount} */ + j_tax_amount = TALER_json_from_amount (&amount); + j_teatax = json_pack ("{s:o}", + "teatax", j_tax_amount); + + if (NULL == (j_item = json_pack ("{s:s, s:I, s:o, s:[o]}", + "description", desc, + "quantity", json_integer_value (j_quantity), + "itemprice", j_item_price, + "taxes", j_teatax))) + { + printf ("error in packing [j_item: %p]\n", j_item); + return; + } + + /* End of 'item' object definition */ + + /* Delivery date: OPTIONAL FIELD */ + now = GNUNET_TIME_absolute_get (); + TALER_round_abs_time (&now); +// deldate = GNUNET_TIME_absolute_add (now, GNUNET_TIME_UNIT_WEEKS); + j_deldate = TALER_json_from_abs (now); + + /* Delivery location: OPTIONAL FIELD */ + j_delloc = json_string ("MALTK"); /* just a 'tag' which points to some well defined location */ + + + /* Merchant jurisdiction: OPTIONAL FIELD (with its fields from 3rd to the last being optional) + * for another optional field */ + j_merchant_zipcode = json_integer (9468); + j_merchant_jurisdiction = json_pack ("{s:s, s:s, s:s, s:s, s:s, s:I}", + "country", "Test Country", + "city", "Test City", + "state", "NA", + "region", "NA", + "province", "NA", + "ZIP code", json_integer_value (j_merchant_zipcode)); + + /* Merchant details */ + j_merchant = json_pack ("{s:s, s:s, s:o}", + "address", "UALMP", + "name", "test merchant", + "jurisdiction", j_merchant_jurisdiction); + + + /* L-names mapping */ + j_lnames = json_pack ("[{s:s}, {s:s}]", + "MALTK", "Test Address 1", + "UALMP", "Second Test Address"); + + + + j_details = json_pack ("{s:I, s:o, s:o, s:o, s:o, s:o}", + "product_id", json_integer_value (j_pid), + "items", j_item, + "delivery date", j_deldate, + "delivery location", j_delloc, + "merchant", j_merchant, + "L-names", j_lnames); + + /* Faking out the mints' list */ + j_mints = json_pack ("[{s:s}]", + "demo.taler.net", + "Q1WVGRGC1F4W7RYC6M23AEGFEXQEHQ730K3GG0B67VPHQSRR75H0"); + + j_fake_contract = json_pack ("{s:o, s:o, s:I, s:o, s:o}", + "amount", j_amount, + "max fee", j_max_fee, + "trans_id", json_integer_value (j_id), + "mints", j_mints, + "details", j_details); + #if 0 + str = json_dumps (j_fake_contract, JSON_INDENT(2) | JSON_PRESERVE_ORDER); + printf ("%s\n", str); + return; + #endif + + nounce = GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_NONCE, UINT64_MAX); + + j_wire = MERCHANT_get_wire_json (wire, nounce, now); + + ret = MERCHANT_handle_contract (j_fake_contract, + db_conn, + &contract, + now, + now, + now, + now, + &aa, + nounce); + if (ret == GNUNET_NO) + { + printf ("Failed, contract already in DB\n"); + return; + } + else + printf ("handling contract fine\n"); + + + printf ("contract string : %s\n", aa); + + GNUNET_CRYPTO_hash (aa, strlen (aa) + 1, &h_contract_str); + if (GNUNET_SYSERR == MERCHANT_DB_get_contract_values (db_conn, &h_contract_str, &nounce, &edate)) + printf ("no hash found\n"); + else + { + + fancy_time = GNUNET_STRINGS_absolute_time_to_string (edate); + printf ("hash found!, nounce is : %llu\n", nounce); + printf ("hash found!, time is : %s\n", fancy_time); + } + + return; +} + + +/** + * The main function of the test tool + * + * @param argc number of arguments from the command line + * @param argv command line arguments + * @return 0 ok, 1 on error + */ +int +main (int argc, char *const *argv) +{ + + static const struct GNUNET_GETOPT_CommandLineOption options[] = { + {'t', "temp", NULL, + gettext_noop ("Use temporary database tables"), GNUNET_NO, + &GNUNET_GETOPT_set_one, &dry}, + GNUNET_GETOPT_OPTION_END + }; + + + if (GNUNET_OK != + GNUNET_PROGRAM_run (argc, argv, + "merchant-contract-test", + "Test for contracts mgmt", + options, &run, NULL)) + return 3; + return (GNUNET_OK == result) ? 0 : 1; + + + +} |