Skip to content

Commit

Permalink
Test failure with something in queue seperately
Browse files Browse the repository at this point in the history
  • Loading branch information
singpolyma committed Jan 8, 2025
1 parent c08cab8 commit 6ff7e81
Showing 1 changed file with 34 additions and 0 deletions.
34 changes: 34 additions & 0 deletions packages/stream-management/stream-features.test.js
Original file line number Diff line number Diff line change
Expand Up @@ -238,6 +238,40 @@ test("resume - resumed", async () => {
test("resume - failed", async () => {
const { entity } = mockClient();

entity.status = "bar";
entity.streamManagement.id = "bar";
entity.streamManagement.enabled = true;
entity.streamManagement.outbound = 45;
entity.streamManagement.outbound_q = [];

entity.mockInput(
<features xmlns="http://etherx.jabber.org/streams">
<sm xmlns="urn:xmpp:sm:3" />
</features>,
);

expect(await entity.catchOutgoing()).toEqual(
<resume xmlns="urn:xmpp:sm:3" previd="bar" h="0" />,
);

entity.mockInput(
<failed xmlns="urn:xmpp:sm:3">
<unexpected-request xmlns="urn:ietf:params:xml:ns:xmpp-stanzas" />
</failed>,
);

await tick();

expect(entity.status).toBe("bar");
expect(entity.streamManagement.id).toBe("");
expect(entity.streamManagement.enabled).toBe(false);
expect(entity.streamManagement.outbound).toBe(0);
expect(entity.streamManagement.outbound_q).toBeEmpty();
});

test("resume - failed with something in queue", async () => {
const { entity } = mockClient();

entity.status = "bar";
entity.streamManagement.id = "bar";
entity.streamManagement.enabled = true;
Expand Down

0 comments on commit 6ff7e81

Please sign in to comment.