@@ -20,6 +20,28 @@ const buildResponse = (params: { status: number; body?: unknown }): MockResponse
2020};
2121};
222223+function cancelTrackedResponse(
24+text: string,
25+init: ResponseInit,
26+): {
27+response: Response;
28+wasCanceled: () => boolean;
29+} {
30+let canceled = false;
31+const stream = new ReadableStream<Uint8Array>({
32+start(controller) {
33+controller.enqueue(new TextEncoder().encode(text));
34+},
35+cancel() {
36+canceled = true;
37+},
38+});
39+return {
40+response: new Response(stream, init),
41+wasCanceled: () => canceled,
42+};
43+}
44+2345describe("fetchPluralKitMessageInfo", () => {
2446it("returns null when disabled", async () => {
2547const fetcher = vi.fn();
@@ -65,4 +87,30 @@ describe("fetchPluralKitMessageInfo", () => {
6587expect(result?.member?.id).toBe("mem_1");
6688expect(receivedHeaders?.Authorization).toBe("pk_test");
6789});
90+91+it("bounds PluralKit API error bodies without using response.text()", async () => {
92+const tracked = cancelTrackedResponse(`${"plural failure ".repeat(1024)}tail`, {
93+status: 500,
94+headers: { "content-type": "text/plain" },
95+});
96+const textSpy = vi.spyOn(tracked.response, "text").mockRejectedValue(new Error("unbounded"));
97+const fetcher = vi.fn(async () => tracked.response);
98+99+let caught: Error | undefined;
100+try {
101+await fetchPluralKitMessageInfo({
102+messageId: "boom",
103+config: { enabled: true },
104+fetcher: fetcher as unknown as typeof fetch,
105+});
106+} catch (error) {
107+caught = error as Error;
108+}
109+110+expect(caught?.message).toContain("PluralKit API failed (500): plural failure");
111+expect(caught?.message).not.toContain("tail");
112+expect(caught?.message.length).toBeLessThan(8_400);
113+expect(tracked.wasCanceled()).toBe(true);
114+expect(textSpy).not.toHaveBeenCalled();
115+});
68116});
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。