#3260 - CAS Integration 3A - Create new Supplier and Site - Retry on Error and Scheduler Time

sources/packages/backend/apps/db-migrations/src/migrations/1729785100207-UpdateCASSupplierIntegrationScheduler.ts

@@ -0,0 +1,18 @@
+import { MigrationInterface, QueryRunner } from "typeorm";
+import { getSQLFileData } from "../utilities/sqlLoader";
+
+export class UpdateCASSupplierIntegrationScheduler1729785100207
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      getSQLFileData("Update-cas-supplier-integration.sql", "Queue"),
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      getSQLFileData("Rollback-update-cas-supplier-integration.sql", "Queue"),
+    );
+  }
+}

sources/packages/backend/apps/db-migrations/src/sql/Queue/Rollback-update-cas-supplier-integration.sql

@@ -0,0 +1,12 @@
+UPDATE
+    sims.queue_configurations
+SET
+    queue_configuration = '{
+        "cron": "0 7 * * *",
+        "retry": 3,
+        "cleanUpPeriod": 2592000000,
+        "retryInterval": 180000,
+        "dashboardReadonly": false
+    }' :: json
+WHERE
+    queue_name = 'cas-supplier-integration';

sources/packages/backend/apps/db-migrations/src/sql/Queue/Update-cas-supplier-integration.sql

@@ -0,0 +1,12 @@
+UPDATE
+    sims.queue_configurations
+SET
+    queue_configuration = '{
+        "cron": "0 19 * * 1-5",
+        "retry": 3,
+        "cleanUpPeriod": 2592000000,
+        "retryInterval": 180000,
+        "dashboardReadonly": false
+    }' :: json
+WHERE
+    queue_name = 'cas-supplier-integration';

sources/packages/backend/apps/queue-consumers/src/processors/schedulers/cas-integration/_tests_/cas-supplier-integration.scheduler.e2e-spec.ts

@@ -365,4 +365,68 @@ describe(describeProcessorRootTest(QueueNames.CASSupplierIntegration), () => {
       );
     },
   );
+
+  it("Should throw an error for the first student and process the second one when the CAS API call failed for the first student but worked for the second one.", async () => {
+    // Arrange
+    // Create two mocks where the first one will throw an error
+    // and the second one is expected to work.
+    casServiceMock.getSupplierInfoFromCAS = jest
+      .fn()
+      .mockRejectedValueOnce("Unknown error")
+      .mockResolvedValue(
+        Promise.resolve(createFakeCASNotFoundSupplierResponse()),
+      );
+    // Mock to be also used for processing the second student.
+    casServiceMock.createSupplierAndSite = jest.fn(() =>
+      Promise.resolve(createFakeCASCreateSupplierAndSiteResponse()),
+    );
+    // Student CAS pending request expected to fail.
+    const savedCASSupplierToFail = await saveFakeCASSupplier(db);
+    // Student CAS pending request expected to succeed.
+    const studentToSucceed = await saveFakeStudent(db.dataSource, undefined, {
+      initialValue: {
+        contactInfo: {
+          address: {
+            addressLine1: "3350 Douglas St",
+            city: "Victoria",
+            country: "Canada",
+            selectedCountry: COUNTRY_CANADA,
+            provinceState: "BC",
+            postalCode: "V8Z 7X9",
+          },
+        } as ContactInfo,
+      },
+    });
+    const savedCASSupplierToSucceed = await saveFakeCASSupplier(db, {
+      student: studentToSucceed,
+    });
+
+    // Queued job.
+    const mockedJob = mockBullJob<void>();
+
+    // Act
+    await expect(
+      processor.processCASSupplierInformation(mockedJob.job),
+    ).rejects.toStrictEqual(
+      new Error(
+        "One or more errors were reported during the process, please see logs for details.",
+      ),
+    );
+
+    // Assert
+    expect(
+      mockedJob.containLogMessages([
+        "Executing CAS supplier integration...",
+        "Found 2 records to be updated.",
+        `Processing student CAS supplier ID: ${savedCASSupplierToFail.id}.`,
+        'Unexpected error while processing supplier. "Unknown error"',
+        `Processing student CAS supplier ID: ${savedCASSupplierToSucceed.id}.`,
+        `CAS evaluation result status: ${CASEvaluationStatus.NotFound}.`,
+        `No active CAS supplier found. Reason: ${NotFoundReason.SupplierNotFound}.`,
+        "Created supplier and site on CAS.",
+        "Updated CAS supplier and site for the student.",
+        "CAS supplier integration executed.",
+      ]),
+    ).toBe(true);
+  });
 });

