Update timestamp

Author: stevebux

internal/datastore/src/letter-queue-repository.ts

@@ -86,7 +86,7 @@ export default class LetterQueueRepository {
   async getLetters(
     supplierId: string,
     limit: number,
-  ): Promise<PendingLetterBase[]> {
+  ): Promise<PendingLetter[]> {
     const result = await this.ddbClient.send(
       new QueryCommand({
         TableName: this.config.letterQueueTableName,
@@ -95,12 +95,11 @@ export default class LetterQueueRepository {
         ExpressionAttributeValues: {
           ":supplierId": supplierId,
         },
-        ProjectionExpression: "supplierId, letterId, specificationId, groupId",
         Limit: limit,
       }),
     );
 
-    return z.array(PendingLetterSchemaBase).parse(result.Items);
+    return z.array(PendingLetterSchema).parse(result.Items);
   }
 
   async updateLetterTimestamp(

lambdas/api-handler/src/services/__tests__/letter-operations.test.ts

@@ -49,7 +49,7 @@ describe("getPendingLetters", () => {
     jest.clearAllMocks();
   });
 
-  it("returns letters from the letter queue repository mapped to LetterBase", async () => {
+  it("returns letters from the letter queue repository", async () => {
     const mockRepo = {
       getLetters: jest.fn().mockResolvedValue([
         {
@@ -65,11 +65,24 @@ describe("getPendingLetters", () => {
           groupId: "g1",
         },
       ]),
+      updateLetterTimestamp: jest.fn()
     };
 
     const result = await getPendingLetters("supplier1", 10, mockRepo as any);
 
     expect(mockRepo.getLetters).toHaveBeenCalledWith("supplier1", 10);
+    expect(mockRepo.updateLetterTimestamp).toHaveBeenNthCalledWith(
+      1,
+      "supplier1",
+      "id1",
+      600,
+    );
+    expect(mockRepo.updateLetterTimestamp).toHaveBeenNthCalledWith(
+      2,
+      "supplier1",
+      "id2",
+      600,
+    );
     expect(result).toEqual([
       { id: "id1", status: "PENDING", specificationId: "s1", groupId: "g1" },
       { id: "id2", status: "PENDING", specificationId: "s1", groupId: "g1" },

lambdas/api-handler/src/services/letter-operations.ts

@@ -2,6 +2,7 @@ import {
   LetterBase,
   LetterQueueRepository,
   LetterRepository,
+  PendingLetter,
   PendingLetterBase,
 } from "@internal/datastore";
 import { getSignedUrl } from "@aws-sdk/s3-request-presigner";
@@ -51,6 +52,13 @@ export const getPendingLetters = async (
   letterQueueRepo: LetterQueueRepository,
 ): Promise<LetterBase[]> => {
   const pendingLetters = await letterQueueRepo.getLetters(supplierId, limit);
+  for (const letter of pendingLetters) {
+    letterQueueRepo.updateLetterTimestamp(
+      letter.supplierId,
+      letter.letterId,
+      600,
+    );
+  }
   return pendingLetters.map((letter) => mapPendingLetterToLetterBase(letter));
 };