import { describe, it, expect, vi, beforeEach } from "vitest";
import { createStatusResource } from "../status.js";
import type { MySQLAdapter } from "../../MySQLAdapter.js";
import {
createMockMySQLAdapter,
createMockRequestContext,
createMockQueryResult,
} from "../../../../__tests__/mocks/index.js";
describe("Status Resource", () => {
let mockAdapter: ReturnType<typeof createMockMySQLAdapter>;
let mockContext: ReturnType<typeof createMockRequestContext>;
beforeEach(() => {
vi.clearAllMocks();
mockAdapter = createMockMySQLAdapter();
mockContext = createMockRequestContext();
});
it("should map query results to status object", async () => {
mockAdapter.executeQuery.mockResolvedValueOnce(
createMockQueryResult([
{ Variable_name: "Uptime", Value: "1000" },
{ Variable_name: "Threads_connected", Value: "5" },
]),
);
const resource = createStatusResource(
mockAdapter as unknown as MySQLAdapter,
);
const result = await resource.handler("mysql://status", mockContext);
expect(result).toEqual({
status: {
Uptime: "1000",
Threads_connected: "5",
},
});
expect(mockAdapter.executeQuery).toHaveBeenCalledWith("SHOW GLOBAL STATUS");
});
it("should handle empty results", async () => {
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
const resource = createStatusResource(
mockAdapter as unknown as MySQLAdapter,
);
const result = await resource.handler("mysql://status", mockContext);
expect(result).toEqual({ status: {} });
});
it("should handle null query results", async () => {
mockAdapter.executeQuery.mockResolvedValueOnce(
createMockQueryResult(null as any),
);
const resource = createStatusResource(
mockAdapter as unknown as MySQLAdapter,
);
const result = await resource.handler("mysql://status", mockContext);
expect(result).toEqual({ status: {} });
});
it("should propagate errors", async () => {
mockAdapter.executeQuery.mockRejectedValue(new Error("Connection failed"));
const resource = createStatusResource(
mockAdapter as unknown as MySQLAdapter,
);
await expect(
resource.handler("mysql://status", mockContext),
).rejects.toThrow("Connection failed");
});
});
