add missing kyc url for manual withdrawal and add support for 451 case: aml-required

1 files changed, 17 insertions, 2 deletions

diff --git a/packages/taler-wallet-core/src/operations/withdraw.ts b/packages/taler-wallet-core/src/operations/withdraw.ts
index a56a1a100..a1cb29e07 100644
--- a/packages/taler-wallet-core/src/operations/withdraw.ts
+++ b/packages/taler-wallet-core/src/operations/withdraw.ts
@@ -725,6 +725,9 @@ interface WithdrawalBatchResult {
   coinIdxs: number[];
   batchResp: ExchangeWithdrawBatchResponse;
 }
+enum AmlStatus {
+  normal= 0, pending = 1, fronzen = 2,
+}
 
 async function handleKycRequired(
   ws: InternalWalletState,
@@ -757,6 +760,7 @@ async function handleKycRequired(
     method: "GET",
   });
   let kycUrl: string;
+  let amlStatus: AmlStatus | undefined;
   if (
     kycStatusRes.status === HttpStatusCode.Ok ||
     //FIXME: NoContent is not expected https://docs.taler.net/core/api-exchange.html#post--purses-$PURSE_PUB-merge
@@ -769,6 +773,10 @@ async function handleKycRequired(
     const kycStatus = await kycStatusRes.json();
     logger.info(`kyc status: ${j2s(kycStatus)}`);
     kycUrl = kycStatus.kyc_url;
+  } else if (kycStatusRes.status === HttpStatusCode.UnavailableForLegalReasons) {
+    const kycStatus = await kycStatusRes.json();
+    logger.info(`aml status: ${j2s(kycStatus)}`);
+    amlStatus = kycStatus.aml_status;
   } else {
     throw Error(`unexpected response from kyc-check (${kycStatusRes.status})`);
   }
@@ -801,7 +809,11 @@ async function handleKycRequired(
             requirementRow: uuidResp.requirement_row,
           };
           wg2.kycUrl = kycUrl;
-          wg2.status = WithdrawalGroupStatus.PendingKyc;
+          wg2.status = amlStatus === AmlStatus.normal || amlStatus === undefined ? WithdrawalGroupStatus.PendingKyc :
+            amlStatus === AmlStatus.pending ? WithdrawalGroupStatus.PendingAml :
+            amlStatus === AmlStatus.fronzen ? WithdrawalGroupStatus.SuspendedAml :
+            assertUnreachable(amlStatus); 
+          
           await tx.withdrawalGroups.put(wg2);
           const newTxState = computeWithdrawalTransactionStatus(wg2);
           return {
@@ -1428,7 +1440,6 @@ async function processWithdrawalGroupPendingKyc(
   url.searchParams.set("timeout_ms", "30000");
 
   const retryTag = TaskIdentifiers.forWithdrawal(withdrawalGroup);
-
   runLongpollAsync(ws, retryTag, async (cancellationToken) => {
     logger.info(`long-polling for withdrawal KYC status via ${url.href}`);
     const kycStatusRes = await ws.http.fetch(url.href, {
@@ -1451,6 +1462,10 @@ async function processWithdrawalGroupPendingKyc(
       logger.info(`kyc status: ${j2s(kycStatus)}`);
       // FIXME: do we need to update the KYC url, or does it always stay constant?
       return { ready: false };
+    } else if (kycStatusRes.status === HttpStatusCode.UnavailableForLegalReasons) {
+      const kycStatus = await kycStatusRes.json();
+      logger.info(`aml status: ${j2s(kycStatus)}`);
+      return {ready : false}
     } else {
       throw Error(
         `unexpected response from kyc-check (${kycStatusRes.status})`,