commit b03f6cf5044193931b028e867642f13ee9a24f3b
parent ed553c1bd7b3a26de30761fe85ad4e9639a06315
Author: Christian Grothoff <christian@grothoff.org>
Date: Fri, 17 Apr 2020 21:06:20 +0200
implement instances_get in library
Diffstat:
5 files changed, 633 insertions(+), 289 deletions(-)
diff --git a/src/include/taler_merchant_service.h b/src/include/taler_merchant_service.h
@@ -177,38 +177,6 @@ enum TALER_MERCHANT_VersionCompatibility
/**
- * @brief Information about a merchant instance.
- */
-struct TALER_MERCHANT_InstanceInformation
-{
- /**
- * URL of this instance. The URL can be relative to the current domain
- * (i.e. "/PizzaShop/") or include a schema and fully qualified domain name
- * (i.e. "https://backend.example.com/PS/"). The latter can be used to redirect
- * clients to a different server in case the deployment location changes.
- */
- const char *instance_baseurl;
-
- /**
- * Legal name of the merchant/instance.
- */
- const char *name;
-
- /**
- * Base URL of the exchange this instance uses for tipping, or NULL if this
- * instance does not support tipping.
- */
- const char *tipping_exchange_baseurl;
-
- /**
- * Public key of the instance.
- */
- struct TALER_MerchantPublicKeyP merchant_pub;
-
-};
-
-
-/**
* @brief Config information we get from the backend.
*/
struct TALER_MERCHANT_ConfigInformation
@@ -280,6 +248,91 @@ void
TALER_MERCHANT_config_get_cancel (struct TALER_MERCHANT_ConfigGetHandle *vgh);
+/* ********************* /instances *********************** */
+
+
+/**
+ * @brief Information about a merchant instance.
+ */
+struct TALER_MERCHANT_InstanceInformation
+{
+ /**
+ * Id of this instance. This $ID can be used to construct the URL of the
+ * instance, by combining it using "$MERCHANT_BASEURL/instances/$ID/".
+ */
+ const char *id;
+
+ /**
+ * Legal name of the merchant/instance.
+ */
+ const char *name;
+
+ /**
+ * Public key of the instance.
+ */
+ struct TALER_MerchantPublicKeyP merchant_pub;
+
+ /**
+ * JSON array of payment targets (strings) supported by this backend
+ * instance.
+ */
+ json_t *payment_targets;
+
+};
+
+
+/**
+ * Handle for a GET /instances operation.
+ */
+struct TALER_MERCHANT_InstancesGetHandle;
+
+
+/**
+ * Function called with the result of the GET /instances operation.
+ *
+ * @param cls closure
+ * @param hr HTTP response data
+ * @param iis_length length of the @a iis array
+ * @param iis array with instance information of length @a iis_length
+ */
+typedef void
+(*TALER_MERCHANT_InstancesCallback)(
+ void *cls,
+ const struct TALER_MERCHANT_HttpResponse *hr,
+ unsigned int iis_length,
+ const struct TALER_MERCHANT_InstanceInformation iis[]);
+
+
+/**
+ * Get the instance data of a backend. Will connect to the merchant backend
+ * and obtain information about the instances. The respective information will
+ * be passed to the @a instances_cb once available.
+ *
+ * @param ctx the context
+ * @param backend_url HTTP base URL for the backend
+ * @param instances_cb function to call with the
+ * backend's instances information
+ * @param instances_cb_cls closure for @a config_cb
+ * @return the instances handle; NULL upon error
+ */
+struct TALER_MERCHANT_InstancesGetHandle *
+TALER_MERCHANT_instances_get (struct GNUNET_CURL_Context *ctx,
+ const char *backend_url,
+ TALER_MERCHANT_InstancesCallback instances_cb,
+ void *instances_cb_cls);
+
+
+/**
+ * Cancel /instances request. Must not be called by clients after
+ * the callback was invoked.
+ *
+ * @param igh request to cancel.
+ */
+void
+TALER_MERCHANT_instances_get_cancel (
+ struct TALER_MERCHANT_InstancesGetHandle *igh);
+
+
/* ********************* /refund ************************** */
/**
diff --git a/src/lib/Makefile.am b/src/lib/Makefile.am
@@ -21,7 +21,8 @@ libtalermerchanttesting_la_LDFLAGS = \
libtalermerchant_la_SOURCES = \
merchant_api_check_payment.c \
merchant_api_common.c \
- merchant_api_config.c \
+ merchant_api_config_get.c \
+ merchant_api_instances_get.c \
merchant_api_history.c \
merchant_api_proposal.c \
merchant_api_proposal_lookup.c \
diff --git a/src/lib/merchant_api_config.c b/src/lib/merchant_api_config.c
@@ -1,256 +0,0 @@
-/*
- This file is part of TALER
- Copyright (C) 2014-2018, 2020 Taler Systems SA
-
- TALER is free software; you can redistribute it and/or modify it under the
- terms of the GNU Lesser General Public License as published by the Free Software
- Foundation; either version 2.1, 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 Lesser General Public License for more details.
-
- You should have received a copy of the GNU Lesser General Public License along with
- TALER; see the file COPYING.LGPL. If not, see
- <http://www.gnu.org/licenses/>
-*/
-/**
- * @file lib/merchant_api_config.c
- * @brief Implementation of the /config request of the merchant's HTTP API
- * @author Christian Grothoff
- */
-#include "platform.h"
-#include <curl/curl.h>
-#include <jansson.h>
-#include <microhttpd.h> /* just for HTTP status codes */
-#include <gnunet/gnunet_util_lib.h>
-#include <gnunet/gnunet_curl_lib.h>
-#include "taler_merchant_service.h"
-#include <taler/taler_json_lib.h>
-#include <taler/taler_signatures.h>
-
-/**
- * Which version of the Taler protocol is implemented
- * by this library? Used to determine compatibility.
- */
-#define MERCHANT_PROTOCOL_CURRENT 0
-
-/**
- * How many configs are we backwards compatible with?
- */
-#define MERCHANT_PROTOCOL_AGE 0
-
-
-/**
- * @brief A handle for /config operations
- */
-struct TALER_MERCHANT_ConfigGetHandle
-{
- /**
- * The url for this request.
- */
- char *url;
-
- /**
- * Handle for the request.
- */
- struct GNUNET_CURL_Job *job;
-
- /**
- * Function to call with the result.
- */
- TALER_MERCHANT_ConfigCallback cb;
-
- /**
- * Closure for @a cb.
- */
- void *cb_cls;
-
- /**
- * Reference to the execution context.
- */
- struct GNUNET_CURL_Context *ctx;
-
-};
-
-
-/**
- * Function called when we're done processing the
- * HTTP /config request.
- *
- * @param cls the `struct TALER_MERCHANT_ConfigGetHandle`
- * @param response_code HTTP response code, 0 on error
- * @param json response body, NULL if not in JSON
- */
-static void
-handle_config_finished (void *cls,
- long response_code,
- const void *response)
-{
- struct TALER_MERCHANT_ConfigGetHandle *vgh = cls;
- const json_t *json = response;
- struct TALER_MERCHANT_HttpResponse hr = {
- .http_status = (unsigned int) response_code,
- .reply = json
- };
-
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Got /config response with status code %u\n",
- (unsigned int) response_code);
-
- vgh->job = NULL;
- switch (response_code)
- {
- case MHD_HTTP_OK:
- {
- struct TALER_MERCHANT_ConfigInformation vi;
- enum TALER_MERCHANT_VersionCompatibility vc =
- TALER_MERCHANT_VC_PROTOCOL_ERROR;
- struct GNUNET_JSON_Specification spec[] = {
- GNUNET_JSON_spec_string ("currency",
- &vi.currency),
- GNUNET_JSON_spec_string ("version",
- &vi.version),
- GNUNET_JSON_spec_end ()
- };
-
- if (GNUNET_OK !=
- GNUNET_JSON_parse (json,
- spec,
- NULL, NULL))
- {
- hr.http_status = 0;
- hr.ec = TALER_EC_INVALID_RESPONSE;
- }
- else
- {
- unsigned int age;
- unsigned int revision;
- unsigned int current;
-
- if (3 != sscanf (vi.version,
- "%u:%u:%u",
- ¤t,
- &revision,
- &age))
- {
- hr.http_status = 0;
- hr.ec = TALER_EC_INVALID_RESPONSE;
- }
- else
- {
- vc = TALER_MERCHANT_VC_MATCH;
- if (MERCHANT_PROTOCOL_CURRENT < current)
- {
- vc |= TALER_MERCHANT_VC_NEWER;
- if (MERCHANT_PROTOCOL_CURRENT < current - age)
- vc |= TALER_MERCHANT_VC_INCOMPATIBLE;
- }
- if (MERCHANT_PROTOCOL_CURRENT > current)
- {
- vc |= TALER_MERCHANT_VC_OLDER;
- if (MERCHANT_PROTOCOL_CURRENT - MERCHANT_PROTOCOL_AGE > current)
- vc |= TALER_MERCHANT_VC_INCOMPATIBLE;
- }
- }
- }
- vgh->cb (vgh->cb_cls,
- &hr,
- &vi,
- vc);
- TALER_MERCHANT_config_get_cancel (vgh);
- return;
- }
- default:
- /* unexpected response code */
- 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);
- vgh->cb (vgh->cb_cls,
- &hr,
- NULL,
- TALER_MERCHANT_VC_PROTOCOL_ERROR);
- break;
- }
- TALER_MERCHANT_config_get_cancel (vgh);
-}
-
-
-/**
- * Get the config data of a merchant. Will connect to the merchant backend
- * and obtain information about the backend. The respective information will
- * be passed to the @a config_cb once available.
- *
- * @param ctx the context
- * @param backend_url HTTP base URL for the backend
- * @param config_cb function to call with the
- * backend's config information
- * @param config_cb_cls closure for @a config_cb
- * @return the config check handle; NULL upon error
- */
-struct TALER_MERCHANT_ConfigGetHandle *
-TALER_MERCHANT_config_get (struct GNUNET_CURL_Context *ctx,
- const char *backend_url,
- TALER_MERCHANT_ConfigCallback config_cb,
- void *config_cb_cls)
-{
- struct TALER_MERCHANT_ConfigGetHandle *vgh;
- CURL *eh;
-
- vgh = GNUNET_new (struct TALER_MERCHANT_ConfigGetHandle);
- vgh->ctx = ctx;
- vgh->cb = config_cb;
- vgh->cb_cls = config_cb_cls;
- vgh->url = TALER_url_join (backend_url,
- "config",
- NULL);
- if (NULL == vgh->url)
- {
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- "Could not construct request URL.\n");
- GNUNET_free (vgh);
- return NULL;
- }
-
- GNUNET_log (GNUNET_ERROR_TYPE_INFO,
- "Requesting URL '%s'\n",
- vgh->url);
-
- eh = curl_easy_init ();
- GNUNET_assert (CURLE_OK ==
- curl_easy_setopt (eh,
- CURLOPT_URL,
- vgh->url));
-
- vgh->job = GNUNET_CURL_job_add (ctx,
- eh,
- GNUNET_YES,
- &handle_config_finished,
- vgh);
- return vgh;
-}
-
-
-/**
- * Cancel /config request. Must not be called by clients after
- * the callback was invoked.
- *
- * @param vgh request to cancel.
- */
-void
-TALER_MERCHANT_config_get_cancel (struct TALER_MERCHANT_ConfigGetHandle *vgh)
-{
- if (NULL != vgh->job)
- {
- GNUNET_CURL_job_cancel (vgh->job);
- vgh->job = NULL;
- }
- GNUNET_free (vgh->url);
- GNUNET_free (vgh);
-}
-
-
-/* end of merchant_api_config.c */
diff --git a/src/lib/merchant_api_config_get.c b/src/lib/merchant_api_config_get.c
@@ -0,0 +1,254 @@
+/*
+ This file is part of TALER
+ Copyright (C) 2014-2018, 2020 Taler Systems SA
+
+ TALER is free software; you can redistribute it and/or modify it under the
+ terms of the GNU Lesser General Public License as published by the Free Software
+ Foundation; either version 2.1, 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 Lesser General Public License for more details.
+
+ You should have received a copy of the GNU Lesser General Public License along with
+ TALER; see the file COPYING.LGPL. If not, see
+ <http://www.gnu.org/licenses/>
+*/
+/**
+ * @file lib/merchant_api_config_get.c
+ * @brief Implementation of the /config request of the merchant's HTTP API
+ * @author Christian Grothoff
+ */
+#include "platform.h"
+#include <curl/curl.h>
+#include <jansson.h>
+#include <microhttpd.h> /* just for HTTP status codes */
+#include <gnunet/gnunet_util_lib.h>
+#include <gnunet/gnunet_curl_lib.h>
+#include "taler_merchant_service.h"
+#include <taler/taler_json_lib.h>
+#include <taler/taler_signatures.h>
+
+/**
+ * Which version of the Taler protocol is implemented
+ * by this library? Used to determine compatibility.
+ */
+#define MERCHANT_PROTOCOL_CURRENT 0
+
+/**
+ * How many configs are we backwards compatible with?
+ */
+#define MERCHANT_PROTOCOL_AGE 0
+
+
+/**
+ * @brief A handle for /config operations
+ */
+struct TALER_MERCHANT_ConfigGetHandle
+{
+ /**
+ * The url for this request.
+ */
+ char *url;
+
+ /**
+ * Handle for the request.
+ */
+ struct GNUNET_CURL_Job *job;
+
+ /**
+ * Function to call with the result.
+ */
+ TALER_MERCHANT_ConfigCallback cb;
+
+ /**
+ * Closure for @a cb.
+ */
+ void *cb_cls;
+
+ /**
+ * Reference to the execution context.
+ */
+ struct GNUNET_CURL_Context *ctx;
+
+};
+
+
+/**
+ * Function called when we're done processing the
+ * HTTP /config request.
+ *
+ * @param cls the `struct TALER_MERCHANT_ConfigGetHandle`
+ * @param response_code HTTP response code, 0 on error
+ * @param json response body, NULL if not in JSON
+ */
+static void
+handle_config_finished (void *cls,
+ long response_code,
+ const void *response)
+{
+ struct TALER_MERCHANT_ConfigGetHandle *vgh = cls;
+ const json_t *json = response;
+ struct TALER_MERCHANT_HttpResponse hr = {
+ .http_status = (unsigned int) response_code,
+ .reply = json
+ };
+
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Got /config response with status code %u\n",
+ (unsigned int) response_code);
+
+ vgh->job = NULL;
+ switch (response_code)
+ {
+ case MHD_HTTP_OK:
+ {
+ struct TALER_MERCHANT_ConfigInformation vi;
+ enum TALER_MERCHANT_VersionCompatibility vc =
+ TALER_MERCHANT_VC_PROTOCOL_ERROR;
+ struct GNUNET_JSON_Specification spec[] = {
+ GNUNET_JSON_spec_string ("currency",
+ &vi.currency),
+ GNUNET_JSON_spec_string ("version",
+ &vi.version),
+ GNUNET_JSON_spec_end ()
+ };
+
+ if (GNUNET_OK !=
+ GNUNET_JSON_parse (json,
+ spec,
+ NULL, NULL))
+ {
+ hr.http_status = 0;
+ hr.ec = TALER_EC_INVALID_RESPONSE;
+ }
+ else
+ {
+ unsigned int age;
+ unsigned int revision;
+ unsigned int current;
+
+ if (3 != sscanf (vi.version,
+ "%u:%u:%u",
+ ¤t,
+ &revision,
+ &age))
+ {
+ hr.http_status = 0;
+ hr.ec = TALER_EC_INVALID_RESPONSE;
+ }
+ else
+ {
+ vc = TALER_MERCHANT_VC_MATCH;
+ if (MERCHANT_PROTOCOL_CURRENT < current)
+ {
+ vc |= TALER_MERCHANT_VC_NEWER;
+ if (MERCHANT_PROTOCOL_CURRENT < current - age)
+ vc |= TALER_MERCHANT_VC_INCOMPATIBLE;
+ }
+ if (MERCHANT_PROTOCOL_CURRENT > current)
+ {
+ vc |= TALER_MERCHANT_VC_OLDER;
+ if (MERCHANT_PROTOCOL_CURRENT - MERCHANT_PROTOCOL_AGE > current)
+ vc |= TALER_MERCHANT_VC_INCOMPATIBLE;
+ }
+ }
+ }
+ vgh->cb (vgh->cb_cls,
+ &hr,
+ &vi,
+ vc);
+ TALER_MERCHANT_config_get_cancel (vgh);
+ return;
+ }
+ default:
+ /* unexpected response code */
+ 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);
+ vgh->cb (vgh->cb_cls,
+ &hr,
+ NULL,
+ TALER_MERCHANT_VC_PROTOCOL_ERROR);
+ break;
+ }
+ TALER_MERCHANT_config_get_cancel (vgh);
+}
+
+
+/**
+ * Get the config data of a merchant. Will connect to the merchant backend
+ * and obtain information about the backend. The respective information will
+ * be passed to the @a config_cb once available.
+ *
+ * @param ctx the context
+ * @param backend_url HTTP base URL for the backend
+ * @param config_cb function to call with the
+ * backend's config information
+ * @param config_cb_cls closure for @a config_cb
+ * @return the config check handle; NULL upon error
+ */
+struct TALER_MERCHANT_ConfigGetHandle *
+TALER_MERCHANT_config_get (struct GNUNET_CURL_Context *ctx,
+ const char *backend_url,
+ TALER_MERCHANT_ConfigCallback config_cb,
+ void *config_cb_cls)
+{
+ struct TALER_MERCHANT_ConfigGetHandle *vgh;
+ CURL *eh;
+
+ vgh = GNUNET_new (struct TALER_MERCHANT_ConfigGetHandle);
+ vgh->ctx = ctx;
+ vgh->cb = config_cb;
+ vgh->cb_cls = config_cb_cls;
+ vgh->url = TALER_url_join (backend_url,
+ "config",
+ NULL);
+ if (NULL == vgh->url)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Could not construct request URL.\n");
+ GNUNET_free (vgh);
+ return NULL;
+ }
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Requesting URL '%s'\n",
+ vgh->url);
+ eh = curl_easy_init ();
+ GNUNET_assert (CURLE_OK ==
+ curl_easy_setopt (eh,
+ CURLOPT_URL,
+ vgh->url));
+
+ vgh->job = GNUNET_CURL_job_add (ctx,
+ eh,
+ GNUNET_YES,
+ &handle_config_finished,
+ vgh);
+ return vgh;
+}
+
+
+/**
+ * Cancel /config request. Must not be called by clients after
+ * the callback was invoked.
+ *
+ * @param vgh request to cancel.
+ */
+void
+TALER_MERCHANT_config_get_cancel (struct TALER_MERCHANT_ConfigGetHandle *vgh)
+{
+ if (NULL != vgh->job)
+ {
+ GNUNET_CURL_job_cancel (vgh->job);
+ vgh->job = NULL;
+ }
+ GNUNET_free (vgh->url);
+ GNUNET_free (vgh);
+}
+
+
+/* end of merchant_api_config_get.c */
diff --git a/src/lib/merchant_api_instances_get.c b/src/lib/merchant_api_instances_get.c
@@ -0,0 +1,292 @@
+/*
+ This file is part of TALER
+ Copyright (C) 2014-2018, 2020 Taler Systems SA
+
+ TALER is free software; you can redistribute it and/or modify it under the
+ terms of the GNU Lesser General Public License as published by the Free Software
+ Foundation; either version 2.1, 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 Lesser General Public License for more details.
+
+ You should have received a copy of the GNU Lesser General Public License along with
+ TALER; see the file COPYING.LGPL. If not, see
+ <http://www.gnu.org/licenses/>
+*/
+/**
+ * @file lib/merchant_api_instances_get.c
+ * @brief Implementation of the GET /instances request of the merchant's HTTP API
+ * @author Christian Grothoff
+ */
+#include "platform.h"
+#include <curl/curl.h>
+#include <jansson.h>
+#include <microhttpd.h> /* just for HTTP status codes */
+#include <gnunet/gnunet_util_lib.h>
+#include <gnunet/gnunet_curl_lib.h>
+#include "taler_merchant_service.h"
+#include <taler/taler_json_lib.h>
+#include <taler/taler_signatures.h>
+
+
+/**
+ * Handle for a GET /instances operation.
+ */
+struct TALER_MERCHANT_InstancesGetHandle
+{
+ /**
+ * The url for this request.
+ */
+ char *url;
+
+ /**
+ * Handle for the request.
+ */
+ struct GNUNET_CURL_Job *job;
+
+ /**
+ * Function to call with the result.
+ */
+ TALER_MERCHANT_InstancesCallback cb;
+
+ /**
+ * Closure for @a cb.
+ */
+ void *cb_cls;
+
+ /**
+ * Reference to the execution context.
+ */
+ struct GNUNET_CURL_Context *ctx;
+
+};
+
+
+/**
+ * Parse instance information from @a ia.
+ *
+ * @param ia JSON array (or NULL!) with instance data
+ * @param igh operation handle
+ * @return #GNUNET_OK on success
+ */
+static int
+parse_instances (const json_t *ia,
+ struct TALER_MERCHANT_InstancesGetHandle *igh)
+{
+ unsigned int iis_len = json_array_size (ia);
+ struct TALER_MERCHANT_InstanceInformation iis[iis_len];
+ size_t index;
+ json_t *value;
+ int ret;
+
+ ret = GNUNET_OK;
+ json_array_foreach (ia, index, value) {
+ struct TALER_MERCHANT_InstanceInformation *ii = &iis[index];
+ struct GNUNET_JSON_Specification spec[] = {
+ GNUNET_JSON_spec_string ("name",
+ &ii->name),
+ GNUNET_JSON_spec_string ("instance",
+ &ii->id),
+ GNUNET_JSON_spec_fixed_auto ("merchant_pub",
+ &ii->merchant_pub),
+ GNUNET_JSON_spec_json ("payment_targets",
+ &ii->payment_targets),
+ GNUNET_JSON_spec_end ()
+ };
+
+ if (GNUNET_OK !=
+ GNUNET_JSON_parse (value,
+ spec,
+ NULL, NULL))
+ {
+ GNUNET_break_op (0);
+ ret = GNUNET_SYSERR;
+ continue;
+ }
+ if (! json_is_array (ii->payment_targets))
+ {
+ GNUNET_break_op (0);
+ ret = GNUNET_SYSERR;
+ break;
+ }
+ for (unsigned int i = 0; i<json_array_size (ii->payment_targets); i++)
+ {
+ if (! json_is_string (json_array_get (ii->payment_targets,
+ i)))
+ {
+ GNUNET_break_op (0);
+ ret = GNUNET_SYSERR;
+ break;
+ }
+ }
+ if (GNUNET_SYSERR == ret)
+ break;
+ }
+ if (GNUNET_OK == ret)
+ {
+ struct TALER_MERCHANT_HttpResponse hr = {
+ .http_status = MHD_HTTP_OK
+ };
+
+ igh->cb (igh->cb_cls,
+ &hr,
+ iis_len,
+ iis);
+ igh->cb = NULL; /* just to be sure */
+ }
+ for (unsigned int i = 0; i<iis_len; i++)
+ if (NULL != iis[i].payment_targets)
+ json_decref (iis[i].payment_targets);
+ return ret;
+}
+
+
+/**
+ * Function called when we're done processing the
+ * HTTP /instances request.
+ *
+ * @param cls the `struct TALER_MERCHANT_InstancesGetHandle`
+ * @param response_code HTTP response code, 0 on error
+ * @param json response body, NULL if not in JSON
+ */
+static void
+handle_instances_finished (void *cls,
+ long response_code,
+ const void *response)
+{
+ struct TALER_MERCHANT_InstancesGetHandle *igh = cls;
+ const json_t *json = response;
+ struct TALER_MERCHANT_HttpResponse hr = {
+ .http_status = (unsigned int) response_code,
+ .reply = json
+ };
+
+ igh->job = NULL;
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Got /instances response with status code %u\n",
+ (unsigned int) response_code);
+ switch (response_code)
+ {
+ case MHD_HTTP_OK:
+ {
+ json_t *instances;
+ struct GNUNET_JSON_Specification spec[] = {
+ GNUNET_JSON_spec_json ("instances",
+ &instances),
+ GNUNET_JSON_spec_end ()
+ };
+
+ if (GNUNET_OK !=
+ GNUNET_JSON_parse (json,
+ spec,
+ NULL, NULL))
+ {
+ hr.http_status = 0;
+ hr.ec = TALER_EC_INVALID_RESPONSE;
+ }
+ else
+ {
+ if ( (! json_is_array (instances)) ||
+ (GNUNET_OK ==
+ parse_instances (instances,
+ igh)) )
+ {
+ GNUNET_JSON_parse_free (spec);
+ TALER_MERCHANT_instances_get_cancel (igh);
+ return;
+ }
+ else
+ {
+ hr.http_status = 0;
+ hr.ec = TALER_EC_INVALID_RESPONSE;
+ }
+ }
+ GNUNET_JSON_parse_free (spec);
+ break;
+ }
+ default:
+ /* unexpected response code */
+ 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;
+ }
+ igh->cb (igh->cb_cls,
+ &hr,
+ 0,
+ NULL);
+ TALER_MERCHANT_instances_get_cancel (igh);
+}
+
+
+/**
+ * Get the instance data of a backend. Will connect to the merchant backend
+ * and obtain information about the instances. The respective information will
+ * be passed to the @a instances_cb once available.
+ *
+ * @param ctx the context
+ * @param backend_url HTTP base URL for the backend
+ * @param instances_cb function to call with the
+ * backend's instances information
+ * @param instances_cb_cls closure for @a config_cb
+ * @return the instances handle; NULL upon error
+ */
+struct TALER_MERCHANT_InstancesGetHandle *
+TALER_MERCHANT_instances_get (struct GNUNET_CURL_Context *ctx,
+ const char *backend_url,
+ TALER_MERCHANT_InstancesCallback instances_cb,
+ void *instances_cb_cls)
+{
+ struct TALER_MERCHANT_InstancesGetHandle *igh;
+ CURL *eh;
+
+ igh = GNUNET_new (struct TALER_MERCHANT_InstancesGetHandle);
+ igh->ctx = ctx;
+ igh->cb = instances_cb;
+ igh->cb_cls = instances_cb_cls;
+ igh->url = TALER_url_join (backend_url,
+ "instances",
+ NULL);
+ if (NULL == igh->url)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Could not construct request URL.\n");
+ GNUNET_free (igh);
+ return NULL;
+ }
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Requesting URL '%s'\n",
+ igh->url);
+ eh = curl_easy_init ();
+ GNUNET_assert (CURLE_OK ==
+ curl_easy_setopt (eh,
+ CURLOPT_URL,
+ igh->url));
+ igh->job = GNUNET_CURL_job_add (ctx,
+ eh,
+ GNUNET_YES,
+ &handle_instances_finished,
+ igh);
+ return igh;
+}
+
+
+/**
+ * Cancel /instances request. Must not be called by clients after
+ * the callback was invoked.
+ *
+ * @param igh request to cancel.
+ */
+void
+TALER_MERCHANT_instances_get_cancel (
+ struct TALER_MERCHANT_InstancesGetHandle *igh)
+{
+ if (NULL != igh->job)
+ GNUNET_CURL_job_cancel (igh->job);
+ GNUNET_free (igh->url);
+ GNUNET_free (igh);
+}
