import { describe, it, expect, vi, beforeEach } from 'vitest';
import { createMockMySQLAdapter, createMockQueryResult, createMockRequestContext } from '../../../../__tests__/mocks/index.js';
import type { MySQLAdapter } from '../../MySQLAdapter.js';
import { createLocksResource } from '../locks.js';
describe('Locks Resource', () => {
let mockAdapter: ReturnType<typeof createMockMySQLAdapter>;
let mockContext: ReturnType<typeof createMockRequestContext>;
beforeEach(() => {
vi.clearAllMocks();
mockAdapter = createMockMySQLAdapter();
mockContext = createMockRequestContext();
});
it('should return lock information including waits and statistics', async () => {
// Mock data_lock_waits query
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{
waiting_trx_id: '100',
waiting_thread: 1,
waiting_query: 'SELECT * FROM users FOR UPDATE',
blocking_trx_id: '101',
blocking_thread: 2,
blocking_query: 'UPDATE users SET name = "test"',
wait_seconds: 5
}
]));
// Mock Innodb_row_lock% status query
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ Variable_name: 'Innodb_row_lock_current_waits', Value: '1' },
{ Variable_name: 'Innodb_row_lock_time', Value: '5000' }
]));
const resource = createLocksResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://locks', mockContext) as any;
expect(result.currentLockWaits).toBe(1);
expect(result.lockWaits).toHaveLength(1);
expect(result.lockWaits[0]).toHaveProperty('waiting_trx_id', '100');
expect(result.lockStatistics).toHaveProperty('Innodb_row_lock_current_waits', '1');
});
it('should handle errors gracefully', async () => {
mockAdapter.executeQuery.mockRejectedValue(new Error('Database error'));
const resource = createLocksResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://locks', mockContext) as any;
expect(result).toHaveProperty('error');
expect(result.currentLockWaits).toBe(0);
expect(result.lockWaits).toHaveLength(0);
});
it('should handle empty lock stats', async () => {
// Mock data_lock_waits query
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// Mock Innodb_row_lock% status query returning empty or malformed
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
const resource = createLocksResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://locks', mockContext) as any;
expect(result.currentLockWaits).toBe(0);
expect(result.lockStatistics).toEqual({});
});
it('should handle non-string variable names gracefully', async () => {
// Mock data_lock_waits query
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// Mock Innodb_row_lock% status query with non-string name
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ Variable_name: null, Value: '123' },
{ Variable_name: 123, Value: '456' },
{ Variable_name: 'valid_var', Value: '789' }
]));
const resource = createLocksResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://locks', mockContext) as any;
expect(result.lockStatistics).toEqual({
'valid_var': '789'
});
});
it('should handle undefined rows from query results gracefully', async () => {
// Mock data_lock_waits query returning valid result object but with undefined rows
mockAdapter.executeQuery.mockResolvedValueOnce({
rows: undefined,
rowsAffected: 0,
executionTimeMs: 0
});
// Mock Innodb_row_lock% status query returning valid result but undefined rows
mockAdapter.executeQuery.mockResolvedValueOnce({
rows: undefined,
rowsAffected: 0,
executionTimeMs: 0
});
const resource = createLocksResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://locks', mockContext) as any;
expect(result.currentLockWaits).toBe(0);
expect(result.lockWaits).toEqual([]);
expect(result.lockStatistics).toEqual({});
});
});
