@@ -947,12 +947,11 @@ describe("deliverOutboundPayloads", () => {
947947queuePolicy: "best_effort",
948948});
949949950-expect(afterCommit).toHaveBeenCalledWith(
951-expect.objectContaining({
952-kind: "text",
953-result: expect.objectContaining({ messageId: "message-adapter-1" }),
954-}),
955-);
950+const [[commitParams]] = afterCommit.mock.calls as unknown as Array<
951+[Record<string, unknown> & { result?: { messageId?: string } }]
952+>;
953+expect(commitParams?.kind).toBe("text");
954+expect(commitParams?.result?.messageId).toBe("message-adapter-1");
956955expect(queueMocks.ackDelivery).not.toHaveBeenCalled();
957956});
958957@@ -1043,23 +1042,20 @@ describe("deliverOutboundPayloads", () => {
10431042unsubscribe();
10441043}
104510441046-const deliveryEvents = events.filter((event) => event.type.startsWith("message.delivery."));
1047-expect(deliveryEvents).toEqual([
1048-expect.objectContaining({
1049-type: "message.delivery.started",
1050-channel: "matrix",
1051-deliveryKind: "text",
1052-sessionKey: "session-1",
1053-}),
1054-expect.objectContaining({
1055-type: "message.delivery.completed",
1056-channel: "matrix",
1057-deliveryKind: "text",
1058-durationMs: expect.any(Number),
1059-resultCount: 1,
1060-sessionKey: "session-1",
1061-}),
1062-]);
1045+const deliveryEvents = events.filter((event) =>
1046+event.type.startsWith("message.delivery."),
1047+) as Array<Record<string, unknown>>;
1048+expect(deliveryEvents).toHaveLength(2);
1049+expect(deliveryEvents[0]?.type).toBe("message.delivery.started");
1050+expect(deliveryEvents[0]?.channel).toBe("matrix");
1051+expect(deliveryEvents[0]?.deliveryKind).toBe("text");
1052+expect(deliveryEvents[0]?.sessionKey).toBe("session-1");
1053+expect(deliveryEvents[1]?.type).toBe("message.delivery.completed");
1054+expect(deliveryEvents[1]?.channel).toBe("matrix");
1055+expect(deliveryEvents[1]?.deliveryKind).toBe("text");
1056+expect(typeof deliveryEvents[1]?.durationMs).toBe("number");
1057+expect(deliveryEvents[1]?.resultCount).toBe(1);
1058+expect(deliveryEvents[1]?.sessionKey).toBe("session-1");
10631059expect(JSON.stringify(deliveryEvents)).not.toContain("secret delivery body");
10641060expect(JSON.stringify(deliveryEvents)).not.toContain("!room:example");
10651061});
@@ -1086,17 +1082,15 @@ describe("deliverOutboundPayloads", () => {
10861082unsubscribe();
10871083}
108810841089-const errorEvent = events.find((event) => event.type === "message.delivery.error");
1090-expect(errorEvent).toEqual(
1091-expect.objectContaining({
1092-type: "message.delivery.error",
1093-channel: "matrix",
1094-deliveryKind: "text",
1095-durationMs: expect.any(Number),
1096-errorCategory: "TypeError",
1097-sessionKey: "session-1",
1098-}),
1099-);
1085+const errorEvent = events.find((event) => event.type === "message.delivery.error") as
1086+| Record<string, unknown>
1087+| undefined;
1088+expect(errorEvent?.type).toBe("message.delivery.error");
1089+expect(errorEvent?.channel).toBe("matrix");
1090+expect(errorEvent?.deliveryKind).toBe("text");
1091+expect(typeof errorEvent?.durationMs).toBe("number");
1092+expect(errorEvent?.errorCategory).toBe("TypeError");
1093+expect(errorEvent?.sessionKey).toBe("session-1");
11001094expect(
11011095JSON.stringify(events.filter((event) => event.type.startsWith("message.delivery."))),
11021096).not.toContain("secret delivery body");
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。