chore: Fix hanging test.

This commit is contained in:
cpojer
2026-02-17 15:56:51 +09:00
parent 73668bb963
commit 5649e403df

View File

@@ -185,24 +185,27 @@ describe("mattermost websocket monitor", () => {
webSocketFactory: () => socket, webSocketFactory: () => socket,
}); });
socket.emitOpen(); const connected = connectOnce();
socket.emitMessage( queueMicrotask(() => {
Buffer.from( socket.emitOpen();
JSON.stringify({ socket.emitMessage(
event: "reaction_added", Buffer.from(
data: { JSON.stringify({
reaction: JSON.stringify({ event: "reaction_added",
user_id: "user-1", data: {
post_id: "post-1", reaction: JSON.stringify({
emoji_name: "thumbsup", user_id: "user-1",
}), post_id: "post-1",
}, emoji_name: "thumbsup",
}), }),
), },
); }),
socket.emitClose(1000); ),
);
socket.emitClose(1000);
});
await connectOnce(); await connected;
expect(onReaction).toHaveBeenCalledTimes(1); expect(onReaction).toHaveBeenCalledTimes(1);
expect(onPosted).not.toHaveBeenCalled(); expect(onPosted).not.toHaveBeenCalled();