f8d89e81d1
Reverts 7c5ca7f6 production-migration edits (load_initial_schema withinTransaction=false + try/catch, idempotency guards) and coupled migrate:fresh guard tests to baseline; imitation suite uses DatabaseTransactions on a pre-migrated DB so the reverted migrate:fresh resilience is not needed for Phase 1. Also drops the orphaned ensureMonth webhook_log test (webhook_log removed from PARTITIONED_TABLES in 2026_05_24_140000_drop_legacy_webhook_artefacts).
141 lines
5.9 KiB
PHP
141 lines
5.9 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
use App\Services\MonthlyPartitionManager;
|
||
use Illuminate\Foundation\Testing\DatabaseTransactions;
|
||
use Illuminate\Support\Carbon;
|
||
use Illuminate\Support\Facades\DB;
|
||
use Tests\Concerns\SharesSupplierPdo;
|
||
|
||
uses(DatabaseTransactions::class, SharesSupplierPdo::class);
|
||
// ensureMonth теперь делает CREATE через pgsql_supplier (см. MonthlyPartitionManager::DDL_CONNECTION).
|
||
// Без SharesSupplierPdo DDL уйдёт мимо test-транзакции и партиции протечь в test DB.
|
||
|
||
function partitionExists(string $name): bool
|
||
{
|
||
return DB::selectOne(
|
||
"SELECT 1 AS ok FROM pg_class WHERE relname = ? AND relkind = 'r'",
|
||
[$name],
|
||
) !== null;
|
||
}
|
||
|
||
// ---------------------------------------------------------------------------
|
||
// Existing tests (deals — business table, received_at key)
|
||
// ---------------------------------------------------------------------------
|
||
|
||
test('ensureRange создаёт месячные партиции deals под диапазон', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
|
||
$created = $manager->ensureRange(
|
||
'deals',
|
||
Carbon::parse('2024-02-15'),
|
||
Carbon::parse('2024-04-03'),
|
||
);
|
||
|
||
expect($created)->toBeGreaterThanOrEqual(3)
|
||
->and(partitionExists('deals_y2024_m02'))->toBeTrue()
|
||
->and(partitionExists('deals_y2024_m03'))->toBeTrue()
|
||
->and(partitionExists('deals_y2024_m04'))->toBeTrue();
|
||
});
|
||
|
||
test('ensureRange идемпотентна — повторный вызов не падает', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
|
||
$manager->ensureRange('deals', Carbon::parse('2024-02-15'), Carbon::parse('2024-02-20'));
|
||
$secondRun = $manager->ensureRange('deals', Carbon::parse('2024-02-15'), Carbon::parse('2024-02-20'));
|
||
|
||
expect($secondRun)->toBe(0); // всё уже существует
|
||
});
|
||
|
||
test('ensureRange отвергает неизвестную таблицу', function (): void {
|
||
app(MonthlyPartitionManager::class)->ensureRange('orders', now(), now());
|
||
})->throws(InvalidArgumentException::class);
|
||
|
||
// ---------------------------------------------------------------------------
|
||
// Hole #2 tests: audit tables (created_at key)
|
||
// ---------------------------------------------------------------------------
|
||
|
||
test('ensureMonth создаёт партицию auth_log (created_at)', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
$month = Carbon::parse('2024-03-01');
|
||
|
||
$manager->ensureMonth('auth_log', $month);
|
||
|
||
expect(partitionExists('auth_log_y2024_m03'))->toBeTrue();
|
||
});
|
||
|
||
test('ensureMonth создаёт партицию activity_log (created_at)', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
$manager->ensureMonth('activity_log', Carbon::parse('2024-03-01'));
|
||
|
||
expect(partitionExists('activity_log_y2024_m03'))->toBeTrue();
|
||
});
|
||
|
||
test('ensureMonth создаёт партицию tenant_operations_log (created_at)', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
$manager->ensureMonth('tenant_operations_log', Carbon::parse('2024-03-01'));
|
||
|
||
expect(partitionExists('tenant_operations_log_y2024_m03'))->toBeTrue();
|
||
});
|
||
|
||
test('ensureMonth создаёт партицию balance_transactions (created_at)', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
$manager->ensureMonth('balance_transactions', Carbon::parse('2024-03-01'));
|
||
|
||
expect(partitionExists('balance_transactions_y2024_m03'))->toBeTrue();
|
||
});
|
||
|
||
test('ensureMonth создаёт партицию pd_processing_log (created_at)', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
$manager->ensureMonth('pd_processing_log', Carbon::parse('2024-03-01'));
|
||
|
||
expect(partitionExists('pd_processing_log_y2024_m03'))->toBeTrue();
|
||
});
|
||
|
||
test('ensureMonth создаёт партицию saas_admin_audit_log (created_at)', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
$manager->ensureMonth('saas_admin_audit_log', Carbon::parse('2024-03-01'));
|
||
|
||
expect(partitionExists('saas_admin_audit_log_y2024_m03'))->toBeTrue();
|
||
});
|
||
|
||
test('partitionName возвращает правильный формат', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
|
||
expect($manager->partitionName('auth_log', Carbon::parse('2026-05-15')))
|
||
->toBe('auth_log_y2026_m05');
|
||
|
||
expect($manager->partitionName('deals', Carbon::parse('2024-01-01')))
|
||
->toBe('deals_y2024_m01');
|
||
});
|
||
|
||
test('listPartitions возвращает созданные партиции', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
$manager->ensureMonth('auth_log', Carbon::parse('2024-04-01'));
|
||
$manager->ensureMonth('auth_log', Carbon::parse('2024-05-01'));
|
||
|
||
$partitions = $manager->listPartitions('auth_log');
|
||
|
||
expect($partitions)->toContain('auth_log_y2024_m04')
|
||
->toContain('auth_log_y2024_m05');
|
||
});
|
||
|
||
// ---------------------------------------------------------------------------
|
||
// Slepok routing: project_routing_snapshots (snapshot_date key, Этап 2, 27.05.2026)
|
||
// ---------------------------------------------------------------------------
|
||
|
||
test('PARTITIONED_TABLES включает project_routing_snapshots с ключом snapshot_date', function (): void {
|
||
expect(MonthlyPartitionManager::PARTITIONED_TABLES)
|
||
->toHaveKey('project_routing_snapshots')
|
||
->and(MonthlyPartitionManager::PARTITIONED_TABLES['project_routing_snapshots'])
|
||
->toBe('snapshot_date');
|
||
});
|
||
|
||
test('ensureMonth создаёт партицию project_routing_snapshots (snapshot_date)', function (): void {
|
||
$manager = app(MonthlyPartitionManager::class);
|
||
$manager->ensureMonth('project_routing_snapshots', Carbon::parse('2024-07-01'));
|
||
|
||
expect(partitionExists('project_routing_snapshots_y2024_m07'))->toBeTrue();
|
||
});
|