[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] [taler-exchange] branch master updated: extend auditordb wi
|
From: |
gnunet |
|
Subject: |
[GNUnet-SVN] [taler-exchange] branch master updated: extend auditordb with storing information about list of exchanges and their signing keys |
|
Date: |
Sun, 28 Oct 2018 10:26:35 +0100 |
This is an automated email from the git hooks/post-receive script.
grothoff pushed a commit to branch master
in repository exchange.
The following commit(s) were added to refs/heads/master by this push:
new fb0d7110 extend auditordb with storing information about list of
exchanges and their signing keys
fb0d7110 is described below
commit fb0d7110e80546f77d8c562ecfeb2ae06e2f4b6b
Author: Christian Grothoff <address@hidden>
AuthorDate: Sun Oct 28 10:26:32 2018 +0100
extend auditordb with storing information about list of exchanges and their
signing keys
---
src/auditordb/plugin_auditordb_postgres.c | 350 ++++++++++++++++++++++++++++++
src/include/taler_auditordb_plugin.h | 154 +++++++++++--
2 files changed, 490 insertions(+), 14 deletions(-)
diff --git a/src/auditordb/plugin_auditordb_postgres.c
b/src/auditordb/plugin_auditordb_postgres.c
index 42d45899..159e4503 100644
--- a/src/auditordb/plugin_auditordb_postgres.c
+++ b/src/auditordb/plugin_auditordb_postgres.c
@@ -149,6 +149,7 @@ postgres_drop_tables (void *cls)
GNUNET_PQ_make_execute ("DROP TABLE IF EXISTS auditor_reserves;"),
GNUNET_PQ_make_execute ("DROP TABLE IF EXISTS auditor_progress_reserve;"),
GNUNET_PQ_make_execute ("DROP TABLE IF EXISTS
auditor_progress_aggregation;"),
+ GNUNET_PQ_make_execute ("DROP TABLE IF EXISTS
auditor_progress_deposit_confirmation;"),
GNUNET_PQ_make_execute ("DROP TABLE IF EXISTS auditor_progress_coin;"),
GNUNET_PQ_make_execute ("DROP TABLE IF EXISTS wire_auditor_progress;"),
GNUNET_PQ_EXECUTE_STATEMENT_END
@@ -183,6 +184,20 @@ postgres_create_tables (void *cls)
{
struct PostgresClosure *pc = cls;
struct GNUNET_PQ_ExecuteStatement es[] = {
+ /* Table with list of exchanges we are auditing */
+ GNUNET_PQ_make_execute ("CREATE TABLE IF NOT EXISTS auditor_exchanges"
+ "(master_pub BYTEA PRIMARY KEY CHECK
(LENGTH(master_pub)=32)"
+ ",exchange_url VARCHAR NOT NULL"
+ ")"),
+ /* Table with list of signing keys of exchanges we are auditing */
+ GNUNET_PQ_make_execute ("CREATE TABLE IF NOT EXISTS
auditor_exchange_signkeys"
+ "(master_pub BYTEA PRIMARY KEY CHECK
(LENGTH(master_pub)=32)"
+ ",ep_start INT8 NOT NULL"
+ ",ep_expire INT8 NOT NULL"
+ ",ep_end INT8 NOT NULL"
+ ",exchange_pub BYTEA NOT NULL CHECK
(LENGTH(exchange_pub)=32)"
+ ",master_sig BYTEA NOT NULL CHECK
(LENGTH(master_sig)=64)"
+ ")"),
/* Table with all of the denomination keys that the auditor
is aware of. */
GNUNET_PQ_make_execute ("CREATE TABLE IF NOT EXISTS auditor_denominations"
@@ -233,6 +248,10 @@ postgres_create_tables (void *cls)
"(master_pub BYTEA PRIMARY KEY CHECK
(LENGTH(master_pub)=32)"
",last_wire_out_serial_id INT8 NOT NULL DEFAULT 0"
")"),
+ GNUNET_PQ_make_execute ("CREATE TABLE IF NOT EXISTS
auditor_progress_deposit_confirmation"
+ "(master_pub BYTEA PRIMARY KEY CHECK
(LENGTH(master_pub)=32)"
+ ",last_deposit_confirmation_serial_id INT8 NOT NULL
DEFAULT 0"
+ ")"),
GNUNET_PQ_make_execute ("CREATE TABLE IF NOT EXISTS auditor_progress_coin"
"(master_pub BYTEA PRIMARY KEY CHECK
(LENGTH(master_pub)=32)"
",last_withdraw_serial_id INT8 NOT NULL DEFAULT 0"
@@ -453,6 +472,37 @@ postgres_prepare (PGconn *db_conn)
GNUNET_PQ_make_prepare ("do_commit",
"COMMIT",
0),
+ /* used in #postgres_insert_exchange */
+ GNUNET_PQ_make_prepare ("auditor_insert_exchange",
+ "INSERT INTO auditor_exchanges "
+ "(master_pub"
+ ",exchange_url"
+ ") VALUES ($1,$2);",
+ 2),
+ /* used in #postgres_delete_exchange */
+ GNUNET_PQ_make_prepare ("auditor_delete_exchange",
+ "DELETE"
+ " FROM auditor_exchanges"
+ " WHERE master_pub=$1;",
+ 1),
+ /* used in #postgres_list_exchanges */
+ GNUNET_PQ_make_prepare ("auditor_list_exchanges",
+ "SELECT"
+ " master_pub"
+ ",exchange_url"
+ " FROM auditor_exchanges",
+ 0),
+ /* used in #postgres_insert_exchange_signkey */
+ GNUNET_PQ_make_prepare ("auditor_insert_exchange_signkey",
+ "INSERT INTO auditor_exchange_signkeys "
+ "(master_pub"
+ ",ep_start"
+ ",ep_expire"
+ ",ep_end"
+ ",exchange_pub"
+ ",master_sig"
+ ") VALUES ($1,$2,$3,$4,$5,$6);",
+ 6),
/* Used in #postgres_insert_denomination_info() */
GNUNET_PQ_make_prepare ("auditor_denominations_insert",
"INSERT INTO auditor_denominations "
@@ -572,6 +622,26 @@ postgres_prepare (PGconn *db_conn)
",last_wire_out_serial_id"
") VALUES ($1,$2);",
2),
+ /* Used in #postgres_update_auditor_progress_deposit_confirmation() */
+ GNUNET_PQ_make_prepare ("auditor_progress_update_deposit_confirmation",
+ "UPDATE auditor_progress_deposit_confirmation SET "
+ " last_deposit_confirmation_serial_id=$1"
+ " WHERE master_pub=$2",
+ 2),
+ /* Used in #postgres_get_auditor_progress_deposit_confirmation() */
+ GNUNET_PQ_make_prepare ("auditor_progress_select_deposit_confirmation",
+ "SELECT"
+ " last_deposit_confirmation_serial_id"
+ " FROM auditor_progress_deposit_confirmation"
+ " WHERE master_pub=$1;",
+ 1),
+ /* Used in #postgres_insert_auditor_progress_deposit_confirmation() */
+ GNUNET_PQ_make_prepare ("auditor_progress_insert_deposit_confirmation",
+ "INSERT INTO auditor_progress_deposit_confirmation "
+ "(master_pub"
+ ",last_deposit_confirmation_serial_id"
+ ") VALUES ($1,$2);",
+ 2),
/* Used in #postgres_update_auditor_progress_coin() */
GNUNET_PQ_make_prepare ("auditor_progress_update_coin",
"UPDATE auditor_progress_coin SET "
@@ -1131,6 +1201,191 @@ postgres_gc (void *cls)
/**
+ * Insert information about an exchange this auditor will be auditing.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to the database
+ * @param master_pub master public key of the exchange
+ * @param exchange_url public (base) URL of the API of the exchange
+ * @return query result status
+ */
+static enum GNUNET_DB_QueryStatus
+postgres_insert_exchange (void *cls,
+ struct TALER_AUDITORDB_Session *session,
+ const struct TALER_MasterPublicKeyP *master_pub,
+ const char *exchange_url)
+{
+ struct GNUNET_PQ_QueryParam params[] = {
+ GNUNET_PQ_query_param_auto_from_type (&master_pub),
+ GNUNET_PQ_query_param_string (exchange_url),
+ GNUNET_PQ_query_param_end
+ };
+
+ return GNUNET_PQ_eval_prepared_non_select (session->conn,
+ "auditor_insert_exchange",
+ params);
+}
+
+
+/**
+ * Delete an exchange from the list of exchanges this auditor is auditing.
+ * Warning: this will cascade and delete all knowledge of this auditor related
+ * to this exchange!
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to the database
+ * @param master_pub master public key of the exchange
+ * @return query result status
+ */
+static enum GNUNET_DB_QueryStatus
+postgres_delete_exchange (void *cls,
+ struct TALER_AUDITORDB_Session *session,
+ const struct TALER_MasterPublicKeyP *master_pub)
+{
+ struct GNUNET_PQ_QueryParam params[] = {
+ GNUNET_PQ_query_param_auto_from_type (&master_pub),
+ GNUNET_PQ_query_param_end
+ };
+
+ return GNUNET_PQ_eval_prepared_non_select (session->conn,
+ "auditor_delete_exchange",
+ params);
+}
+
+
+/**
+ * Closure for #exchange_info_cb().
+ */
+struct ExchangeInfoContext
+{
+
+ /**
+ * Function to call for each exchange.
+ */
+ TALER_AUDITORDB_ExchangeCallback cb;
+
+ /**
+ * Closure for @e cb
+ */
+ void *cb_cls;
+
+ /**
+ * Query status to return.
+ */
+ enum GNUNET_DB_QueryStatus qs;
+};
+
+
+/**
+ * Helper function for #postgres_auditor_list_exchanges().
+ * To be called with the results of a SELECT statement
+ * that has returned @a num_results results.
+ *
+ * @param cls closure of type `struct ExchangeInfoContext *`
+ * @param result the postgres result
+ * @param num_result the number of results in @a result
+ */
+static void
+exchange_info_cb (void *cls,
+ PGresult *result,
+ unsigned int num_results)
+{
+ struct ExchangeInfoContext *eic = cls;
+
+ for (unsigned int i = 0; i < num_results; i++)
+ {
+ struct TALER_MasterPublicKeyP master_pub;
+ char *exchange_url;
+ struct GNUNET_PQ_ResultSpec rs[] = {
+ GNUNET_PQ_result_spec_auto_from_type ("master_pub", &master_pub),
+ GNUNET_PQ_result_spec_string ("exchange_url", &exchange_url),
+ GNUNET_PQ_result_spec_end
+ };
+
+ if (GNUNET_OK !=
+ GNUNET_PQ_extract_result (result,
+ rs,
+ i))
+ {
+ GNUNET_break (0);
+ eic->qs = GNUNET_DB_STATUS_HARD_ERROR;
+ return;
+ }
+ eic->qs = i + 1;
+ eic->cb (eic->cb_cls,
+ &master_pub,
+ exchange_url);
+ GNUNET_free (exchange_url);
+ }
+}
+
+
+/**
+ * Obtain information about exchanges this auditor is auditing.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to the database
+ * @param master_pub master public key of the exchange
+ * @param exchange_url public (base) URL of the API of the exchange
+ * @return query result status
+ */
+static enum GNUNET_DB_QueryStatus
+postgres_list_exchanges (void *cls,
+ struct TALER_AUDITORDB_Session *session,
+ TALER_AUDITORDB_ExchangeCallback cb,
+ void *cb_cls)
+{
+ struct GNUNET_PQ_QueryParam params[] = {
+ GNUNET_PQ_query_param_end
+ };
+ struct ExchangeInfoContext eic = {
+ .cb = cb,
+ .cb_cls = cb_cls
+ };
+ enum GNUNET_DB_QueryStatus qs;
+
+ qs = GNUNET_PQ_eval_prepared_multi_select (session->conn,
+ "auditor_list_exchanges",
+ params,
+ &exchange_info_cb,
+ &eic);
+ if (qs > 0)
+ return eic.qs;
+ GNUNET_break (GNUNET_DB_STATUS_HARD_ERROR != qs);
+ return qs;
+}
+
+
+/**
+ * Insert information about a signing key of the exchange.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to the database
+ * @param sk signing key information to store
+ * @return query result status
+ */
+static enum GNUNET_DB_QueryStatus
+postgres_insert_exchange_signkey (void *cls,
+ struct TALER_AUDITORDB_Session *session,
+ const struct
TALER_AUDITORDB_ExchangeSigningKey *sk)
+{
+ struct GNUNET_PQ_QueryParam params[] = {
+ GNUNET_PQ_query_param_auto_from_type (&sk->master_public_key),
+ TALER_PQ_query_param_absolute_time (&sk->ep_start),
+ TALER_PQ_query_param_absolute_time (&sk->ep_expire),
+ TALER_PQ_query_param_absolute_time (&sk->ep_end),
+ GNUNET_PQ_query_param_auto_from_type (&sk->exchange_pub),
+ GNUNET_PQ_query_param_auto_from_type (&sk->master_sig),
+ GNUNET_PQ_query_param_end
+ };
+
+ return GNUNET_PQ_eval_prepared_non_select (session->conn,
+ "auditor_insert_exchange_signkey",
+ params);
+}
+
+
+/**
* Insert information about a deposit confirmation into the database.
*
* @param cls the @e cls of this struct with the plugin-specific state
@@ -1529,6 +1784,94 @@ postgres_get_auditor_progress_aggregation (void *cls,
* @param cls the @e cls of this struct with the plugin-specific state
* @param session connection to use
* @param master_pub master key of the exchange
+ * @param ppdc where is the auditor in processing
+ * @return transaction status code
+ */
+static enum GNUNET_DB_QueryStatus
+postgres_insert_auditor_progress_deposit_confirmation (void *cls,
+ struct
TALER_AUDITORDB_Session *session,
+ const struct
TALER_MasterPublicKeyP *master_pub,
+ const struct
TALER_AUDITORDB_ProgressPointDepositConfirmation *ppdc)
+{
+ struct GNUNET_PQ_QueryParam params[] = {
+ GNUNET_PQ_query_param_auto_from_type (master_pub),
+ GNUNET_PQ_query_param_uint64 (&ppdc->last_deposit_confirmation_serial_id),
+ GNUNET_PQ_query_param_end
+ };
+
+ return GNUNET_PQ_eval_prepared_non_select (session->conn,
+
"auditor_progress_insert_deposit_confirmation",
+ params);
+}
+
+
+/**
+ * Update information about the progress of the auditor. There
+ * must be an existing record for the exchange.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to use
+ * @param master_pub master key of the exchange
+ * @param ppdc where is the auditor in processing
+ * @return transaction status code
+ */
+static enum GNUNET_DB_QueryStatus
+postgres_update_auditor_progress_deposit_confirmation (void *cls,
+ struct
TALER_AUDITORDB_Session *session,
+ const struct
TALER_MasterPublicKeyP *master_pub,
+ const struct
TALER_AUDITORDB_ProgressPointDepositConfirmation *ppdc)
+{
+ struct GNUNET_PQ_QueryParam params[] = {
+ GNUNET_PQ_query_param_uint64 (&ppdc->last_deposit_confirmation_serial_id),
+ GNUNET_PQ_query_param_auto_from_type (master_pub),
+ GNUNET_PQ_query_param_end
+ };
+
+ return GNUNET_PQ_eval_prepared_non_select (session->conn,
+
"auditor_progress_update_deposit_confirmation",
+ params);
+}
+
+
+/**
+ * Get information about the progress of the auditor.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to use
+ * @param master_pub master key of the exchange
+ * @param[out] ppdc set to where the auditor is in processing
+ * @return transaction status code
+ */
+static enum GNUNET_DB_QueryStatus
+postgres_get_auditor_progress_deposit_confirmation (void *cls,
+ struct
TALER_AUDITORDB_Session *session,
+ const struct
TALER_MasterPublicKeyP *master_pub,
+ struct
TALER_AUDITORDB_ProgressPointDepositConfirmation *ppdc)
+{
+ struct GNUNET_PQ_QueryParam params[] = {
+ GNUNET_PQ_query_param_auto_from_type (master_pub),
+ GNUNET_PQ_query_param_end
+ };
+ struct GNUNET_PQ_ResultSpec rs[] = {
+ GNUNET_PQ_result_spec_uint64 ("last_deposit_confirmation_serial_id",
+ &ppdc->last_deposit_confirmation_serial_id),
+ GNUNET_PQ_result_spec_end
+ };
+
+ return GNUNET_PQ_eval_prepared_singleton_select (session->conn,
+
"auditor_progress_select_deposit_confirmation",
+ params,
+ rs);
+}
+
+
+/**
+ * Insert information about the auditor's progress with an exchange's
+ * data.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to use
+ * @param master_pub master key of the exchange
* @param ppc where is the auditor in processing
* @return transaction status code
*/
@@ -2910,6 +3253,10 @@ libtaler_plugin_auditordb_postgres_init (void *cls)
plugin->rollback = &postgres_rollback;
plugin->gc = &postgres_gc;
+ plugin->insert_exchange = &postgres_insert_exchange;
+ plugin->delete_exchange = &postgres_delete_exchange;
+ plugin->list_exchanges = &postgres_list_exchanges;
+ plugin->insert_exchange_signkey = &postgres_insert_exchange_signkey;
plugin->insert_deposit_confirmation = &postgres_insert_deposit_confirmation;
plugin->select_denomination_info = &postgres_select_denomination_info;
@@ -2921,6 +3268,9 @@ libtaler_plugin_auditordb_postgres_init (void *cls)
plugin->get_auditor_progress_aggregation =
&postgres_get_auditor_progress_aggregation;
plugin->update_auditor_progress_aggregation =
&postgres_update_auditor_progress_aggregation;
plugin->insert_auditor_progress_aggregation =
&postgres_insert_auditor_progress_aggregation;
+ plugin->get_auditor_progress_deposit_confirmation =
&postgres_get_auditor_progress_deposit_confirmation;
+ plugin->update_auditor_progress_deposit_confirmation =
&postgres_update_auditor_progress_deposit_confirmation;
+ plugin->insert_auditor_progress_deposit_confirmation =
&postgres_insert_auditor_progress_deposit_confirmation;
plugin->get_auditor_progress_coin = &postgres_get_auditor_progress_coin;
plugin->update_auditor_progress_coin =
&postgres_update_auditor_progress_coin;
plugin->insert_auditor_progress_coin =
&postgres_insert_auditor_progress_coin;
diff --git a/src/include/taler_auditordb_plugin.h
b/src/include/taler_auditordb_plugin.h
index ae8cafc0..65db12b7 100644
--- a/src/include/taler_auditordb_plugin.h
+++ b/src/include/taler_auditordb_plugin.h
@@ -30,6 +30,20 @@
/**
+ * Function called with information about exchanges this
+ * auditor is monitoring.
+ *
+ * @param cls closure
+ * @param master_pub master public key of the exchange
+ * @param exchange_url base URL of the exchange's API
+ */
+typedef void
+(*TALER_AUDITORDB_ExchangeCallback)(void *cls,
+ const struct TALER_MasterPublicKeyP
*master_pub,
+ const char *exchange_url);
+
+
+/**
* Function called with the results of select_denomination_info()
*
* @param cls closure
@@ -113,12 +127,12 @@ typedef int
struct TALER_AUDITORDB_WireProgressPoint
{
/**
- * last_reserve_in_serial_id serial ID of the last reserve_in transfer the
wire auditor processed
+ * serial ID of the last reserve_in transfer the wire auditor processed
*/
uint64_t last_reserve_in_serial_id;
/**
- * last_wire_out_serial_id serial ID of the last wire_out the wire auditor
processed
+ * serial ID of the last wire_out the wire auditor processed
*/
uint64_t last_wire_out_serial_id;
@@ -137,23 +151,23 @@ struct TALER_AUDITORDB_WireProgressPoint
struct TALER_AUDITORDB_ProgressPointReserve
{
/**
- * last_reserve_in_serial_id serial ID of the last reserve_in transfer the
auditor processed
+ * serial ID of the last reserve_in transfer the auditor processed
*/
uint64_t last_reserve_in_serial_id;
/**
- * last_reserve_out_serial_id serial ID of the last reserve_out the auditor
processed
+ * serial ID of the last reserve_out the auditor processed
*/
uint64_t last_reserve_out_serial_id;
/**
- * last_payback_serial_id serial ID of the last payback entry the auditor
processed when
+ * serial ID of the last payback entry the auditor processed when
* considering reserves.
*/
uint64_t last_reserve_payback_serial_id;
/**
- * last_reserve_close_serial_id serial ID of the last reserve_close
+ * serial ID of the last reserve_close
* entry the auditor processed.
*/
uint64_t last_reserve_close_serial_id;
@@ -163,13 +177,28 @@ struct TALER_AUDITORDB_ProgressPointReserve
/**
* Structure for remembering the auditor's progress over the various
+ * tables and (auditor) transactions when analyzing reserves.
+ */
+struct TALER_AUDITORDB_ProgressPointDepositConfirmation
+{
+ /**
+ * serial ID of the last deposit_confirmation the auditor processed
+ */
+ uint64_t last_deposit_confirmation_serial_id;
+
+
+};
+
+
+/**
+ * Structure for remembering the auditor's progress over the various
* tables and (auditor) transactions when analyzing aggregations.
*/
struct TALER_AUDITORDB_ProgressPointAggregation
{
/**
- * last_prewire_serial_id serial ID of the last prewire transfer the auditor
processed
+ * serial ID of the last prewire transfer the auditor processed
*/
uint64_t last_wire_out_serial_id;
};
@@ -182,22 +211,22 @@ struct TALER_AUDITORDB_ProgressPointAggregation
struct TALER_AUDITORDB_ProgressPointCoin
{
/**
- * last_reserve_out_serial_id serial ID of the last withdraw the auditor
processed
+ * serial ID of the last withdraw the auditor processed
*/
uint64_t last_withdraw_serial_id;
/**
- * last_deposit_serial_id serial ID of the last deposit the auditor processed
+ * serial ID of the last deposit the auditor processed
*/
uint64_t last_deposit_serial_id;
/**
- * last_melt_serial_id serial ID of the last refresh the auditor processed
+ * serial ID of the last refresh the auditor processed
*/
uint64_t last_melt_serial_id;
/**
- * last_prewire_serial_id serial ID of the last prewire transfer the auditor
processed
+ * serial ID of the last refund the auditor processed
*/
uint64_t last_refund_serial_id;
@@ -422,6 +451,53 @@ struct TALER_AUDITORDB_Plugin
/**
+ * Insert information about an exchange this auditor will be auditing.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to the database
+ * @param master_pub master public key of the exchange
+ * @param exchange_url public (base) URL of the API of the exchange
+ * @return query result status
+ */
+ enum GNUNET_DB_QueryStatus
+ (*insert_exchange) (void *cls,
+ struct TALER_AUDITORDB_Session *session,
+ const struct TALER_MasterPublicKeyP *master_pub,
+ const char *exchange_url);
+
+
+ /**
+ * Delete an exchange from the list of exchanges this auditor is auditing.
+ * Warning: this will cascade and delete all knowledge of this auditor
related
+ * to this exchange!
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to the database
+ * @param master_pub master public key of the exchange
+ * @return query result status
+ */
+ enum GNUNET_DB_QueryStatus
+ (*delete_exchange) (void *cls,
+ struct TALER_AUDITORDB_Session *session,
+ const struct TALER_MasterPublicKeyP *master_pub);
+
+
+ /**
+ * Obtain information about exchanges this auditor is auditing.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to the database
+ * @param master_pub master public key of the exchange
+ * @param exchange_url public (base) URL of the API of the exchange
+ * @return query result status
+ */
+ enum GNUNET_DB_QueryStatus
+ (*list_exchanges) (void *cls,
+ struct TALER_AUDITORDB_Session *session,
+ TALER_AUDITORDB_ExchangeCallback cb,
+ void *cb_cls);
+
+ /**
* Insert information about a signing key of the exchange.
*
* @param cls the @e cls of this struct with the plugin-specific state
@@ -433,7 +509,7 @@ struct TALER_AUDITORDB_Plugin
(*insert_exchange_signkey) (void *cls,
struct TALER_AUDITORDB_Session *session,
const struct TALER_AUDITORDB_ExchangeSigningKey
*sk);
- // FIXME: above function is not yet implemented!
+ // FIXME: above function is not yet implemented!, check for _XX for prepared
statement!
/**
@@ -582,7 +658,57 @@ struct TALER_AUDITORDB_Plugin
const struct TALER_MasterPublicKeyP
*master_pub,
struct TALER_AUDITORDB_ProgressPointReserve
*ppr);
- /**
+ /**
+ * Insert information about the auditor's progress with an exchange's
+ * data.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to use
+ * @param master_pub master key of the exchange
+ * @param ppdc where is the auditor in processing
+ * @return transaction status code
+ */
+ enum GNUNET_DB_QueryStatus
+ (*insert_auditor_progress_deposit_confirmation)(void *cls,
+ struct
TALER_AUDITORDB_Session *session,
+ const struct
TALER_MasterPublicKeyP *master_pub,
+ const struct
TALER_AUDITORDB_ProgressPointDepositConfirmation *ppdc);
+
+
+ /**
+ * Update information about the progress of the auditor. There
+ * must be an existing record for the exchange.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to use
+ * @param master_pub master key of the exchange
+ * @param ppdc where is the auditor in processing
+ * @return transaction status code
+ */
+ enum GNUNET_DB_QueryStatus
+ (*update_auditor_progress_deposit_confirmation)(void *cls,
+ struct
TALER_AUDITORDB_Session *session,
+ const struct
TALER_MasterPublicKeyP *master_pub,
+ const struct
TALER_AUDITORDB_ProgressPointDepositConfirmation *ppdc);
+
+
+ /**
+ * Get information about the progress of the auditor.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param session connection to use
+ * @param master_pub master key of the exchange
+ * @param[out] ppdc set to where the auditor is in processing
+ * @return transaction status code
+ */
+ enum GNUNET_DB_QueryStatus
+ (*get_auditor_progress_deposit_confirmation)(void *cls,
+ struct TALER_AUDITORDB_Session
*session,
+ const struct
TALER_MasterPublicKeyP *master_pub,
+ struct
TALER_AUDITORDB_ProgressPointDepositConfirmation *ppdc);
+
+
+ /**
* Insert information about the auditor's progress with an exchange's
* data.
*
@@ -629,7 +755,7 @@ struct TALER_AUDITORDB_Plugin
(*get_auditor_progress_aggregation)(void *cls,
struct TALER_AUDITORDB_Session *session,
const struct TALER_MasterPublicKeyP
*master_pub,
- struct
TALER_AUDITORDB_ProgressPointAggregation *pp);
+ struct
TALER_AUDITORDB_ProgressPointAggregation *ppa);
/**
--
To stop receiving notification emails like this one, please contact
address@hidden
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] [taler-exchange] branch master updated: extend auditordb with storing information about list of exchanges and their signing keys,
gnunet <=