feat: update new Status#CreatedAt field when changing Status in Dynam…

…oDB Vault entries
cds-snc · Nov 20, 2024 · 4272287 · 4272287
1 parent 0ae0402
commit 4272287
Show file tree

Hide file tree

Showing 3 changed files with 29 additions and 14 deletions.
diff --git a/...rms)/[locale]/(form administration)/form-builder/[id]/responses/[statusFilter]/actions.ts b/...rms)/[locale]/(form administration)/form-builder/[id]/responses/[statusFilter]/actions.ts
@@ -360,6 +360,7 @@ export const getSubmissionsByFormat = async ({
       return {
         id: item.name,
         status: item.status,
+        createdAt: item.createdAt,
       };
     });
 

diff --git a/app/api/id/[form]/submission/report/route.ts b/app/api/id/[form]/submission/report/route.ts
@@ -16,12 +16,12 @@ async function getSubmissionsFromSubmissionNames(
   formId: string,
   submissionNames: string[]
 ): Promise<{
-  submissionsToReport: { name: string; confirmationCode: string }[];
+  submissionsToReport: { name: string; createdAt: number; confirmationCode: string }[];
   submissionNamesAlreadyUsed: string[];
   submissionNamesNotFound: string[];
 }> {
   const accumulatedSubmissions: {
-    [name: string]: { status: VaultStatus; confirmationCode: string };
+    [name: string]: { status: VaultStatus; createdAt: number; confirmationCode: string };
   } = {};
 
   let requestedKeys = submissionNames.map((name) => {
@@ -33,7 +33,7 @@ async function getSubmissionsFromSubmissionNames(
       RequestItems: {
         Vault: {
           Keys: requestedKeys,
-          ProjectionExpression: "#name,#status,ConfirmationCode",
+          ProjectionExpression: "#name,#status,ConfirmationCode,CreatedAt",
           ExpressionAttributeNames: {
             "#name": "Name",
             "#status": "Status",
@@ -49,6 +49,7 @@ async function getSubmissionsFromSubmissionNames(
       response.Responses.Vault.forEach((record) => {
         accumulatedSubmissions[record["Name"]] = {
           status: record["Status"],
+          createdAt: record["CreatedAt"],
           confirmationCode: record["ConfirmationCode"],
         };
       });
@@ -75,13 +76,14 @@ async function getSubmissionsFromSubmissionNames(
       } else {
         acc.submissionsToReport.push({
           name: currentSubmissionName,
+          createdAt: submission.createdAt,
           confirmationCode: submission.confirmationCode,
         });
       }
       return acc;
     },
     {
-      submissionsToReport: Array<{ name: string; confirmationCode: string }>(),
+      submissionsToReport: Array<{ name: string; createdAt: number; confirmationCode: string }>(),
       submissionNamesAlreadyUsed: Array<string>(),
       submissionNamesNotFound: Array<string>(),
     }
@@ -90,7 +92,7 @@ async function getSubmissionsFromSubmissionNames(
 
 async function report(
   formId: string,
-  submissionsToReport: { name: string; confirmationCode: string }[]
+  submissionsToReport: { name: string; createdAt: number; confirmationCode: string }[]
 ): Promise<void> {
   const request = new TransactWriteCommand({
     TransactItems: submissionsToReport.flatMap((submission) => {
@@ -103,12 +105,14 @@ async function report(
               NAME_OR_CONF: `NAME#${submission.name}`,
             },
             UpdateExpression:
-              "SET #status = :status, ProblemTimestamp = :problemTimestamp REMOVE RemovalDate",
+              "SET #status = :status, #statusCreatedAtKey = :statusCreatedAtValue, ProblemTimestamp = :problemTimestamp REMOVE RemovalDate",
             ExpressionAttributeNames: {
               "#status": "Status",
+              "#statusCreatedAtKey": "Status#CreatedAt",
             },
             ExpressionAttributeValues: {
               ":status": "Problem",
+              ":statusCreatedAtValue": `Problem#${submission.createdAt}`,
               ":problemTimestamp": Date.now(),
             },
           },

diff --git a/lib/vault.ts b/lib/vault.ts
@@ -389,7 +389,7 @@ export async function retrieveSubmissions(
  * @param email Email address of the user downloading the Submission
  */
 export async function updateLastDownloadedBy(
-  responses: Array<{ id: string; status: string }>,
+  responses: Array<{ id: string; status: string; createdAt: number }>,
   formID: string,
   email: string
 ) {
@@ -407,16 +407,22 @@ export async function updateLastDownloadedBy(
               NAME_OR_CONF: `NAME#${response.id}`,
             },
             UpdateExpression: "SET LastDownloadedBy = :email, DownloadedAt = :downloadedAt".concat(
-              isNewResponse ? ", #status = :statusUpdate" : ""
+              isNewResponse
+                ? ", #status = :statusUpdate, #statusCreatedAtKey = :statusCreatedAtValue"
+                : ""
             ),
             ExpressionAttributeValues: {
               ":email": email,
               ":downloadedAt": Date.now(),
-              ...(isNewResponse && { ":statusUpdate": "Downloaded" }),
+              ...(isNewResponse && {
+                ":statusUpdate": "Downloaded",
+                ":statusCreatedAtValue": `Downloaded#${response.createdAt}`,
+              }),
             },
             ...(isNewResponse && {
               ExpressionAttributeNames: {
                 "#status": "Status",
+                "#statusCreatedAtKey": "Status#CreatedAt",
               },
             }),
           },
@@ -577,7 +583,7 @@ async function getSubmissionsFromConfirmationCodes(
   formId: string,
   confirmationCodes: string[]
 ): Promise<{
-  submissionsToConfirm: { name: string; confirmationCode: string }[];
+  submissionsToConfirm: { name: string; createdAt: number; confirmationCode: string }[];
   confirmationCodesAlreadyUsed: string[];
   confirmationCodesNotFound: string[];
 }> {
@@ -594,7 +600,7 @@ async function getSubmissionsFromConfirmationCodes(
   });
 
   const accumulatedSubmissions: {
-    [confCode: string]: { name: string; removalDate?: number };
+    [confCode: string]: { name: string; createdAt: number; removalDate?: number };
   } = {};
 
   let requestedKeys = confirmationCodes.map((code) => {
@@ -606,7 +612,7 @@ async function getSubmissionsFromConfirmationCodes(
       RequestItems: {
         Vault: {
           Keys: requestedKeys,
-          ProjectionExpression: "#name,ConfirmationCode,RemovalDate",
+          ProjectionExpression: "#name,CreatedAt,ConfirmationCode,RemovalDate",
           ExpressionAttributeNames: {
             "#name": "Name",
           },
@@ -621,6 +627,7 @@ async function getSubmissionsFromConfirmationCodes(
       response.Responses.Vault.forEach((record) => {
         accumulatedSubmissions[record["ConfirmationCode"]] = {
           name: record["Name"],
+          createdAt: record["CreatedAt"],
           removalDate: record["RemovalDate"],
         };
       });
@@ -647,13 +654,14 @@ async function getSubmissionsFromConfirmationCodes(
       } else {
         acc.submissionsToConfirm.push({
           name: submission.name,
+          createdAt: submission.createdAt,
           confirmationCode: currentConfirmationCode,
         });
       }
       return acc;
     },
     {
-      submissionsToConfirm: Array<{ name: string; confirmationCode: string }>(),
+      submissionsToConfirm: Array<{ name: string; createdAt: number; confirmationCode: string }>(),
       confirmationCodesAlreadyUsed: Array<string>(),
       confirmationCodesNotFound: Array<string>(),
     }
@@ -724,12 +732,14 @@ export const confirmResponses = async (
                     NAME_OR_CONF: `NAME#${submission.name}`,
                   },
                   UpdateExpression:
-                    "SET #status = :status, ConfirmTimestamp = :confirmTimestamp, RemovalDate = :removalDate",
+                    "SET #status = :status, #statusCreatedAtKey = :statusCreatedAtValue, ConfirmTimestamp = :confirmTimestamp, RemovalDate = :removalDate",
                   ExpressionAttributeNames: {
                     "#status": "Status",
+                    "#statusCreatedAtKey": "Status#CreatedAt",
                   },
                   ExpressionAttributeValues: {
                     ":status": "Confirmed",
+                    ":statusCreatedAtValue": `Confirmed#${submission.createdAt}`,
                     ":confirmTimestamp": confirmationTimestamp,
                     ":removalDate": removalDate,
                   },