diff options
| author | Christian Grothoff <christian@grothoff.org> | 2021-11-09 15:39:31 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2021-11-09 15:39:31 +0100 |
| commit | a9b2140b1ece806847aa45a6b95a959c9ddaa7bf (patch) | |
| tree | 1e99fa21fa001dac1aa9934830c0fd3f2c84b26a /src/exchange/taler-exchange-httpd_kyc-proof.c | |
| parent | a79cc16067285cee7de72d889eaf8152cc17739d (diff) | |
| download | exchange-a9b2140b1ece806847aa45a6b95a959c9ddaa7bf.tar.gz exchange-a9b2140b1ece806847aa45a6b95a959c9ddaa7bf.tar.bz2 exchange-a9b2140b1ece806847aa45a6b95a959c9ddaa7bf.zip | |
get first KYC test to pass
Diffstat (limited to 'src/exchange/taler-exchange-httpd_kyc-proof.c')
| -rw-r--r-- | src/exchange/taler-exchange-httpd_kyc-proof.c | 43 |
1 files changed, 26 insertions, 17 deletions
diff --git a/src/exchange/taler-exchange-httpd_kyc-proof.c b/src/exchange/taler-exchange-httpd_kyc-proof.c index 842e5dfd2..fdf5ade54 100644 --- a/src/exchange/taler-exchange-httpd_kyc-proof.c +++ b/src/exchange/taler-exchange-httpd_kyc-proof.c @@ -108,6 +108,24 @@ static struct KycProofContext *kpc_head; static struct KycProofContext *kpc_tail; +/** + * Resume processing the @a kpc request. + * + * @param kpc request to resume + */ +static void +kpc_resume (struct KycProofContext *kpc) +{ + GNUNET_assert (GNUNET_YES == kpc->suspended); + kpc->suspended = GNUNET_NO; + GNUNET_CONTAINER_DLL_remove (kpc_head, + kpc_tail, + kpc); + MHD_resume_connection (kpc->rc->connection); + TALER_MHD_daemon_trigger (); +} + + void TEH_kyc_proof_cleanup (void) { @@ -120,11 +138,7 @@ TEH_kyc_proof_cleanup (void) GNUNET_CURL_job_cancel (kpc->job); kpc->job = NULL; } - GNUNET_CONTAINER_DLL_remove (kpc_head, - kpc_tail, - kpc); - kpc->suspended = GNUNET_NO; - MHD_resume_connection (kpc->rc->connection); + kpc_resume (kpc); } } @@ -210,8 +224,7 @@ handle_curl_login_finished (void *cls, "Unexpected response from KYC gateway"); kpc->response_code = MHD_HTTP_BAD_GATEWAY; - MHD_resume_connection (kpc->rc->connection); - TALER_MHD_daemon_trigger (); + kpc_resume (kpc); return; } } @@ -225,8 +238,7 @@ handle_curl_login_finished (void *cls, "Unexpected token type in response from KYC gateway"); kpc->response_code = MHD_HTTP_BAD_GATEWAY; - MHD_resume_connection (kpc->rc->connection); - TALER_MHD_daemon_trigger (); + kpc_resume (kpc); return; } @@ -234,8 +246,7 @@ handle_curl_login_finished (void *cls, possibly use the access_token to download information we should persist; then continue! */ - MHD_resume_connection (kpc->rc->connection); - TALER_MHD_daemon_trigger (); + kpc_resume (kpc); return; } default: @@ -268,8 +279,7 @@ handle_curl_login_finished (void *cls, "Unexpected response from KYC gateway"); kpc->response_code = MHD_HTTP_BAD_GATEWAY; - MHD_resume_connection (kpc->rc->connection); - TALER_MHD_daemon_trigger (); + kpc_resume (kpc); return; } } @@ -292,8 +302,7 @@ handle_curl_login_finished (void *cls, GNUNET_free (reply); } kpc->response_code = MHD_HTTP_FORBIDDEN; - MHD_resume_connection (kpc->rc->connection); - TALER_MHD_daemon_trigger (); + kpc_resume (kpc); } break; } @@ -387,7 +396,7 @@ TEH_handler_kyc_proof ( "curl_easy_init"); } GNUNET_asprintf (&kpc->token_url, - "%s/token", + "%stoken", TEH_kyc_config.details.oauth2.url); GNUNET_assert (CURLE_OK == curl_easy_setopt (eh, @@ -411,7 +420,7 @@ TEH_handler_kyc_proof ( char *request_uri; GNUNET_asprintf (&request_uri, - "%s/login?client_id=%s", + "%slogin?client_id=%s", TEH_kyc_config.details.oauth2.url, TEH_kyc_config.details.oauth2.client_id); redirect_uri = curl_easy_escape (eh, |