/**
* MySQL Resource - Events
*/
import type { MySQLAdapter } from '../MySQLAdapter.js';
import type { ResourceDefinition, RequestContext } from '../../../types/index.js';
export function createEventsResource(adapter: MySQLAdapter): ResourceDefinition {
return {
uri: 'mysql://events',
name: 'Scheduled Events',
title: 'MySQL Scheduled Events',
description: 'Event Scheduler status and scheduled events overview',
mimeType: 'application/json',
annotations: {
audience: ['user', 'assistant'],
priority: 0.6
},
handler: async (_uri: string, _context: RequestContext) => {
// Get scheduler status
const schedulerResult = await adapter.executeQuery(
"SHOW VARIABLES LIKE 'event_scheduler'"
);
const schedulerRow = schedulerResult.rows?.[0];
const schedulerVal = schedulerRow?.['Value'];
const schedulerStatus = typeof schedulerVal === 'string' ? schedulerVal : 'OFF';
// Get all events
const eventsResult = await adapter.executeQuery(`
SELECT
EVENT_SCHEMA as schema_name,
EVENT_NAME as name,
EVENT_TYPE as type,
STATUS as status,
EXECUTE_AT as execute_at,
INTERVAL_VALUE as interval_value,
INTERVAL_FIELD as interval_field,
LAST_EXECUTED as last_executed
FROM information_schema.EVENTS
ORDER BY EVENT_SCHEMA, EVENT_NAME
`);
return {
schedulerEnabled: schedulerStatus === 'ON',
schedulerStatus,
eventCount: eventsResult.rows?.length ?? 0,
events: eventsResult.rows ?? []
};
}
};
}
