10553: Use title to check if request timed out;

web-api/src/business/useCases/user/queueEmailUpdateAssociatedCasesWorker.ts

@@ -0,0 +1,89 @@
+import { AuthUser } from '@shared/business/entities/authUser/AuthUser';
+import {
+  Practitioner,
+  RawPractitioner,
+} from '../../../../../shared/src/business/entities/Practitioner';
+import { ROLES } from '@shared/business/entities/EntityConstants';
+import {
+  RawUser,
+  User,
+} from '../../../../../shared/src/business/entities/User';
+import { ServerApplicationContext } from '@web-api/applicationContext';
+
+async function disableIsUserUpdatingFlag({
+  applicationContext,
+  user,
+}: {
+  applicationContext: ServerApplicationContext;
+  user: RawUser | RawPractitioner;
+}): Promise<void> {
+  user.isUpdatingInformation = false;
+  let userEntity;
+  if (
+    user.role === ROLES.privatePractitioner ||
+    user.role === ROLES.irsPractitioner ||
+    user.role === ROLES.inactivePractitioner
+  ) {
+    userEntity = new Practitioner(user);
+  } else {
+    userEntity = new User(user);
+  }
+
+  await applicationContext.getPersistenceGateway().updateUser({
+    applicationContext,
+    user: userEntity.validate().toRawObject(),
+  });
+}
+
+export const queueEmailUpdateAssociatedCasesWorker = async (
+  applicationContext: ServerApplicationContext,
+  { user }: { user: RawUser | RawPractitioner },
+  authorizedUser: AuthUser,
+): Promise<void> => {
+  const docketNumbersAssociatedWithUser = await applicationContext
+    .getPersistenceGateway()
+    .getDocketNumbersByUser({
+      applicationContext,
+      userId: user.userId,
+    });
+
+  if (!docketNumbersAssociatedWithUser.length) {
+    await disableIsUserUpdatingFlag({ applicationContext, user });
+    return;
+  }
+
+  await applicationContext
+    .getUseCases()
+    .queueUpdateAssociatedCasesWorker(
+      applicationContext,
+      { user },
+      authorizedUser,
+    );
+
+  try {
+    const expectedUpdatedCaseCount = (
+      await applicationContext.getPersistenceGateway().getDocketNumbersByUser({
+        applicationContext,
+        userId: user.userId,
+      })
+    ).length;
+
+    let checkCount = true;
+    while (checkCount) {
+      await applicationContext.getUtilities().sleep(1500);
+      const actualUpdatedCaseCount = await applicationContext
+        .getPersistenceGateway()
+        .getCasesByEmailTotal({
+          applicationContext,
+          email: user.email!,
+        });
+
+      if (actualUpdatedCaseCount >= expectedUpdatedCaseCount)
+        checkCount = false;
+    }
+
+    await disableIsUserUpdatingFlag({ applicationContext, user });
+  } catch (e) {
+    await disableIsUserUpdatingFlag({ applicationContext, user });
+  }
+};

web-api/src/business/useCases/user/verifyUserPendingEmailInteractor.ts

@@ -92,42 +92,7 @@ export const verifyUserPendingEmailInteractor = async (
     message: {
       authorizedUser,
       payload: { user: updatedUser },
-      type: MESSAGE_TYPES.QUEUE_UPDATE_ASSOCIATED_CASES,
+      type: MESSAGE_TYPES.QUEUE_EMAIL_UPDATE_ASSOCIATED_CASES,
     },
   });
-
-  try {
-    const expectedUpdatedCaseCount = (
-      await applicationContext.getPersistenceGateway().getDocketNumbersByUser({
-        applicationContext,
-        userId: user.userId,
-      })
-    ).length;
-
-    let checkCount = true;
-    while (checkCount) {
-      await applicationContext.getUtilities().sleep(1500);
-      const actualUpdatedCaseCount = await applicationContext
-        .getPersistenceGateway()
-        .getCasesByEmailTotal({
-          applicationContext,
-          email: updatedUser.email!,
-        });
-
-      if (actualUpdatedCaseCount === expectedUpdatedCaseCount)
-        checkCount = false;
-    }
-
-    updatedUser.isUpdatingInformation = false;
-    await applicationContext.getPersistenceGateway().updateUser({
-      applicationContext,
-      user: updatedUser,
-    });
-  } catch (e) {
-    updatedUser.isUpdatingInformation = false;
-    await applicationContext.getPersistenceGateway().updateUser({
-      applicationContext,
-      user: updatedUser,
-    });
-  }
 };

