1 files changed, 44 insertions, 10 deletions

diff --git a/src/exchange/taler-exchange-httpd_kyc-webhook.c b/src/exchange/taler-exchange-httpd_kyc-webhook.c
index 415e5de9a..b92b43e69 100644
--- a/src/exchange/taler-exchange-httpd_kyc-webhook.c
+++ b/src/exchange/taler-exchange-httpd_kyc-webhook.c
@@ -221,12 +221,38 @@ webhook_finished_cb (
       kwh);
     if (NULL == kwh->kat)
     {
-      http_status = MHD_HTTP_INTERNAL_SERVER_ERROR;
       if (NULL != response)
         MHD_destroy_response (response);
+      http_status = MHD_HTTP_INTERNAL_SERVER_ERROR;
       response = TALER_MHD_make_error (
         TALER_EC_EXCHANGE_GENERIC_BAD_CONFIGURATION,
         "[exchange] AML_KYC_TRIGGER");
+      break;
+    }
+    return;
+  case TALER_KYCLOGIC_STATUS_FAILED:
+  case TALER_KYCLOGIC_STATUS_PROVIDER_FAILED:
+  case TALER_KYCLOGIC_STATUS_USER_ABORTED:
+  case TALER_KYCLOGIC_STATUS_ABORTED:
+    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+                "KYC process %s/%s (Row #%llu) failed: %d\n",
+                provider_user_id,
+                provider_legitimization_id,
+                (unsigned long long) process_row,
+                status);
+    if (! TEH_kyc_failed (process_row,
+                          account_id,
+                          provider_section,
+                          provider_user_id,
+                          provider_legitimization_id))
+    {
+      GNUNET_break (0);
+      if (NULL != response)
+        MHD_destroy_response (response);
+      http_status = MHD_HTTP_INTERNAL_SERVER_ERROR;
+      response = TALER_MHD_make_error (
+        TALER_EC_GENERIC_DB_STORE_FAILED,
+        "insert_kyc_failure");
     }
     break;
   default:
@@ -235,13 +261,13 @@ webhook_finished_cb (
                 provider_user_id,
                 provider_legitimization_id,
                 (unsigned long long) process_row,
-                status);
+                (int) status);
     break;
   }
-  if (NULL == kwh->kat)
-    kyc_aml_webhook_finished (kwh,
-                              http_status,
-                              response);
+  GNUNET_break (NULL == kwh->kat);
+  kyc_aml_webhook_finished (kwh,
+                            http_status,
+                            response);
 }
 
 
@@ -314,6 +340,10 @@ handler_kyc_webhook_generic (
                                          TALER_EC_EXCHANGE_KYC_GENERIC_LOGIC_UNKNOWN,
                                          args[0]);
     }
+    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+                "KYC logic `%s' mapped to section %s\n",
+                args[0],
+                kwh->provider_section);
     kwh->wh = kwh->plugin->webhook (kwh->plugin->cls,
                                     kwh->pd,
                                     TEH_plugin->kyc_provider_account_lookup,
@@ -339,13 +369,17 @@ handler_kyc_webhook_generic (
     MHD_suspend_connection (rc->connection);
     return MHD_YES;
   }
+  GNUNET_break (GNUNET_NO == kwh->suspended);
 
   if (NULL != kwh->response)
   {
-    /* handle _failed_ resumed cases */
-    return MHD_queue_response (rc->connection,
-                               kwh->response_code,
-                               kwh->response);
+    MHD_RESULT res;
+
+    res = MHD_queue_response (rc->connection,
+                              kwh->response_code,
+                              kwh->response);
+    GNUNET_break (MHD_YES == res);
+    return res;
   }
 
   /* We resumed, but got no response? This should