@@ -26,36 +26,34 @@ import {
|
26 | 26 | resolveDurableInboundReplyToId, |
27 | 27 | } from "./durable-delivery.js"; |
28 | 28 | |
29 | | -function latestSendDurableMessageBatchRequest(): { |
| 29 | +type SendDurableMessageBatchRequest = { |
30 | 30 | cfg?: unknown; |
31 | 31 | channel?: string; |
32 | 32 | to?: string; |
33 | 33 | threadId?: string | number | null; |
34 | 34 | durability?: string; |
35 | | -} { |
36 | | -const [request] = mocks.sendDurableMessageBatch.mock.calls.at(-1) as unknown as [ |
37 | | -{ |
38 | | -cfg?: unknown; |
39 | | -channel?: string; |
40 | | -to?: string; |
41 | | -threadId?: string | number | null; |
42 | | -durability?: string; |
43 | | -}, |
44 | | -]; |
45 | | -return request; |
46 | | -} |
| 35 | +}; |
47 | 36 | |
48 | | -function latestDeliverySupportRequest(): { |
| 37 | +type DeliverySupportRequest = { |
49 | 38 | requirements?: Record<string, boolean>; |
50 | | -} { |
51 | | -const [request] = mocks.resolveOutboundDurableFinalDeliverySupport.mock.calls.at( |
52 | | --1, |
53 | | -) as unknown as [ |
54 | | -{ |
55 | | -requirements?: Record<string, boolean>; |
56 | | -}, |
57 | | -]; |
58 | | -return request; |
| 39 | +}; |
| 40 | + |
| 41 | +function latestSendDurableMessageBatchRequest(): SendDurableMessageBatchRequest { |
| 42 | +const calls = mocks.sendDurableMessageBatch.mock.calls; |
| 43 | +const request = calls[calls.length - 1]?.[0]; |
| 44 | +if (!request || typeof request !== "object") { |
| 45 | +throw new Error("expected sendDurableMessageBatch request"); |
| 46 | +} |
| 47 | +return request as SendDurableMessageBatchRequest; |
| 48 | +} |
| 49 | + |
| 50 | +function latestDeliverySupportRequest(): DeliverySupportRequest { |
| 51 | +const calls = mocks.resolveOutboundDurableFinalDeliverySupport.mock.calls; |
| 52 | +const request = calls[calls.length - 1]?.[0]; |
| 53 | +if (!request || typeof request !== "object") { |
| 54 | +throw new Error("expected delivery support request"); |
| 55 | +} |
| 56 | +return request as DeliverySupportRequest; |
59 | 57 | } |
60 | 58 | |
61 | 59 | describe("durable inbound reply delivery", () => { |
|
