Filter on date

Author: stevebux

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

@@ -128,6 +128,16 @@ describe("LetterQueueRepository", () => {
       expect(letters).toHaveLength(0);
     });
 
+    it("filters by queueTimestamp", async () => {
+      jest.useFakeTimers().setSystemTime(new Date("2026-03-04T13:25:45.000Z"));
+      await letterQueueRepository.putLetter(createLetter());
+      jest.useFakeTimers().setSystemTime(new Date("2026-03-04T13:23:45.000Z"));
+
+      const letters = await letterQueueRepository.getLetters("supplier1", 1);
+
+      expect(letters).toHaveLength(0);
+    });
+
     it("returns letters in timestamp order", async () => {
       await letterQueueRepository.putLetter(createLetter("first-letter"));
       await letterQueueRepository.putLetter(createLetter("second-letter"));

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

@@ -85,9 +85,11 @@ export default class LetterQueueRepository {
       new QueryCommand({
         TableName: this.config.letterQueueTableName,
         IndexName: "queueTimestamp-index",
-        KeyConditionExpression: "supplierId = :supplierId",
+        KeyConditionExpression:
+          "supplierId = :supplierId and queueTimestamp < :now",
         ExpressionAttributeValues: {
           ":supplierId": supplierId,
+          ":now": new Date().toISOString(),
         },
         Limit: limit,
       }),