Skip to content

Commit 129a4e8

Browse files
committed
Add logging
1 parent b26cdf5 commit 129a4e8

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

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

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ import LetterNotFoundError from "./errors/letter-not-found-error";
1919
type LetterQueueRepositoryConfig = {
2020
letterQueueTableName: string;
2121
letterQueueTtlHours: number;
22-
/** Maximum number of items to fetch per DynamoDB page. Defaults to 100. */
22+
/** Maximum number of items to fetch per DynamoDB page. Defaults to 1000. */
2323
queryPageSize?: number;
2424
};
2525

@@ -100,6 +100,7 @@ export default class LetterQueueRepository {
100100
const letters: PendingLetter[] = [];
101101
let lastEvaluatedKey: Record<string, unknown> | undefined;
102102

103+
let retries = 0;
103104
do {
104105
const result = await this.ddbClient.send(
105106
new QueryCommand({
@@ -119,9 +120,15 @@ export default class LetterQueueRepository {
119120
);
120121

121122
const page = z.array(PendingLetterSchema).parse(result.Items);
123+
this.log.info({
124+
description: "Found results",
125+
count: page.length,
126+
retries,
127+
});
122128
letters.push(...page);
123129

124130
lastEvaluatedKey = result.LastEvaluatedKey;
131+
retries += 1;
125132
} while (lastEvaluatedKey !== undefined && letters.length < limit);
126133

127134
return letters.slice(0, limit);

0 commit comments

Comments
 (0)