/**
* MySQL Resource - Cluster
*/
import type { MySQLAdapter } from '../MySQLAdapter.js';
import type { ResourceDefinition, RequestContext } from '../../../types/index.js';
export function createClusterResource(adapter: MySQLAdapter): ResourceDefinition {
return {
uri: 'mysql://cluster',
name: 'Cluster Status',
title: 'MySQL Group Replication / InnoDB Cluster',
description: 'Group Replication and InnoDB Cluster status overview',
mimeType: 'application/json',
annotations: {
audience: ['user', 'assistant'],
priority: 0.7
},
handler: async (_uri: string, _context: RequestContext) => {
try {
// Check if Group Replication is enabled
const grStatusResult = await adapter.executeQuery(
"SHOW VARIABLES LIKE 'group_replication_group_name'"
);
const grRow = grStatusResult.rows?.[0];
const groupNameVal = grRow?.['Value'];
const groupName = typeof groupNameVal === 'string' ? groupNameVal : null;
if (groupName === null || groupName === '') {
return {
groupReplicationEnabled: false,
message: 'Group Replication is not configured'
};
}
// Get members
const membersResult = await adapter.executeQuery(`
SELECT
MEMBER_ID as id,
MEMBER_HOST as host,
MEMBER_PORT as port,
MEMBER_STATE as state,
MEMBER_ROLE as role,
MEMBER_VERSION as version
FROM performance_schema.replication_group_members
`);
// Get primary
const primaryResult = await adapter.executeQuery(`
SELECT MEMBER_HOST as host, MEMBER_PORT as port
FROM performance_schema.replication_group_members
WHERE MEMBER_ROLE = 'PRIMARY'
`);
const primaryRow = primaryResult.rows?.[0];
return {
groupReplicationEnabled: true,
groupName,
memberCount: membersResult.rows?.length ?? 0,
members: membersResult.rows ?? [],
primary: primaryRow ? `${String(primaryRow['host'])}:${String(primaryRow['port'])}` : null
};
} catch {
return {
groupReplicationEnabled: false,
message: 'Unable to retrieve cluster information',
suggestion: 'Group Replication may not be configured or insufficient privileges'
};
}
}
};
}
