import { describe, it, expect, vi, beforeEach } from "vitest";
import { createEventsResource } from "../events.js";
import type { MySQLAdapter } from "../../MySQLAdapter.js";
import {
createMockMySQLAdapter,
createMockRequestContext,
createMockQueryResult,
} from "../../../../__tests__/mocks/index.js";
describe("createEventsResource", () => {
let mockAdapter: ReturnType<typeof createMockMySQLAdapter>;
let mockContext: ReturnType<typeof createMockRequestContext>;
let resource: ReturnType<typeof createEventsResource>;
beforeEach(() => {
vi.clearAllMocks();
mockAdapter = createMockMySQLAdapter();
mockContext = createMockRequestContext();
resource = createEventsResource(mockAdapter as unknown as MySQLAdapter);
});
it("should return scheduler enabled when variable is ON", async () => {
// Mock scheduler variable
mockAdapter.executeQuery.mockResolvedValueOnce(
createMockQueryResult([
{ Variable_name: "event_scheduler", Value: "ON" },
]),
);
// Mock events list
mockAdapter.executeQuery.mockResolvedValueOnce(
createMockQueryResult([
{ schema_name: "test", name: "event1", status: "ENABLED" },
]),
);
const result = await resource.handler(resource.uri, mockContext);
expect(result).toEqual({
schedulerEnabled: true,
schedulerStatus: "ON",
eventCount: 1,
events: [{ schema_name: "test", name: "event1", status: "ENABLED" }],
});
});
it("should return scheduler disabled when variable is OFF", async () => {
// Mock scheduler variable
mockAdapter.executeQuery.mockResolvedValueOnce(
createMockQueryResult([
{ Variable_name: "event_scheduler", Value: "OFF" },
]),
);
// Mock events list
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
const result = await resource.handler(resource.uri, mockContext);
expect(result).toEqual({
schedulerEnabled: false,
schedulerStatus: "OFF",
eventCount: 0,
events: [],
});
});
it("should handle missing variable execution gracefully (default OFF)", async () => {
// Mock scheduler variable empty result
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// Mock events list
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
const result = await resource.handler(resource.uri, mockContext);
expect(result).toEqual({
schedulerEnabled: false,
schedulerStatus: "OFF",
eventCount: 0,
events: [],
});
});
it("should propagate errors since no try/catch in handler", async () => {
mockAdapter.executeQuery.mockRejectedValue(new Error("DB Error"));
await expect(resource.handler(resource.uri, mockContext)).rejects.toThrow(
"DB Error",
);
});
it("should handle undefined rows gracefully", async () => {
// Mock scheduler variable with undefined rows
mockAdapter.executeQuery.mockResolvedValueOnce({ rows: undefined } as any);
// Mock events list with undefined rows
mockAdapter.executeQuery.mockResolvedValueOnce({ rows: undefined } as any);
const result = await resource.handler(resource.uri, mockContext);
expect(result).toEqual({
schedulerEnabled: false,
schedulerStatus: "OFF",
eventCount: 0,
events: [],
});
});
});
