import { describe, expect, it } from "vitest";
import "./setup.js";
import { ClickUpGateway } from "../src/infrastructure/clickup/ClickUpGateway.js";
import type { ClickUpGatewayConfig } from "../src/infrastructure/clickup/ClickUpGateway.js";
import { HttpClient } from "../src/infrastructure/http/HttpClient.js";
import type { HttpRequest, HttpResponse } from "../src/infrastructure/http/HttpClient.js";
import { ApiCache } from "../src/infrastructure/cache/ApiCache.js";
import { makeMemoryKV } from "../src/shared/KV.js";
describe("ClickUpGateway", () => {
const config: ClickUpGatewayConfig = {
baseUrl: "https://api.clickup.com",
token: "tok123",
authScheme: "personal_token",
timeoutMs: 5000,
defaultTeamId: 101
};
it("uses cache when searching docs", async () => {
const kv = makeMemoryKV();
const cache = new ApiCache(kv);
const calls: HttpRequest[] = [];
const client = new HttpClient({
baseUrl: config.baseUrl,
transport: async request => {
calls.push(request);
const response: HttpResponse = {
status: 200,
headers: {},
data: { total: 1, items: [{ id: "d1" }] }
};
return response;
}
});
const gateway = new ClickUpGateway(client, cache, config);
const first = await gateway.search_docs(7, "roadmap", 20, 0);
const second = await gateway.search_docs(7, "roadmap", 20, 0);
expect(first).toEqual({ total: 1, items: [{ id: "d1" }] });
expect(second).toEqual(first);
expect(calls.length).toBe(1);
});
it("paginates task fetch and stops when empty", async () => {
const kv = makeMemoryKV();
const cache = new ApiCache(kv);
const calls: HttpRequest[] = [];
const responses: HttpResponse[] = [
{ status: 200, headers: {}, data: { tasks: Array.from({ length: 100 }, (_, index) => ({ id: `t${index}` })) } },
{ status: 200, headers: {}, data: { tasks: [] } }
];
const client = new HttpClient({
baseUrl: config.baseUrl,
transport: async request => {
calls.push(request);
const response = responses.shift();
if (!response) {
throw new Error("No more responses");
}
return response;
}
});
const gateway = new ClickUpGateway(client, cache, config);
const tasks = await gateway.fetch_tasks_for_index();
expect(tasks.length).toBe(100);
expect(calls.length).toBe(2);
});
it("forwards personal token when auto scheme chooses it", async () => {
const kv = makeMemoryKV();
const cache = new ApiCache(kv);
const calls: HttpRequest[] = [];
const client = new HttpClient({
baseUrl: config.baseUrl,
transport: async request => {
calls.push(request);
const response: HttpResponse = { status: 200, headers: {}, data: { id: "task" } };
return response;
}
});
const autoConfig: ClickUpGatewayConfig = { ...config, authScheme: "auto", token: "tok123" };
const gateway = new ClickUpGateway(client, cache, autoConfig);
const task = await gateway.get_task_by_id("task123");
expect(task).toEqual({ id: "task" });
expect(calls.length).toBe(1);
expect(calls[0].headers?.Authorization).toBe("tok123");
});
it("does not incorrectly prefix Bearer for long personal tokens", async () => {
const kv = makeMemoryKV();
const cache = new ApiCache(kv);
const calls: HttpRequest[] = [];
const client = new HttpClient({
baseUrl: config.baseUrl,
transport: async request => {
calls.push(request);
const response: HttpResponse = { status: 200, headers: {}, data: { id: "task" } };
return response;
}
});
const personalToken = "pk_abcdefghijklmnopqrstuvwxyz0123456789TOKEN";
const autoConfig: ClickUpGatewayConfig = { ...config, authScheme: "auto", token: personalToken };
const gateway = new ClickUpGateway(client, cache, autoConfig);
await gateway.get_task_by_id("task123");
expect(calls.length).toBe(1);
expect(calls[0].headers?.Authorization).toBe(personalToken);
});
it("prefers Bearer for JWT-style tokens when auto-detected", async () => {
const kv = makeMemoryKV();
const cache = new ApiCache(kv);
const calls: HttpRequest[] = [];
const client = new HttpClient({
baseUrl: config.baseUrl,
transport: async request => {
calls.push(request);
const response: HttpResponse = { status: 200, headers: {}, data: { id: "task" } };
return response;
}
});
const jwtToken = "aaa.bbb.ccc";
const autoConfig: ClickUpGatewayConfig = { ...config, authScheme: "auto", token: jwtToken };
const gateway = new ClickUpGateway(client, cache, autoConfig);
await gateway.get_task_by_id("task123");
expect(calls.length).toBe(1);
expect(calls[0].headers?.Authorization).toBe(`Bearer ${jwtToken}`);
});
});