web-api/src/gateways/worker/workerRouter.ts

@@ -8,6 +8,7 @@ export type WorkerMessage = {
 };
 
 export const MESSAGE_TYPES = {
+  QUEUE_EMAIL_UPDATE_ASSOCIATED_CASES: 'QUEUE_EMAIL_UPDATE_ASSOCIATED_CASES',
   QUEUE_UPDATE_ASSOCIATED_CASES: 'QUEUE_UPDATE_ASSOCIATED_CASES',
   UPDATE_ASSOCIATED_CASE: 'UPDATE_ASSOCIATED_CASE',
 } as const;
@@ -42,6 +43,15 @@ export const workerRouter = async (
           message.authorizedUser,
         );
       break;
+    case MESSAGE_TYPES.QUEUE_EMAIL_UPDATE_ASSOCIATED_CASES:
+      await applicationContext
+        .getUseCases()
+        .queueEmailUpdateAssociatedCasesWorker(
+          applicationContext,
+          message.payload,
+          message.authorizedUser,
+        );
+      break;
     default:
       throw new Error(
         `No matching router found for message: ${JSON.stringify(message)}`,

web-api/src/getUseCases.ts

@@ -149,6 +149,7 @@ import { orderAdvancedSearchInteractor } from '../../shared/src/business/useCase
 import { orderPublicSearchInteractor } from './business/useCases/public/orderPublicSearchInteractor';
 import { prioritizeCaseInteractor } from '../../shared/src/business/useCases/prioritizeCaseInteractor';
 import { processStreamRecordsInteractor } from './business/useCases/processStreamRecords/processStreamRecordsInteractor';
+import { queueEmailUpdateAssociatedCasesWorker } from '@web-api/business/useCases/user/queueEmailUpdateAssociatedCasesWorker';
 import { queueUpdateAssociatedCasesWorker } from './business/useCases/user/queueUpdateAssociatedCasesWorker';
 import { removeCaseFromTrialInteractor } from './business/useCases/trialSessions/removeCaseFromTrialInteractor';
 import { removeCasePendingItemInteractor } from '../../shared/src/business/useCases/removeCasePendingItemInteractor';
@@ -363,6 +364,7 @@ const useCases = {
   orderPublicSearchInteractor,
   prioritizeCaseInteractor,
   processStreamRecordsInteractor,
+  queueEmailUpdateAssociatedCasesWorker,
   queueUpdateAssociatedCasesWorker,
   removeCaseFromTrialInteractor,
   removeCasePendingItemInteractor,

web-client/src/presenter/actions/verifyUserPendingEmailAction.tsx

@@ -1,3 +1,4 @@
+import { GatewayTimeoutErrorTitle } from '@web-client/presenter/errors/GatewayTimeoutError';
 import { TROUBLESHOOTING_INFO } from '@shared/business/entities/EntityConstants';
 import { state } from '@web-client/presenter/app.cerebral';
 import React from 'react';
@@ -66,7 +67,7 @@ export const verifyUserPendingEmailAction = async ({
         alertError: expiredTokenAlertError,
       });
     }
-    if (e.message === 'Endpoint request timed out') {
+    if (e.title === GatewayTimeoutErrorTitle) {
       return path.error({
         alertError: requestTimedOutAlertError,
       });

web-client/src/presenter/errors/GatewayTimeoutError.ts

@@ -1,11 +1,13 @@
 import { ActionError } from './ActionError';
+export const GatewayTimeoutErrorTitle =
+  'The system is taking too long to respond';
 
 export class GatewayTimeoutError extends ActionError {
   // HTTP 504
   constructor() {
     const message = 'Try again.';
     super(message);
-    this.title = 'The system is taking too long to respond';
+    this.title = GatewayTimeoutErrorTitle;
     this.message = message;
   }
 }