/*
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
*/
/**
* @file merchant/tests/merchant-non-http-test.c
* @brief test for various merchant's capabilities
* @author Marcello Stanisci
*/
#include "platform.h"
#include
#include
#include
#include "merchant.h"
#include "merchant_db.h"
#include
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_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 *desc;
struct TALER_Amount amount;
int64_t t_id;
int64_t p_id;
struct Contract contract;
struct GNUNET_TIME_Absolute edate;
struct GNUNET_TIME_Absolute now;
uint64_t nounce;
struct GNUNET_HashCode h_contract_str;
char *aa;
const 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);
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;
}