Flaky queued Notifications test (#357)

* fix: OwnSharedAttributeDeletedByOwnerNotificationItem not yet processed * fix: did not wait for running Message received event handler
nmshd · Dec 4, 2024 · c3f5ac2 · c3f5ac2
1 parent 20398db
commit c3f5ac2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/packages/runtime/test/transport/messages.test.ts b/packages/runtime/test/transport/messages.test.ts
@@ -11,6 +11,7 @@ import {
     MessageReceivedEvent,
     MessageSentEvent,
     MessageWasReadAtChangedEvent,
+    OwnSharedAttributeDeletedByOwnerEvent,
     OwnSharedAttributeSucceededEvent,
     PeerDeletionCancelledEvent,
     PeerToBeDeletedEvent,
@@ -448,6 +449,7 @@ describe("Postponed Notifications via Messages", () => {
 
             const postponedMessages = await syncUntilHasMessages(client5.transport);
             expect(postponedMessages).toHaveLength(1);
+            await client5.eventBus.waitForRunningEventHandlers();
             const postponedNotification = await client5.consumption.notifications.getNotification({ id: notificationId.toString() });
             expect(postponedNotification).toBeSuccessful();
         });
@@ -508,6 +510,8 @@ describe("Postponed Notifications via Messages", () => {
             const postponedDeletionNotification = await client5.consumption.notifications.getNotification({ id: notifyAboutDeletionResult.notificationId });
             expect(postponedDeletionNotification).toBeSuccessful();
 
+            await client5.eventBus.waitForEvent(OwnSharedAttributeDeletedByOwnerEvent);
+
             const peerSharedIdentityAttribute = (await client5.consumption.attributes.getAttribute({ id: ownSharedIdentityAttribute.id })).value;
             assert(peerSharedIdentityAttribute.succeededBy);
             assert(peerSharedIdentityAttribute.deletionInfo?.deletionDate);