functionality to implement reset needs evaluation flag

eslint.config.js

@@ -1,11 +1,11 @@
-const { defineConfig } = require('eslint/config');
+import defineConfig from 'eslint/config';
+import tsParser from '@typescript-eslint/parser';
 
-const tsParser = require('@typescript-eslint/parser');
-const typescriptEslintEslintPlugin = require('@typescript-eslint/eslint-plugin');
-const globals = require('globals');
-const js = require('@eslint/js');
+import typescriptEslintEslintPlugin from '@typescript-eslint/eslint-plugin';
+import globals from 'globals';
 
-const { FlatCompat } = require('@eslint/eslintrc');
+import js from '@eslint/js';
+import FlatCompat from '@eslint/eslintrc';
 
 const compat = new FlatCompat({
   baseDirectory: __dirname,
@@ -43,6 +43,7 @@ module.exports = defineConfig([
       '@typescript-eslint/explicit-function-return-type': 'off',
       '@typescript-eslint/explicit-module-boundary-types': 'off',
       '@typescript-eslint/no-explicit-any': 'off',
+      'prettier/prettier': ['error', { endOfLine: 'auto' }],
     },
   },
 ]);

src/qa-certification-event-workspace/qa-certification-event-workspace.service.spec.ts

@@ -55,6 +55,7 @@ const mockRepository = () => ({
   create: jest.fn().mockResolvedValue(entity),
   save: jest.fn().mockResolvedValue(entity),
   delete: jest.fn().mockResolvedValue(null),
+  query: jest.fn().mockResolvedValue(['']),
 });
 
 const mockQACertRepository = () => ({

src/qa-certification-event-workspace/qa-certification-event-workspace.service.ts

@@ -82,8 +82,11 @@ export class QACertificationEventWorkspaceService {
 
     await this.repository.save(entity);
 
-    const result = await this.repository.getQACertificationEventById(entity.id);
+    //Finally, perform the updates (reset needs eval flag, etc) for those records
+    // that may have been collaterally affected by this change.
+    await this.updateCollaterallyAffectedRecords(entity.id);
 
+    const result = await this.repository.getQACertificationEventById(entity.id);
     return this.map.one(result);
   }
 
@@ -161,6 +164,10 @@ export class QACertificationEventWorkspaceService {
   async deleteQACertEvent(id: string): Promise<void> {
     try {
       await this.repository.delete(id);
+
+      //Finally, perform the updates (reset needs eval flag, etc) for those records
+      // that may have been collaterally affected by this change.
+      await this.updateCollaterallyAffectedRecords(id);
     } catch (e) {
       throw new InternalServerErrorException(
         `Error deleting QA Certification Event record Id [${id}]`,
@@ -233,9 +240,26 @@ export class QACertificationEventWorkspaceService {
 
     await this.repository.save(entity);
 
+    //Finally, perform the updates (reset needs eval flag, etc) for those records
+    // that may have been collaterally affected by this change.
+    await this.updateCollaterallyAffectedRecords(entity.id);
+
     return this.getQACertEvent(entity.id);
   }
 
+  async updateCollaterallyAffectedRecords(qceId: string): Promise<void> {
+
+    //1. Update affected EM Records
+    const emResult = await this.repository.query(
+      'SELECT * FROM camdecmpswks.update_collateral_em_data_for_qce_changes($1)',
+      [qceId],
+    );
+
+    if (emResult[0].result === 'F') {
+      throw new Error(`EM Deletion Failed: ${emResult[0].error_msg}`);
+    }
+  }
+
   async export(
     facilityId: number,
     unitIds?: string[],

src/test-extension-exemptions-workspace/test-extension-exemptions-workspace.service.spec.ts

@@ -63,6 +63,7 @@ const mockRepository = () => ({
   findOneBy: jest.fn().mockResolvedValue(entity),
   create: jest.fn().mockResolvedValue(entity),
   save: jest.fn().mockResolvedValue(entity),
+  query: jest.fn().mockResolvedValue(['']),
 });
 
 const mockTestExtensionExemptionsRepository = () => ({

src/test-extension-exemptions-workspace/test-extension-exemptions-workspace.service.ts

@@ -211,10 +211,13 @@ export class TestExtensionExemptionsWorkspaceService {
 
     await this.repository.save(entity);
 
+    //Finally, perform the updates (reset needs eval flag, etc) for those records
+    // that may have been collaterally affected by this change.
+    await this.updateCollaterallyAffectedRecords(entity.id);
+
     const result = await this.repository.getTestExtensionExemptionById(
       entity.id,
     );
-
     return this.map.one(result);
   }
 
@@ -259,12 +262,21 @@ export class TestExtensionExemptionsWorkspaceService {
     record.submissionAvailabilityCode = 'REQUIRE';
 
     await this.repository.save(record);
+
+    //Finally, perform the updates (reset needs eval flag, etc) for those records
+    // that may have been collaterally affected by this change.
+    await this.updateCollaterallyAffectedRecords(record.id);
+
     return this.getTestExtensionExemptionById(record.id);
   }
 
   async deleteTestExtensionExemption(id: string): Promise<void> {
     try {
       await this.repository.delete(id);
+
+      //Finally, perform the updates (reset needs eval flag, etc) for those records
+      // that may have been collaterally affected by this change.
+      await this.updateCollaterallyAffectedRecords(id);
     } catch (e) {
       throw new InternalServerErrorException(
         `Error deleting Test Extension Exemption record Id [${id}]`,
@@ -273,6 +285,19 @@ export class TestExtensionExemptionsWorkspaceService {
     }
   }
 
+  async updateCollaterallyAffectedRecords(teeId: string): Promise<void> {
+
+    //1. Update affected EM Records
+    const emResult = await this.repository.query(
+      'SELECT * FROM camdecmpswks.update_collateral_em_data_for_tee_changes($1)',
+      [teeId],
+    );
+
+    if (emResult[0].result === 'F') {
+      throw new Error(`EM Deletion Failed: ${emResult[0].error_msg}`);
+    }
+  }
+
   async lookupValues(
     locationId: string,
     payload: TestExtensionExemptionBaseDTO,

src/test-summary-workspace/test-summary.service.spec.ts

@@ -92,6 +92,7 @@ const mockRepository = () => ({
   findOneBy: jest.fn().mockResolvedValue(testSummary),
   create: jest.fn().mockResolvedValue(testSummary),
   save: jest.fn().mockResolvedValue(testSummary),
+  query: jest.fn().mockResolvedValue(['']),
 });
 
 const mockTestSummaryReviewAndSubmitService = () => ({

src/test-summary-workspace/test-summary.service.ts

@@ -703,8 +703,12 @@ export class TestSummaryWorkspaceService {
     });
 
     await this.repository.save(entity);
-    const result = await this.repository.getTestSummaryById(entity.id);
 
+    // Perform the updates (reset needs eval flag, etc) for those records
+    // that may have been collaterally affected by this change.
+    await this.updateCollaterallyAffectedRecords(entity.id);
+
+    const result = await this.repository.getTestSummaryById(entity.id);
     const dto = await this.map.one(result);
 
     delete dto.calibrationInjectionData;
@@ -776,12 +780,21 @@ export class TestSummaryWorkspaceService {
     entity.evalStatusCode = 'EVAL';
 
     await this.repository.save(entity);
+
+    // Perform the updates (reset needs eval flag, etc) for those records
+    // that may have been collaterally affected by this change.
+    await this.updateCollaterallyAffectedRecords(entity.id);
+
     return this.getTestSummaryById(entity.id);
   }
 
   async deleteTestSummary(id: string): Promise<void> {
     try {
       await this.repository.delete(id);
+
+      // Perform the updates (reset needs eval flag, etc) for those records
+      // that may have been collaterally affected by this change.
+      await this.updateCollaterallyAffectedRecords(id);
     } catch (e) {
       throw new InternalServerErrorException(
         `Error deleting Test Summary record Id [${id}]`,
@@ -806,6 +819,31 @@ export class TestSummaryWorkspaceService {
       entity.evalStatusCode = 'EVAL';
 
       await this.repository.save(entity);
+
+      //Finally, perform the updates (reset needs eval flag, etc) for those records
+      // that may have been collaterally affected by this change.
+      await this.updateCollaterallyAffectedRecords(testSumId);
+    }
+  }
+
+  async updateCollaterallyAffectedRecords(testSumId: string): Promise<void> {
+    //1. Update affected QAT Records
+    const qaResult = await this.repository.query(
+      'SELECT * FROM camdecmpswks.update_collateral_qat_data_for_qat_changes($1)',
+      [testSumId],
+    );
+    if (qaResult[0].result === 'F') {
+      throw new Error(`QA Deletion Failed: ${qaResult[0].error_msg}`);
+    }
+
+    //2. Update affected EM Records
+    const emResult = await this.repository.query(
+      'SELECT * FROM camdecmpswks.update_collateral_em_data_for_qat_changes($1)',
+      [testSumId],
+    );
+
+    if (emResult[0].result === 'F') {
+      throw new Error(`EM Deletion Failed: ${emResult[0].error_msg}`);
     }
   }