aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/lib/Makefile.am1
-rw-r--r--src/lib/exchange_api_management_auditor_disable.c1
-rw-r--r--src/lib/exchange_api_management_get_keys.c213
3 files changed, 213 insertions, 2 deletions
diff --git a/src/lib/Makefile.am b/src/lib/Makefile.am
index 3ed672bb0..44d15ac6f 100644
--- a/src/lib/Makefile.am
+++ b/src/lib/Makefile.am
@@ -30,6 +30,7 @@ libtalerexchange_la_SOURCES = \
exchange_api_link.c \
exchange_api_management_auditor_disable.c \
exchange_api_management_auditor_enable.c \
+ exchange_api_management_get_keys.c \
exchange_api_management_post_keys.c \
exchange_api_management_revoke_denomination_key.c \
exchange_api_management_revoke_signing_key.c \
diff --git a/src/lib/exchange_api_management_auditor_disable.c b/src/lib/exchange_api_management_auditor_disable.c
index 0ea368b8c..d91818707 100644
--- a/src/lib/exchange_api_management_auditor_disable.c
+++ b/src/lib/exchange_api_management_auditor_disable.c
@@ -64,6 +64,7 @@ struct TALER_EXCHANGE_ManagementAuditorDisableHandle
struct GNUNET_CURL_Context *ctx;
};
+
/**
* Function called when we're done processing the
* HTTP /management/auditors/%s/disable request.
diff --git a/src/lib/exchange_api_management_get_keys.c b/src/lib/exchange_api_management_get_keys.c
index 36259314b..7148af516 100644
--- a/src/lib/exchange_api_management_get_keys.c
+++ b/src/lib/exchange_api_management_get_keys.c
@@ -24,7 +24,8 @@
#include <gnunet/gnunet_curl_lib.h>
#include "taler_exchange_service.h"
#include "taler_signatures.h"
-
+#include "taler_curl_lib.h"
+#include "taler_json_lib.h"
/**
* @brief Handle for a GET /management/keys request.
@@ -60,6 +61,177 @@ struct TALER_EXCHANGE_ManagementGetKeysHandle
/**
+ * Function called when we're done processing the
+ * HTTP GET /management/keys request.
+ *
+ * @param cls the `struct TALER_EXCHANGE_ManagementGetKeysHandle *`
+ * @param response_code HTTP response code, 0 on error
+ * @param response response body, NULL if not in JSON
+ */
+static void
+handle_get_keys_finished (void *cls,
+ long response_code,
+ const void *response)
+{
+ struct TALER_EXCHANGE_ManagementGetKeysHandle *gh = cls;
+ const json_t *json = response;
+ struct TALER_EXCHANGE_HttpResponse hr = {
+ .http_status = (unsigned int) response_code,
+ .reply = json
+ };
+
+ gh->job = NULL;
+ switch (response_code)
+ {
+ case MHD_HTTP_OK:
+ {
+ struct TALER_EXCHANGE_FutureKeys fk;
+ json_t *sk;
+ json_t *dk;
+ bool ok;
+
+ struct GNUNET_JSON_Specification spec[] = {
+ GNUNET_JSON_spec_json ("future_denoms",
+ &dk),
+ GNUNET_JSON_spec_json ("future_signkeys",
+ &sk),
+ GNUNET_JSON_spec_end ()
+ };
+
+ if (GNUNET_OK !=
+ GNUNET_JSON_parse (json,
+ spec,
+ NULL, NULL))
+ {
+ GNUNET_break_op (0);
+ response_code = 0;
+ break;
+ }
+ fk.num_sign_keys = json_array_size (sk);
+ fk.num_denom_keys = json_array_size (dk);
+ fk.sign_keys = GNUNET_new_array (
+ fk.num_sign_keys,
+ struct TALER_EXCHANGE_FutureSigningPublicKey);
+ fk.denom_keys = GNUNET_new_array (
+ fk.num_denom_keys,
+ struct TALER_EXCHANGE_FutureDenomPublicKey);
+ ok = true;
+ for (unsigned int i = 0; i<fk.num_sign_keys; i++)
+ {
+ json_t *j = json_array_get (sk,
+ i);
+ struct TALER_EXCHANGE_FutureSigningPublicKey *sign_key
+ = &fk.sign_keys[i];
+ struct GNUNET_JSON_Specification spec[] = {
+ GNUNET_JSON_spec_fixed_auto ("key",
+ &sign_key->key),
+ TALER_JSON_spec_absolute_time ("stamp_start",
+ &sign_key->valid_from),
+ TALER_JSON_spec_absolute_time ("stamp_expire",
+ &sign_key->valid_until),
+ TALER_JSON_spec_absolute_time ("stamp_end",
+ &sign_key->valid_legal),
+ GNUNET_JSON_spec_end ()
+ };
+
+ if (GNUNET_OK !=
+ GNUNET_JSON_parse (j,
+ spec,
+ NULL, NULL))
+ {
+ GNUNET_break_op (0);
+ ok = false;
+ break;
+ }
+ }
+ for (unsigned int i = 0; i<fk.num_denom_keys; i++)
+ {
+ json_t *j = json_array_get (dk,
+ i);
+ struct TALER_EXCHANGE_FutureDenomPublicKey *denom_key
+ = &fk.denom_keys[i];
+ struct GNUNET_JSON_Specification spec[] = {
+ TALER_JSON_spec_absolute_time ("stamp_expire_deposit",
+ &denom_key->expire_deposit),
+ TALER_JSON_spec_absolute_time ("stamp_expire_withdraw",
+ &denom_key->withdraw_valid_until),
+ TALER_JSON_spec_absolute_time ("stamp_start",
+ &denom_key->valid_from),
+ TALER_JSON_spec_absolute_time ("stamp_expire_legal",
+ &denom_key->expire_legal),
+ TALER_JSON_spec_amount ("value",
+ &denom_key->value),
+ TALER_JSON_spec_amount ("fee_withdraw",
+ &denom_key->fee_withdraw),
+ TALER_JSON_spec_amount ("fee_deposit",
+ &denom_key->fee_deposit),
+ TALER_JSON_spec_amount ("fee_refresh",
+ &denom_key->fee_refresh),
+ TALER_JSON_spec_amount ("fee_refund",
+ &denom_key->fee_refund),
+ GNUNET_JSON_spec_rsa_public_key ("denom_pub",
+ &denom_key->key.rsa_public_key),
+ GNUNET_JSON_spec_end ()
+ };
+
+ if (GNUNET_OK !=
+ GNUNET_JSON_parse (j,
+ spec,
+ NULL, NULL))
+ {
+ GNUNET_break_op (0);
+ ok = false;
+ break;
+ }
+ }
+ if (ok)
+ {
+ gh->cb (gh->cb_cls,
+ &hr,
+ &fk);
+ gh->cb = NULL;
+ }
+ for (unsigned int i = 0; i<fk.num_denom_keys; i++)
+ {
+ if (NULL != fk.denom_keys[i].key.rsa_public_key)
+ {
+ GNUNET_CRYPTO_rsa_public_key_free (
+ fk.denom_keys[i].key.rsa_public_key);
+ fk.denom_keys[i].key.rsa_public_key = NULL;
+ }
+ }
+ GNUNET_free (fk.sign_keys);
+ GNUNET_free (fk.denom_keys);
+ if (! ok)
+ {
+ response_code = 0;
+ break;
+ }
+ }
+ break;
+ default:
+ /* unexpected response code */
+ GNUNET_break_op (0);
+ hr.ec = TALER_JSON_get_error_code (json);
+ hr.hint = TALER_JSON_get_error_hint (json);
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Unexpected response code %u/%d\n",
+ (unsigned int) response_code,
+ (int) hr.ec);
+ break;
+ }
+ if (NULL != gh->cb)
+ {
+ gh->cb (gh->cb_cls,
+ &hr,
+ NULL);
+ gh->cb = NULL;
+ }
+ TALER_EXCHANGE_get_management_keys_cancel (gh);
+};
+
+
+/**
* Request future keys from the exchange. The obtained information will be
* passed to the @a cb.
*
@@ -73,7 +245,44 @@ struct TALER_EXCHANGE_ManagementGetKeysHandle *
TALER_EXCHANGE_get_management_keys (struct GNUNET_CURL_Context *ctx,
const char *url,
TALER_EXCHANGE_ManagementGetKeysCallback cb,
- void *cb_cls);
+ void *cb_cls)
+{
+ struct TALER_EXCHANGE_ManagementGetKeysHandle *gh;
+ CURL *eh;
+
+ gh = GNUNET_new (struct TALER_EXCHANGE_ManagementGetKeysHandle);
+ gh->cb = cb;
+ gh->cb_cls = cb_cls;
+ gh->ctx = ctx;
+ gh->url = TALER_url_join (url,
+ "management/keys",
+ NULL);
+ if (NULL == gh->url)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Could not construct request URL.\n");
+ GNUNET_free (gh);
+ return NULL;
+ }
+ eh = curl_easy_init ();
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Requesting URL '%s'\n",
+ gh->url);
+ GNUNET_assert (CURLE_OK ==
+ curl_easy_setopt (eh,
+ CURLOPT_URL,
+ gh->url));
+ gh->job = GNUNET_CURL_job_add (ctx,
+ eh,
+ &handle_get_keys_finished,
+ gh);
+ if (NULL == gh->job)
+ {
+ TALER_EXCHANGE_get_management_keys_cancel (gh);
+ return NULL;
+ }
+ return gh;
+}
/**
generated by cgit v1.2.3 (git 2.26.2) at 2024-10-30 04:52:48 +0000