sources/packages/backend/apps/queue-consumers/src/processors/schedulers/cas-integration/cas-supplier-integration.scheduler.ts

@@ -13,7 +13,6 @@ import {
   logProcessSummaryToJobLogger,
   getSuccessMessageWithAttentionCheck,
 } from "../../../utilities";
-import { CAS_AUTH_ERROR } from "@sims/integrations/constants";
 
 @Processor(QueueNames.CASSupplierIntegration)
 export class CASSupplierIntegrationScheduler extends BaseScheduler<void> {
@@ -63,19 +62,16 @@ export class CASSupplierIntegrationScheduler extends BaseScheduler<void> {
           `Records updated: ${suppliersUpdated}.`,
         ],
         processSummary,
+        { throwOnError: true },
       );
     } catch (error: unknown) {
+      // Throw an error to force the queue to retry.
       if (error instanceof CustomNamedError) {
-        if (error.name === CAS_AUTH_ERROR) {
-          // Throw an error to force the queue to retry.
-          throw new Error(
-            `Unable to request data to CAS due to an authentication error.`,
-          );
-        }
-        const errorMessage = "Unexpected error while executing the job.";
-        processSummary.error(errorMessage, error);
-        return [errorMessage];
+        throw new Error(error.message);
       }
+      throw new Error("Unexpected error while executing the job.", {
+        cause: error,
+      });
     } finally {
       this.logger.logProcessSummary(processSummary);
       await logProcessSummaryToJobLogger(processSummary, job);

sources/packages/backend/apps/queue-consumers/src/utilities/log-utils.ts

@@ -1,3 +1,4 @@
+import { CustomNamedError } from "@sims/utilities";
 import { ProcessSummary } from "@sims/utilities/logger";
 import * as dayjs from "dayjs";
 
@@ -7,6 +8,8 @@ import * as dayjs from "dayjs";
  */
 const LOG_INDENTATION = "--";
 
+export const PROCESS_SUMMARY_CONTAINS_ERROR = "PROCESS_SUMMARY_CONTAINS_ERROR";
+
 /**
  * Log capability provided by a queue job.
  */
@@ -41,13 +44,18 @@ export async function logProcessSummaryToJobLogger(
  * @param successMessages generic success message.
  * @param processSummary processSummary to check if an
  * attention message is required.
+ * @param options options.
+ * - `throwOnError`: when true, throws an exception if the
+ * error summary contains some error.
  * @returns generic success message or success message with
  * attention messages appended.
  */
 export function getSuccessMessageWithAttentionCheck(
   successMessages: string[],
   processSummary: ProcessSummary,
+  options?: { throwOnError?: boolean },
 ): string[] {
+  const throwOnError = options?.throwOnError ?? false;
   const message: string[] = [];
   message.push(...successMessages);
   const logsSum = processSummary.getLogLevelSum();
@@ -58,6 +66,12 @@ export function getSuccessMessageWithAttentionCheck(
     message.push(
       `Error(s): ${logsSum.error}, Warning(s): ${logsSum.warn}, Info: ${logsSum.info}`,
     );
+    if (logsSum.error && throwOnError) {
+      throw new CustomNamedError(
+        "One or more errors were reported during the process, please see logs for details.",
+        PROCESS_SUMMARY_CONTAINS_ERROR,
+      );
+    }
   }
   return message;
 }

sources/packages/backend/libs/utilities/src/address-utils.ts

@@ -5,7 +5,7 @@ import { AddressInfo } from "@sims/sims-db";
 export const OTHER_COUNTRY = "other";
 // 'selectedCountry' in the student contact info will have the value 'canada',
 // when 'Canada' is selected.
-export const COUNTRY_CANADA = "canada";
+export const COUNTRY_CANADA = "Canada";
 
 /**
  * Inspects the address info to determine if the address is from Canada.