summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--src/include/taler_mintdb_plugin.h35
-rw-r--r--src/mintdb/plugin_mintdb_postgres.c142
2 files changed, 147 insertions, 30 deletions
diff --git a/src/include/taler_mintdb_plugin.h b/src/include/taler_mintdb_plugin.h
index 2eeead26f..25d747a2d 100644
--- a/src/include/taler_mintdb_plugin.h
+++ b/src/include/taler_mintdb_plugin.h
@@ -667,14 +667,9 @@ struct TALER_MINTDB_Plugin
/**
- * Insert a denomination key.
- *
- * FIXME: Note that the main mint currently does NOT use this API at
- * all. Furthermore, the function to retrieve denomination keys
- * from the DB is still missing. The main mint should check if its
- * denomination keys are in the DB, and if not, insert them (when it
- * loads them). The auditor will (presumably) need the denomination
- * key information to audit the DB. (#3808).
+ * Insert information about a denomination key and in particular
+ * the properties (value, fees, expiration times) the coins signed
+ * with this key have.
*
* @param cls the @e cls of this struct with the plugin-specific state
* @param sesssion connection to use
@@ -683,10 +678,26 @@ struct TALER_MINTDB_Plugin
* @return #GNUNET_OK on success; #GNUNET_SYSERR on failure
*/
int
- (*insert_denomination) (void *cls,
- struct TALER_MINTDB_Session *session,
- const struct TALER_DenominationPublicKey *denom_pub,
- const struct TALER_DenominationKeyValidityPS *issue);
+ (*insert_denomination_info) (void *cls,
+ struct TALER_MINTDB_Session *session,
+ const struct TALER_DenominationPublicKey *denom_pub,
+ const struct TALER_DenominationKeyValidityPS *issue);
+
+
+ /**
+ * Fetch information about a denomination key.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param sesssion connection to use
+ * @param denom_pub the public key used for signing coins of this denomination
+ * @param[out] issue set to issue information with value, fees and other info about the coin
+ * @return #GNUNET_OK on success; #GNUNET_NO if no record was found, #GNUNET_SYSERR on failure
+ */
+ int
+ (*get_denomination_info) (void *cls,
+ struct TALER_MINTDB_Session *session,
+ const struct TALER_DenominationPublicKey *denom_pub,
+ struct TALER_DenominationKeyValidityPS *issue);
/**
diff --git a/src/mintdb/plugin_mintdb_postgres.c b/src/mintdb/plugin_mintdb_postgres.c
index 69646c217..144732087 100644
--- a/src/mintdb/plugin_mintdb_postgres.c
+++ b/src/mintdb/plugin_mintdb_postgres.c
@@ -438,8 +438,8 @@ postgres_prepare (PGconn *db_conn)
PQclear (result); result = NULL; \
} while (0);
- /* Used in #postgres_insert_denomination() */
- PREPARE ("insert_denomination",
+ /* Used in #postgres_insert_denomination_info() */
+ PREPARE ("denomination_insert",
"INSERT INTO denominations "
"(pub"
",master_pub"
@@ -465,7 +465,29 @@ postgres_prepare (PGconn *db_conn)
" $11, $12, $13, $14, $15, $16, $17, $18, $19);",
19, NULL);
- /* FIXME: #3808: need a 'select_denominations' for auditor */
+ /* Used in #postgres_get_denomination_info() */
+ PREPARE ("denomination_get",
+ "SELECT FROM denominations"
+ " master_pub"
+ ",master_sig"
+ ",valid_from"
+ ",expire_withdraw"
+ ",expire_spend"
+ ",expire_legal"
+ ",coin_val" /* value of this denom */
+ ",coin_frac" /* fractional value of this denom */
+ ",coin_curr" /* assuming same currency for fees */
+ ",fee_withdraw_val"
+ ",fee_withdraw_frac"
+ ",fee_withdraw_curr" /* must match coin_curr */
+ ",fee_deposit_val"
+ ",fee_deposit_frac"
+ ",fee_deposit_curr" /* must match coin_curr */
+ ",fee_refresh_val"
+ ",fee_refresh_frac"
+ ",fee_refresh_curr" /* must match coin_curr */
+ " WHERE pub=$1;",
+ 1, NULL);
/* Used in #postgres_reserve_get() */
PREPARE ("reserve_get",
@@ -1027,10 +1049,10 @@ postgres_commit (void *cls,
* @return #GNUNET_OK on success; #GNUNET_SYSERR on failure
*/
static int
-postgres_insert_denomination (void *cls,
- struct TALER_MINTDB_Session *session,
- const struct TALER_DenominationPublicKey *denom_pub,
- const struct TALER_DenominationKeyValidityPS *issue)
+postgres_insert_denomination_info (void *cls,
+ struct TALER_MINTDB_Session *session,
+ const struct TALER_DenominationPublicKey *denom_pub,
+ const struct TALER_DenominationKeyValidityPS *issue)
{
PGresult *result;
int ret;
@@ -1061,7 +1083,7 @@ postgres_insert_denomination (void *cls,
&issue->fee_refresh));
result = TALER_PQ_exec_prepared (session->conn,
- "insert_denomination",
+ "denomination_insert",
params);
if (PGRES_COMMAND_OK != PQresultStatus (result))
{
@@ -1078,6 +1100,86 @@ postgres_insert_denomination (void *cls,
/**
+ * Fetch information about a denomination key.
+ *
+ * @param cls the @e cls of this struct with the plugin-specific state
+ * @param sesssion connection to use
+ * @param denom_pub the public key used for signing coins of this denomination
+ * @param[out] issue set to issue information with value, fees and other info about the coin
+ * @return #GNUNET_OK on success; #GNUNET_NO if no record was found, #GNUNET_SYSERR on failure
+ */
+static int
+postgres_get_denomination_info (void *cls,
+ struct TALER_MINTDB_Session *session,
+ const struct TALER_DenominationPublicKey *denom_pub,
+ struct TALER_DenominationKeyValidityPS *issue)
+{
+ PGresult *result;
+ struct TALER_PQ_QueryParam params[] = {
+ TALER_PQ_query_param_rsa_public_key (denom_pub->rsa_public_key),
+ TALER_PQ_query_param_end
+ };
+
+ result = TALER_PQ_exec_prepared (session->conn,
+ "reserve_get",
+ params);
+ if (PGRES_TUPLES_OK != PQresultStatus (result))
+ {
+ QUERY_ERR (result);
+ PQclear (result);
+ return GNUNET_SYSERR;
+ }
+ if (0 == PQntuples (result))
+ {
+ PQclear (result);
+ return GNUNET_NO;
+ }
+ if (1 != PQntuples (result))
+ {
+ GNUNET_break (0);
+ PQclear (result);
+ return GNUNET_SYSERR;
+ }
+ {
+ struct TALER_PQ_ResultSpec rs[] = {
+ TALER_PQ_result_spec_auto_from_type ("master_pub",
+ &issue->master),
+ TALER_PQ_result_spec_auto_from_type ("master_sig",
+ &issue->signature),
+ TALER_PQ_result_spec_auto_from_type ("valid_from",
+ &issue->start.abs_value_us__),
+ TALER_PQ_result_spec_auto_from_type ("expire_withdraw",
+ &issue->expire_withdraw.abs_value_us__),
+ TALER_PQ_result_spec_auto_from_type ("expire_spend",
+ &issue->expire_spend.abs_value_us__),
+ TALER_PQ_result_spec_auto_from_type ("expire_legal",
+ &issue->expire_legal.abs_value_us__),
+ TALER_PQ_result_spec_amount_nbo ("coin",
+ &issue->value),
+ TALER_PQ_result_spec_amount_nbo ("fee_withdraw",
+ &issue->fee_withdraw),
+ TALER_PQ_result_spec_amount_nbo ("fee_deposit",
+ &issue->fee_deposit),
+ TALER_PQ_result_spec_amount_nbo ("fee_refresh",
+ &issue->fee_refresh),
+ TALER_PQ_result_spec_end
+ };
+
+ EXITIF (GNUNET_OK !=
+ TALER_PQ_extract_result (result,
+ rs,
+ 0));
+ }
+ PQclear (result);
+ return GNUNET_OK;
+
+ EXITIF_exit:
+ PQclear (result);
+ return GNUNET_SYSERR;
+}
+
+
+/**
* Get the summary of a reserve.
*
* @param cls the `struct PostgresClosure` with the plugin-specific state
@@ -1097,11 +1199,6 @@ postgres_reserve_get (void *cls,
TALER_PQ_query_param_auto_from_type(&reserve->pub),
TALER_PQ_query_param_end
};
- struct TALER_PQ_ResultSpec rs[] = {
- TALER_PQ_result_spec_amount("current_balance", &reserve->balance),
- TALER_PQ_result_spec_absolute_time("expiration_date", &reserve->expiry),
- TALER_PQ_result_spec_end
- };
result = TALER_PQ_exec_prepared (session->conn,
"reserve_get",
@@ -1117,10 +1214,18 @@ postgres_reserve_get (void *cls,
PQclear (result);
return GNUNET_NO;
}
- EXITIF (GNUNET_OK !=
- TALER_PQ_extract_result (result,
- rs,
- 0));
+ {
+ struct TALER_PQ_ResultSpec rs[] = {
+ TALER_PQ_result_spec_amount("current_balance", &reserve->balance),
+ TALER_PQ_result_spec_absolute_time("expiration_date", &reserve->expiry),
+ TALER_PQ_result_spec_end
+ };
+
+ EXITIF (GNUNET_OK !=
+ TALER_PQ_extract_result (result,
+ rs,
+ 0));
+ }
PQclear (result);
return GNUNET_OK;
@@ -3047,7 +3152,8 @@ libtaler_plugin_mintdb_postgres_init (void *cls)
plugin->start = &postgres_start;
plugin->commit = &postgres_commit;
plugin->rollback = &postgres_rollback;
- plugin->insert_denomination = &postgres_insert_denomination;
+ plugin->insert_denomination_info = &postgres_insert_denomination_info;
+ plugin->get_denomination_info = &postgres_get_denomination_info;
plugin->reserve_get = &postgres_reserve_get;
plugin->reserves_in_insert = &postgres_reserves_in_insert;
plugin->get_withdraw_info = &postgres_get_withdraw_info;
generated by cgit v1.2.3 (git 2.39.1) at 2024-04-18 01:17:59 +0000