diff --git a/packages/stream-management/stream-features.test.js b/packages/stream-management/stream-features.test.js index f30c572d..1439a25d 100644 --- a/packages/stream-management/stream-features.test.js +++ b/packages/stream-management/stream-features.test.js @@ -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( + + + , + ); + + expect(await entity.catchOutgoing()).toEqual( + , + ); + + entity.mockInput( + + + , + ); + + 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;