taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

KYC DB methods: store a wire transfer.

Browse Source
This commit is contained in:
Marcello Stanisci 2018-07-10 13:08:53 +02:00
parent 8f6b8dbe97
commit 109a4a5aa1
No known key found for this signature in database
GPG Key ID: 8D526861953F4C0F
3 changed files with 71 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/exchangedb/plugin_exchangedb_postgres.c
View File

@ -6576,6 +6576,39 @@ postgres_unmark_kyc_merchant
params);
}
/**
* Record timestamp where a particular merchant performed
* a wire transfer.
*
* @param cls closure.
* @param session db session.
* @param merchant_serial_id serial id of the merchant who
* performed the wire transfer.
* @param amount amount of the wire transfer being monitored.
* @return database transaction status.
*/
static enum GNUNET_DB_QueryStatus
postgres_insert_kyc_event
(void *cls,
struct TALER_EXCHANGEDB_Session *session,
uint64_t merchant_serial_id,
struct TALER_Amount *amount)
{
struct GNUNET_TIME_Absolute now;
now = GNUNET_TIME_absolute_get ();
struct GNUNET_PQ_QueryParam params[] = {
GNUNET_PQ_query_param_uint64 (&merchant_serial_id),
TALER_PQ_query_param_amount (amount),
GNUNET_PQ_query_param_absolute_time (&now),
GNUNET_PQ_query_param_end
};
return GNUNET_PQ_eval_prepared_non_select (session->conn,
"insert_kyc_event",
params);
}
/**
* Mark a merchant as KYC-checked.
*
@ -6814,6 +6847,7 @@ libtaler_plugin_exchangedb_postgres_init (void *cls)
plugin->mark_kyc_merchant = postgres_mark_kyc_merchant;
plugin->unmark_kyc_merchant = postgres_unmark_kyc_merchant;
plugin->get_kyc_status = postgres_get_kyc_status;
plugin->insert_kyc_event = postgres_insert_kyc_event;
return plugin;
}

23
src/exchangedb/test_exchangedb.c
View File

@ -361,7 +361,25 @@ kcs (void *cls,
uint8_t kyc_checked,
uint64_t merchant_serial_id)
{
GNUNET_break (0);
struct TALER_EXCHANGEDB_Session *session = cls;
struct TALER_Amount amount;
TALER_amount_get_zero (CURRENCY,
&amount);
FAILIF
(GNUNET_OK != plugin->insert_kyc_event (NULL,
session,
merchant_serial_id,
&amount));
FAILIF
(GNUNET_OK != plugin->insert_kyc_event (NULL,
session,
merchant_serial_id,
&amount));
drop:
return;
}
/**
@ -2215,13 +2233,12 @@ run (void *cls)
session,
"payto://mock",
&kcs,
NULL));
session));
FAILIF (GNUNET_OK !=
plugin->unmark_kyc_merchant (NULL,
session,
"payto://mock"));
plugin->preflight (plugin->cls,
session);

17
src/include/taler_exchangedb_plugin.h
View File

@ -2305,6 +2305,23 @@ struct TALER_EXCHANGEDB_Plugin
const char *payto_url,
TALER_EXCHANGEDB_KycStatusCallback ksc,
void *ksc_cls);
/**
* Record timestamp where a particular merchant performed
* a wire transfer.
*
* @param cls closure.
* @param session db session.
* @param merchant_serial_id serial id of the merchant who
* performed the wire transfer.
* @param amount amount of the wire transfer being monitored.
* @return database transaction status.
*/
enum GNUNET_DB_QueryStatus
(*insert_kyc_event) (void *cls,
struct TALER_EXCHANGEDB_Session *session,
uint64_t merchant_serial_id,
struct TALER_Amount *amount);
};
#endif /* _TALER_EXCHANGE_DB_H */