feat(wallet-backend): handle manual approve flow (#1752)

* feat(wallet-backend): gatehub userState is now stored on wallet User even if it was manually approved
log user connected to gateway

* chore(wallet/backend): move log

* chore(wallet/backend): format

* chore(wallet/backend): format

* chore(wallet/backend): format

* fix(wallet/backend): eslint no-case-declarations (add block to switch case)

* fix(wallet/backend): change wh triggered addUserToGateway condition

* feat(wallet/backend): keep drop firstName condition

Author: beniaminmunteanu

packages/wallet/backend/src/gatehub/controller.ts

@@ -33,10 +33,10 @@ export class GateHubController implements IGateHubController {
   ) => {
     try {
       const userId = req.session.user.id
-      const { isUserApproved, customerId } =
+      const { isApproved, customerId } =
         await this.gateHubService.addUserToGateway(userId)
 
-      if (isUserApproved) {
+      if (isApproved) {
         req.session.user.needsIDProof = false
       }
 

packages/wallet/backend/src/gatehub/service.ts

@@ -39,23 +39,42 @@ export class GateHubService {
     this.logger.debug(`GateHub webhook event received: ${JSON.stringify(data)}`)
     // TODO: handle other webhook types
     switch (data.event_type) {
-      case 'id.verification.accepted':
-        await this.markUserAsVerified(data.user_uuid)
+      case 'id.verification.accepted': {
+        const gateHubUserId = data.user_uuid
+        const user = await User.query().findOne({ gateHubUserId })
+
+        // if user is already verified (for manual verify cases)
+        // we skip the approveUserToGateway and overrideRiskLevel in addUserToGateway
+        // but still execute the function in order to store gatehub userState
+        if (user && !user.kycVerified && !user.lastName) {
+          await this.addUserToGateway(gateHubUserId, true)
+        }
+
+        await this.markUserAsVerified(gateHubUserId)
+
         break
+      }
     }
   }
 
   async addUserToGateway(
-    userId: string
-  ): Promise<{ isUserApproved: boolean; customerId?: string }> {
+    userId: string,
+    isApproved = false
+  ): Promise<{ isApproved: boolean; customerId?: string }> {
     const user = await User.query().findById(userId)
     if (!user || !user.gateHubUserId) {
       throw new NotFound()
     }
 
-    const isUserApproved = await this.gateHubClient.connectUserToGateway(
-      user.gateHubUserId,
-      this.env.GATEHUB_GATEWAY_UUID
+    if (!isApproved) {
+      isApproved = await this.gateHubClient.connectUserToGateway(
+        user.gateHubUserId,
+        this.env.GATEHUB_GATEWAY_UUID
+      )
+    }
+
+    this.logger.info(
+      `User ${user.id} with gatehub id ${user.gateHubUserId} CONNECTED TO GATEWAY`
     )
 
     const userState = await this.gateHubClient.getUserState(user.gateHubUserId)
@@ -73,7 +92,7 @@ export class GateHubService {
         .join(', ')
     }
 
-    if (isUserApproved) {
+    if (isApproved) {
       userDetails.kycVerified = true
     }
 
@@ -104,7 +123,7 @@ export class GateHubService {
       await this.createDefaultAccountAndWAForManagedUser(userId)
     }
 
-    return { isUserApproved, customerId }
+    return { isApproved, customerId }
   }
 
   private async createDefaultAccountAndWAForManagedUser(
@@ -220,5 +239,7 @@ export class GateHubService {
     await User.query().findById(user.id).patch({
       kycVerified: true
     })
+
+    this.logger.info(`USER ${user.id} with gatehub id ${uuid} VERIFIED`)
   }
 }