Skip to content

Commit

Permalink
♻️ Make getAllEvents while loop code more explicit
Browse files Browse the repository at this point in the history
  • Loading branch information
valentinbeggi committed Apr 1, 2022
1 parent fcab1b5 commit 0d5ed2a
Showing 1 changed file with 7 additions and 8 deletions.
15 changes: 7 additions & 8 deletions src/helpers/eventBridge.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import { removeUndefinedMessages } from "./utils/removeUndefinedMessages";
type EventBridgeMessage = { Body?: string };

type EventBridgeEvents = {
Messages?: EventBridgeMessage[];
Messages: EventBridgeMessage[];
};

export default class EventBridge {
Expand Down Expand Up @@ -177,20 +177,19 @@ export default class EventBridge {

async getAllEvents(): Promise<EventBridgeEvents> {
let allEventsFound = false;
const allEventBridgeEvents: EventBridgeEvents = {};
// initialise allEventBridgeEvents at the start of the function
const allEventBridgeEvents: EventBridgeEvents = { Messages: [] };

while (!allEventsFound) {
try {
const lastEventBridgeEvent = await this.getLastEvent();

if (!lastEventBridgeEvents || !lastEventBridgeEvents.Messages) {
return allEventBridgeEvents;
if (!lastEventBridgeEvent || !lastEventBridgeEvent.Messages) {
allEventsFound = true;
break;
}

allEventBridgeEvents.Messages = [
...(allEventBridgeEvents.Messages ?? []),
...lastEventBridgeEvents.Messages,
];
allEventBridgeEvents.Messages.push(...lastEventBridgeEvent.Messages);
} catch (e) {
allEventsFound = true;
}
Expand Down

0 comments on commit 0d5ed2a

Please sign in to comment.