aboutsummaryrefslogtreecommitdiff
path: root/src/kyclogic
diff options
context:
space:
mode:
Diffstat (limited to 'src/kyclogic')
-rw-r--r--src/kyclogic/Makefile.am1
-rw-r--r--src/kyclogic/plugin_kyclogic_kycaid.c332
-rw-r--r--src/kyclogic/taler-exchange-kyc-tester.c6
3 files changed, 29 insertions, 310 deletions
diff --git a/src/kyclogic/Makefile.am b/src/kyclogic/Makefile.am
index 9f034731c..c77abd876 100644
--- a/src/kyclogic/Makefile.am
+++ b/src/kyclogic/Makefile.am
@@ -84,7 +84,6 @@ libtaler_plugin_kyclogic_kycaid_la_LDFLAGS = \
$(TALER_PLUGIN_LDFLAGS) \
$(top_builddir)/src/json/libtalerjson.la \
$(top_builddir)/src/curl/libtalercurl.la \
- $(top_builddir)/src/templating/libtalertemplating.la \
$(top_builddir)/src/util/libtalerutil.la \
-lgnunetutil \
-ljansson \
diff --git a/src/kyclogic/plugin_kyclogic_kycaid.c b/src/kyclogic/plugin_kyclogic_kycaid.c
index 2ebbe986c..933c0d353 100644
--- a/src/kyclogic/plugin_kyclogic_kycaid.c
+++ b/src/kyclogic/plugin_kyclogic_kycaid.c
@@ -23,7 +23,6 @@
#include "taler_mhd_lib.h"
#include "taler_curl_lib.h"
#include "taler_json_lib.h"
-#include "taler_templating_lib.h"
#include <regex.h>
#include "taler_util.h"
@@ -182,19 +181,14 @@ struct TALER_KYCLOGIC_ProofHandle
void *cb_cls;
/**
- * Handle for the request.
- */
- struct GNUNET_CURL_Job *job;
-
- /**
- * URL of the cURL request.
+ * Connection we are handling.
*/
- char *url;
+ struct MHD_Connection *connection;
/**
- * Connection we are handling.
+ * Task for asynchronous execution.
*/
- struct MHD_Connection *connection;
+ struct GNUNET_SCHEDULER_Task *task;
};
@@ -631,289 +625,41 @@ kycaid_initiate (void *cls,
static void
kycaid_proof_cancel (struct TALER_KYCLOGIC_ProofHandle *ph)
{
- if (NULL != ph->job)
+ if (NULL != ph->task)
{
- GNUNET_CURL_job_cancel (ph->job);
- ph->job = NULL;
+ GNUNET_SCHEDULER_cancel (ph->task);
+ ph->task = NULL;
}
- GNUNET_free (ph->url);
GNUNET_free (ph);
}
/**
- * Call @a ph callback with HTTP response generated
- * from @a template_name using the given @a template_data.
+ * Call @a ph callback with HTTP error response.
*
- * @param ph proof handle to generate reply for
- * @param http_status http response status to use
- * @param template_name template to load and return
- * @param[in] template_data data for the template, freed by this function!
+ * @param cls proof handle to generate reply for
*/
static void
-proof_reply_with_template (struct TALER_KYCLOGIC_ProofHandle *ph,
- unsigned int http_status,
- const char *template_name,
- json_t *template_data)
+proof_reply (void *cls)
{
- enum GNUNET_GenericReturnValue ret;
+ struct TALER_KYCLOGIC_ProofHandle *ph = cls;
struct MHD_Response *resp;
- ret = TALER_TEMPLATING_build (ph->connection,
- &http_status,
- template_name,
- NULL, /* no instance */
- NULL, /* no Taler URI */
- template_data,
- &resp);
- json_decref (template_data);
- if (GNUNET_SYSERR == ret)
- http_status = 0;
+ resp = TALER_MHD_make_error (TALER_EC_GENERIC_ENDPOINT_UNKNOWN,
+ "there is no '/kyc-proof' for kycaid");
ph->cb (ph->cb_cls,
TALER_KYCLOGIC_STATUS_PROVIDER_FAILED,
NULL, /* user id */
NULL, /* provider legi ID */
GNUNET_TIME_UNIT_ZERO_ABS, /* expiration */
- http_status,
+ MHD_HTTP_BAD_REQUEST,
resp);
}
/**
- * Function called when we're done processing the
- * HTTP "/verifications/{verification_id}" request.
- *
- * @param cls the `struct TALER_KYCLOGIC_ProofHandle`
- * @param response_code HTTP response code, 0 on error
- * @param response parsed JSON result, NULL on error
- */
-static void
-handle_proof_finished (void *cls,
- long response_code,
- const void *response)
-{
- struct TALER_KYCLOGIC_ProofHandle *ph = cls;
- const json_t *j = response;
- struct MHD_Response *resp;
-
- ph->job = NULL;
- switch (response_code)
- {
- case MHD_HTTP_OK:
- {
- const char *applicant_id;
- const char *verification_id;
- bool verified;
- json_t *verifications;
- struct GNUNET_JSON_Specification spec[] = {
- GNUNET_JSON_spec_string ("applicant_id",
- &applicant_id),
- GNUNET_JSON_spec_string ("verification_id",
- &verification_id),
- GNUNET_JSON_spec_bool ("verified",
- &verified),
- GNUNET_JSON_spec_json ("verifications",
- &verifications),
- GNUNET_JSON_spec_end ()
- };
- struct GNUNET_TIME_Absolute expiration;
-
- if (GNUNET_OK !=
- GNUNET_JSON_parse (j,
- spec,
- NULL, NULL))
- {
- json_t *template_data;
-
- GNUNET_break_op (0);
- json_dumpf (j,
- stderr,
- JSON_INDENT (2));
- template_data = GNUNET_JSON_PACK (
- GNUNET_JSON_pack_object_incref ("kyc_server_reply",
- (json_t *) j));
- proof_reply_with_template (ph,
- MHD_HTTP_BAD_GATEWAY,
- "bad_gateway",
- template_data);
- break;
- }
- /* FIXME: comment out, unless debugging ... */
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "The provider returned the following verifications:\n");
- json_dumpf (verifications,
- stderr,
- JSON_INDENT (2));
- if (verified)
- {
- // FIXME: or should we return an empty body? Redirect?
- resp = TALER_MHD_make_json_steal (json_object ());
- // FIXME: setup redirect?
- expiration = GNUNET_TIME_relative_to_absolute (ph->pd->validity);
- ph->cb (ph->cb_cls,
- TALER_KYCLOGIC_STATUS_SUCCESS,
- applicant_id,
- verification_id,
- expiration,
- MHD_HTTP_OK, // OK, or redirect???
- resp);
- }
- else
- {
- json_t *template_data;
-
- GNUNET_break_op (0);
- json_dumpf (j,
- stderr,
- JSON_INDENT (2));
- template_data = GNUNET_JSON_PACK (
- GNUNET_JSON_pack_string ("kyc_logic",
- "kycaid"),
- GNUNET_JSON_pack_object_incref ("verifiations",
- (json_t *) verifications));
- proof_reply_with_template (ph,
- MHD_HTTP_OK,
- "kyc_user_failed",
- template_data);
- }
- GNUNET_JSON_parse_free (spec);
- }
- break;
- case MHD_HTTP_BAD_REQUEST:
- case MHD_HTTP_NOT_FOUND:
- case MHD_HTTP_CONFLICT:
- case MHD_HTTP_UNPROCESSABLE_ENTITY: /* validation */
- {
- json_t *template_data;
-
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- "KYCAID failed with response %u:\n",
- (unsigned int) response_code);
- json_dumpf (j,
- stderr,
- JSON_INDENT (2));
- template_data = GNUNET_JSON_PACK (
- GNUNET_JSON_pack_uint64 ("kyc_http_status",
- response_code),
- GNUNET_JSON_pack_string ("kyc_logic",
- "kycaid"),
- GNUNET_JSON_pack_object_incref ("kyc_server_reply",
- (json_t *) j));
- proof_reply_with_template (ph,
- MHD_HTTP_INTERNAL_SERVER_ERROR,
- "kyc_interaction_failed",
- template_data);
- break;
- }
- case MHD_HTTP_UNAUTHORIZED:
- {
- json_t *template_data;
-
- template_data = GNUNET_JSON_PACK (
- GNUNET_JSON_pack_uint64 ("kyc_http_status",
- response_code),
- GNUNET_JSON_pack_string ("kyc_logic",
- "kycaid"),
- GNUNET_JSON_pack_object_incref ("kyc_server_reply",
- (json_t *) j));
- proof_reply_with_template (ph,
- MHD_HTTP_INTERNAL_SERVER_ERROR,
- "kyc_provider_unauthorized",
- template_data);
- break;
- }
- case MHD_HTTP_PAYMENT_REQUIRED:
- {
- json_t *template_data;
-
- template_data = GNUNET_JSON_PACK (
- GNUNET_JSON_pack_uint64 ("kyc_http_status",
- response_code),
- GNUNET_JSON_pack_string ("kyc_logic",
- "kycaid"),
- GNUNET_JSON_pack_object_incref ("kyc_server_reply",
- (json_t *) j));
- proof_reply_with_template (ph,
- MHD_HTTP_INTERNAL_SERVER_ERROR,
- "kyc_provider_unpaid",
- template_data);
- break;
- }
- case MHD_HTTP_REQUEST_TIMEOUT:
- {
- json_t *template_data;
-
- template_data = GNUNET_JSON_PACK (
- GNUNET_JSON_pack_uint64 ("kyc_http_status",
- response_code),
- GNUNET_JSON_pack_string ("kyc_logic",
- "kycaid"),
- GNUNET_JSON_pack_object_incref ("kyc_server_reply",
- (json_t *) j));
- proof_reply_with_template (ph,
- MHD_HTTP_INTERNAL_SERVER_ERROR,
- "kyc_provider_timeout",
- template_data);
- break;
- }
- case MHD_HTTP_TOO_MANY_REQUESTS:
- {
- json_t *template_data;
-
- template_data = GNUNET_JSON_PACK (
- GNUNET_JSON_pack_uint64 ("kyc_http_status",
- response_code),
- GNUNET_JSON_pack_string ("kyc_logic",
- "kycaid"),
- GNUNET_JSON_pack_object_incref ("kyc_server_reply",
- (json_t *) j));
- proof_reply_with_template (ph,
- MHD_HTTP_INTERNAL_SERVER_ERROR,
- "kyc_provider_ratelimit",
- template_data);
- break;
- }
- case MHD_HTTP_INTERNAL_SERVER_ERROR:
- {
- json_t *template_data;
-
- template_data = GNUNET_JSON_PACK (
- GNUNET_JSON_pack_uint64 ("kyc_http_status",
- response_code),
- GNUNET_JSON_pack_string ("kyc_logic",
- "kycaid"),
- GNUNET_JSON_pack_object_incref ("kyc_server_reply",
- (json_t *) j));
- proof_reply_with_template (ph,
- MHD_HTTP_INTERNAL_SERVER_ERROR,
- "kyc_provider_internal_error",
- template_data);
- break;
- }
- default:
- {
- json_t *template_data;
-
- template_data = GNUNET_JSON_PACK (
- GNUNET_JSON_pack_uint64 ("kyc_http_status",
- response_code),
- GNUNET_JSON_pack_string ("kyc_logic",
- "kycaid"),
- GNUNET_JSON_pack_object_incref ("kyc_server_reply",
- (json_t *) j));
- proof_reply_with_template (ph,
- MHD_HTTP_INTERNAL_SERVER_ERROR,
- "kyc_provider_unexpected_reply",
- template_data);
- break;
- }
- }
- kycaid_proof_cancel (ph);
-}
-
-
-/**
- * Check KYC status and return status to human.
+ * Check KYC status and return status to human. Not
+ * used by KYC AID!
*
* @param cls the @e cls of this struct with the plugin-specific state
* @param pd provider configuration details
@@ -941,14 +687,6 @@ kycaid_proof (void *cls,
{
struct PluginState *ps = cls;
struct TALER_KYCLOGIC_ProofHandle *ph;
- CURL *eh;
-
- eh = curl_easy_init ();
- if (NULL == eh)
- {
- GNUNET_break (0);
- return NULL;
- }
ph = GNUNET_new (struct TALER_KYCLOGIC_ProofHandle);
ph->ps = ps;
@@ -956,27 +694,8 @@ kycaid_proof (void *cls,
ph->cb = cb;
ph->cb_cls = cb_cls;
ph->connection = connection;
- GNUNET_asprintf (&ph->url,
- "https://api.kycaid.com/verifications/%s",
- provider_legitimization_id);
- GNUNET_break (CURLE_OK ==
- curl_easy_setopt (eh,
- CURLOPT_VERBOSE,
- 1));
- GNUNET_assert (CURLE_OK ==
- curl_easy_setopt (eh,
- CURLOPT_MAXREDIRS,
- 1L));
- GNUNET_break (CURLE_OK ==
- curl_easy_setopt (eh,
- CURLOPT_URL,
- ph->url));
- ph->job = GNUNET_CURL_job_add (ps->curl_ctx,
- eh,
- &handle_proof_finished,
- ph);
- GNUNET_CURL_extend_headers (ph->job,
- pd->slist);
+ ph->task = GNUNET_SCHEDULER_add_now (&proof_reply,
+ ph);
return ph;
}
@@ -1029,6 +748,8 @@ handle_webhook_finished (void *cls,
{
const char *applicant_id;
const char *verification_id;
+ const char *status;
+ const char *type;
bool verified;
json_t *verifications;
struct GNUNET_JSON_Specification spec[] = {
@@ -1036,6 +757,10 @@ handle_webhook_finished (void *cls,
&applicant_id),
GNUNET_JSON_spec_string ("verification_id",
&verification_id),
+ GNUNET_JSON_spec_string ("type",
+ &type),
+ GNUNET_JSON_spec_string ("status",
+ &status),
GNUNET_JSON_spec_bool ("verified",
&verified),
GNUNET_JSON_spec_json ("verifications",
@@ -1075,9 +800,11 @@ handle_webhook_finished (void *cls,
json_dumpf (verifications,
stderr,
JSON_INDENT (2));
+ resp = MHD_create_response_from_buffer (0,
+ "",
+ MHD_RESPMEM_PERSISTENT);
if (verified)
{
- resp = TALER_MHD_make_json_steal (json_object ());
expiration = GNUNET_TIME_relative_to_absolute (wh->pd->validity);
wh->cb (wh->cb_cls,
wh->legi_row,
@@ -1086,12 +813,11 @@ handle_webhook_finished (void *cls,
wh->verification_id,
TALER_KYCLOGIC_STATUS_SUCCESS,
expiration,
- MHD_HTTP_OK,
+ MHD_HTTP_NO_CONTENT,
resp);
}
else
{
- resp = TALER_MHD_make_json_steal (json_object ());
wh->cb (wh->cb_cls,
wh->legi_row,
&wh->h_payto,
@@ -1099,7 +825,7 @@ handle_webhook_finished (void *cls,
wh->verification_id,
TALER_KYCLOGIC_STATUS_USER_ABORTED,
GNUNET_TIME_UNIT_ZERO_ABS,
- MHD_HTTP_OK,
+ MHD_HTTP_NO_CONTENT,
resp);
}
GNUNET_JSON_parse_free (spec);
diff --git a/src/kyclogic/taler-exchange-kyc-tester.c b/src/kyclogic/taler-exchange-kyc-tester.c
index 740fcda7a..2f3fa561c 100644
--- a/src/kyclogic/taler-exchange-kyc-tester.c
+++ b/src/kyclogic/taler-exchange-kyc-tester.c
@@ -1458,12 +1458,6 @@ main (int argc,
"initiate KYC check using provider configured in SECTION_NAME of the configuration",
&initiate_section),
GNUNET_GETOPT_option_string (
- 'i',
- "initiate",
- "SECTION_NAME",
- "initiate KYC check using provider configured in SECTION_NAME of the configuration",
- &initiate_section),
- GNUNET_GETOPT_option_string (
'u',
"user",
"ID",
generated by cgit v1.2.3 (git 2.26.2) at 2024-11-19 20:56:37 +0000