5682ec37fa
* refactor: move Discord channel implementation to extensions/discord/src/ Move all Discord source files from src/discord/ to extensions/discord/src/, following the extension migration pattern. Source files in src/discord/ are replaced with re-export shims. Channel-plugin files from src/channels/plugins/*/discord* are similarly moved and shimmed. - Copy all .ts source files preserving subdirectory structure (monitor/, voice/) - Move channel-plugin files (actions, normalize, onboarding, outbound, status-issues) - Fix all relative imports to use correct paths from new location - Create re-export shims at original locations for backward compatibility - Delete test files from shim locations (tests live in extension now) - Update tsconfig.plugin-sdk.dts.json rootDir from "src" to "." to accommodate extension files outside src/ - Update write-plugin-sdk-entry-dts.ts to match new declaration output paths * fix: add importOriginal to thread-bindings session-meta mock for extensions test * style: fix formatting in thread-bindings lifecycle test
73 lines
2.1 KiB
TypeScript
73 lines
2.1 KiB
TypeScript
import { describe, expect, it } from "vitest";
|
|
import { withFetchPreconnect } from "../../../src/test-utils/fetch-mock.js";
|
|
import { fetchDiscord } from "./api.js";
|
|
import { jsonResponse } from "./test-http-helpers.js";
|
|
|
|
describe("fetchDiscord", () => {
|
|
it("formats rate limit payloads without raw JSON", async () => {
|
|
const fetcher = withFetchPreconnect(async () =>
|
|
jsonResponse(
|
|
{
|
|
message: "You are being rate limited.",
|
|
retry_after: 0.631,
|
|
global: false,
|
|
},
|
|
429,
|
|
),
|
|
);
|
|
|
|
let error: unknown;
|
|
try {
|
|
await fetchDiscord("/users/@me/guilds", "test", fetcher, {
|
|
retry: { attempts: 1 },
|
|
});
|
|
} catch (err) {
|
|
error = err;
|
|
}
|
|
|
|
const message = String(error);
|
|
expect(message).toContain("Discord API /users/@me/guilds failed (429)");
|
|
expect(message).toContain("You are being rate limited.");
|
|
expect(message).toContain("retry after 0.6s");
|
|
expect(message).not.toContain("{");
|
|
expect(message).not.toContain("retry_after");
|
|
});
|
|
|
|
it("preserves non-JSON error text", async () => {
|
|
const fetcher = withFetchPreconnect(async () => new Response("Not Found", { status: 404 }));
|
|
await expect(
|
|
fetchDiscord("/users/@me/guilds", "test", fetcher, {
|
|
retry: { attempts: 1 },
|
|
}),
|
|
).rejects.toThrow("Discord API /users/@me/guilds failed (404): Not Found");
|
|
});
|
|
|
|
it("retries rate limits before succeeding", async () => {
|
|
let calls = 0;
|
|
const fetcher = withFetchPreconnect(async () => {
|
|
calls += 1;
|
|
if (calls === 1) {
|
|
return jsonResponse(
|
|
{
|
|
message: "You are being rate limited.",
|
|
retry_after: 0,
|
|
global: false,
|
|
},
|
|
429,
|
|
);
|
|
}
|
|
return jsonResponse([{ id: "1", name: "Guild" }], 200);
|
|
});
|
|
|
|
const result = await fetchDiscord<Array<{ id: string; name: string }>>(
|
|
"/users/@me/guilds",
|
|
"test",
|
|
fetcher,
|
|
{ retry: { attempts: 2, minDelayMs: 0, maxDelayMs: 0 } },
|
|
);
|
|
|
|
expect(result).toHaveLength(1);
|
|
expect(calls).toBe(2);
|
|
});
|
|
});
|