import { describe, it, expect, vi, beforeEach } from 'vitest';
import { createMockMySQLAdapter, createMockQueryResult, createMockRequestContext } from '../../../../__tests__/mocks/index.js';
import type { MySQLAdapter } from '../../MySQLAdapter.js';
import { createReplicationResource } from '../replication.js';
describe('Replication Resource', () => {
let mockAdapter: ReturnType<typeof createMockMySQLAdapter>;
let mockContext: ReturnType<typeof createMockRequestContext>;
beforeEach(() => {
vi.clearAllMocks();
mockAdapter = createMockMySQLAdapter();
mockContext = createMockRequestContext();
});
it('should handle empty result sets gracefully', async () => {
// SHOW REPLICA STATUS (returns empty array)
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// Fallback: SHOW SLAVE STATUS (returns empty array)
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// SHOW BINARY LOG STATUS (returns empty array)
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// Fallback: SHOW MASTER STATUS (returns empty array)
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// GTID (fails or empty)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('No GTID'));
// SHOW REPLICAS (empty)
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
const resource = createReplicationResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://replication', mockContext) as any;
expect(result.role).toBe('standalone');
expect(result.source).toBeNull();
expect(result.replica).toBeNull();
});
it('should return source role info correctly', async () => {
// SHOW REPLICA STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('Not found'));
// SHOW SLAVE STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('Not found'));
// SHOW BINARY LOG STATUS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ File: 'bin.001', Position: 100, Binlog_Do_DB: '', Binlog_Ignore_DB: '' }
]));
// GTID
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// SHOW REPLICAS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ Host: 'slave1' }
]));
const resource = createReplicationResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://replication', mockContext) as any;
expect(result.role).toBe('source');
expect(result.source).toBeDefined();
expect(result.connected_replicas).toHaveLength(1);
});
it('should return replica role info correctly', async () => {
// SHOW REPLICA STATUS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ Source_Host: 'master1', Slave_IO_Running: 'Yes', Slave_SQL_Running: 'Yes', Seconds_Behind_Master: 0 }
]));
// SHOW BINARY LOG STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('Not source'));
// SHOW MASTER STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('Not source'));
// GTID
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// SHOW REPLICAS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('Not source'));
// SHOW SLAVE HOSTS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('Not source'));
const resource = createReplicationResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://replication', mockContext) as any;
expect(result.role).toBe('replica');
expect(result.replica).toBeDefined();
expect(result.replica.source_host).toBe('master1');
});
it('should handle replica-source role', async () => {
// SHOW REPLICA STATUS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ Source_Host: 'master1' }
]));
// SHOW BINARY LOG STATUS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ File: 'bin.001' }
]));
// GTID
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// SHOW REPLICAS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
const resource = createReplicationResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://replication', mockContext) as any;
expect(result.role).toBe('replica-source');
expect(result.gtid).toEqual({});
});
it('should parse GTID information', async () => {
// SHOW REPLICA STATUS (fail - not a replica)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('Not a replica'));
// SHOW SLAVE STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('Not a replica'));
// SHOW BINARY LOG STATUS (source)
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ File: 'bin.001' }
]));
// GTID
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ Variable_name: 'gtid_mode', Value: 'ON' },
{ Variable_name: 'gtid_executed', Value: 'uuid:1-100' }
]));
// SHOW REPLICAS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
const resource = createReplicationResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://replication', mockContext) as any;
expect(result.role).toBe('source');
expect(result.gtid).toEqual({
gtid_mode: 'ON',
gtid_executed: 'uuid:1-100'
});
});
it('should fallback to older syntax for replicas', async () => {
// SHOW REPLICA STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('Syntax error'));
// SHOW SLAVE STATUS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ Master_Host: 'master1' }
]));
// SHOW BINARY LOG STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('fail'));
// SHOW MASTER STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('fail'));
// GTID
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// SHOW REPLICAS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('fail'));
// SHOW SLAVE HOSTS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('fail'));
const resource = createReplicationResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://replication', mockContext) as any;
expect(result.replica).toBeDefined();
expect(result.replica.source_host).toBe('master1');
});
it('should fallback to older syntax for source', async () => {
// SHOW REPLICA STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('fail'));
// SHOW SLAVE STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('fail'));
// SHOW BINARY LOG STATUS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('fail'));
// SHOW MASTER STATUS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ File: 'bin.001' }
]));
// GTID
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([]));
// SHOW REPLICAS (fail)
mockAdapter.executeQuery.mockRejectedValueOnce(new Error('fail'));
// SHOW SLAVE HOSTS
mockAdapter.executeQuery.mockResolvedValueOnce(createMockQueryResult([
{ Host: 'slave1' }
]));
const resource = createReplicationResource(mockAdapter as unknown as MySQLAdapter);
const result = await resource.handler('mysql://replication', mockContext) as any;
expect(result.role).toBe('source');
expect(result.connected_replicas).toHaveLength(1);
});
});
