Stabilize IdentityDeletionPeerProcessing test (#273)

nmshd · Sep 17, 2024 · 62c1735 · 62c1735
1 parent 4cf8873
commit 62c1735
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/packages/runtime/test/transport/identityDeletionPeerProcessing.test.ts b/packages/runtime/test/transport/identityDeletionPeerProcessing.test.ts
@@ -43,6 +43,7 @@ describe("IdentityDeletionProcess", () => {
         await services1.transport.identityDeletionProcesses.initiateIdentityDeletionProcess();
 
         await syncUntilHasEvent(services2, PeerToBeDeletedEvent, (e) => e.data.id === relationshipId);
+        await services2.eventBus.waitForRunningEventHandlers();
 
         const updatedRelationship = (await services2.transport.relationships.getRelationship({ id: relationshipId })).value;
         expect(updatedRelationship.peerDeletionInfo!.deletionStatus).toBe(PeerDeletionStatus.ToBeDeleted);
@@ -53,6 +54,7 @@ describe("IdentityDeletionProcess", () => {
         await services1.transport.identityDeletionProcesses.cancelIdentityDeletionProcess();
 
         await syncUntilHasEvent(services2, PeerDeletionCancelledEvent, (e) => e.data.id === relationshipId);
+        await services2.eventBus.waitForRunningEventHandlers();
 
         const updatedRelationship = (await services2.transport.relationships.getRelationship({ id: relationshipId })).value;
         expect(updatedRelationship.peerDeletionInfo).toBeUndefined();