<?php

use App\Models\AuditLog;
use App\Models\QualificationAssessment;
use App\Models\QualificationSet;
use App\Services\DocumentaryQualificationWorkflow;
use Illuminate\Contracts\Console\Kernel;
use Illuminate\Support\Facades\Artisan;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Schema;
use Symfony\Component\Process\Process;

require __DIR__.'/../../vendor/autoload.php';
foreach (['APP_ENV' => 'testing', 'CACHE_STORE' => 'array', 'SESSION_DRIVER' => 'array', 'QUEUE_CONNECTION' => 'sync', 'MAIL_MAILER' => 'array'] as $key => $value) {
    putenv($key.'='.$value);
    $_ENV[$key] = $_SERVER[$key] = $value;
}
$app = require __DIR__.'/../../bootstrap/app.php';
$app->make(Kernel::class)->bootstrap();
require __DIR__.'/../Support/QualificationFixture.php';
$original = DB::connection();
if ($original->getDriverName() !== 'pgsql') {
    throw new LogicException('Exige PostgreSQL.');
}
$config = $original->getConfig();
$admin = $original->getPdo();
$database = 'compras_receipts_test_'.bin2hex(random_bytes(6));
$created = false;
$processes = [];
$report = ['tested_at_utc' => gmdate('c'), 'separate_database' => true, 'transport' => 'Independent PHP service transactions and PostgreSQL connections', 'scenarios' => []];
try {
    $admin->exec('CREATE DATABASE "'.$database.'"');
    $created = true;
    config(['database.connections.pgsql' => [...$config, 'database' => $database, 'url' => null]]);
    DB::purge('pgsql');
    DB::setDefaultConnection('pgsql');
    Schema::clearResolvedInstance('db.schema');
    app()->forgetInstance('db.schema');
    if (DB::connection()->getDatabaseName() !== $database || Schema::getConnection()->getDatabaseName() !== $database) {
        throw new LogicException('Migração fora do isolamento recusada.');
    }
    Artisan::call('migrate', ['--database' => 'pgsql', '--force' => true]);
    $workerEnv = ['APP_ENV' => 'testing', 'DB_CONNECTION' => 'pgsql', 'DB_URL' => '', 'DB_DATABASE' => $database, 'DB_HOST' => $config['host'], 'DB_PORT' => (string) $config['port'], 'DB_USERNAME' => $config['username'], 'DB_PASSWORD' => $config['password'], 'CACHE_STORE' => 'array', 'SESSION_DRIVER' => 'array'];
    foreach (['competing_requirements', 'same_analyst', 'distinct_analysts', 'changed_basis', 'revoked_role', 'requirements_versus_assessment'] as $scenario) {
        $f = qualificationFixture();
        $workflow = app(DocumentaryQualificationWorkflow::class);
        $set = null;
        if ($scenario !== 'competing_requirements') {
            $set = $workflow->define($f['issuer'], $f['r'], $f['definition']);
        }
        $connection = DB::connection();
        $connection->beginTransaction();
        $connection->table('tenants')->where('id', $f['tenant']->id)->lockForUpdate()->first();
        $processes = [];
        foreach (['A', 'B'] as $index => $suffix) {
            $define = $scenario === 'competing_requirements' || ($scenario === 'requirements_versus_assessment' && $index === 0);
            $actor = $define ? $f['issuer'] : ($scenario === 'distinct_analysts' && $index === 1 ? $f['other_analyst'] : $f['analyst']);
            $target = $define ? $f['r']->id : $set->id;
            $data = $define ? [...$f['definition'], 'previous_id' => $set->id ?? 0] : $f['assessment'];
            $process = new Process([PHP_BINARY, __DIR__.'/qualification-worker.php', $database, (string) $actor->id, (string) $target, $suffix], base_path(), $workerEnv);
            $process->setInput(json_encode(['action' => $define ? 'define' : 'assess', 'data' => $data], JSON_THROW_ON_ERROR));
            $process->setTimeout(40);
            $process->start();
            $processes[] = $process;
        }
        $statement = $admin->prepare("SELECT count(*) FROM pg_stat_activity WHERE datname = ? AND application_name IN ('sgc_qualification_A','sgc_qualification_B') AND wait_event_type = 'Lock'");
        $deadline = microtime(true) + 20;
        do {
            $statement->execute([$database]);
            $waits = (int) $statement->fetchColumn();
            if ($waits === 2) {
                break;
            }
            foreach ($processes as $process) {
                if (! $process->isRunning()) {
                    throw new RuntimeException('Worker terminou antes do bloqueio: '.$process->getErrorOutput());
                }
            }
            usleep(20000);
        } while (microtime(true) < $deadline);
        if ($scenario === 'revoked_role') {
            $connection->table('users')->where('id', $f['analyst']->id)->update(['purchasing_role' => 'requester']);
        }
        if ($scenario === 'changed_basis') {
            $connection->table('quotations')->where('id', $f['quote']->id)->update(['reference' => 'Proposta alterada durante a espera']);
        }
        $connection->commit();
        if ($waits !== 2) {
            throw new RuntimeException('Sem sobreposição de bloqueios.');
        }
        $results = [];
        foreach ($processes as $process) {
            $process->wait();
            if (! $process->isSuccessful()) {
                throw new RuntimeException('Falha do worker: '.$process->getErrorOutput());
            }
            $results[] = json_decode($process->getOutput(), true, 512, JSON_THROW_ON_ERROR);
        }
        $statuses = array_column($results, 'status');
        sort($statuses);
        $expected = match ($scenario) {
            'distinct_analysts' => [200, 200], 'changed_basis' => [422, 422], 'revoked_role' => [403, 403], default => [200, 422]
        };
        $sets = QualificationSet::query()->count();
        $assessments = QualificationAssessment::query()->count();
        if ($scenario === 'requirements_versus_assessment') {
            if (! in_array($statuses, [[200, 200], [200, 422]], true) || $sets !== 2 || $assessments !== ($statuses === [200, 200] ? 1 : 0) || QualificationAssessment::query()->where('qualification_set_id', QualificationSet::query()->max('id'))->exists()) {
                throw new RuntimeException('Análise misturada com requisitos novos.');
            }
        } elseif ($statuses !== $expected || $sets !== 1 || $assessments !== match ($scenario) {
            'same_analyst' => 1, 'distinct_analysts' => 2, default => 0
        }) {
            throw new RuntimeException('Resultado concorrente inesperado.');
        }
        if (count(array_unique(array_column($results, 'backend_pid'))) !== 2 || AuditLog::query()->where('action', 'qualification.defined')->count() !== $sets || AuditLog::query()->where('action', 'qualification.assessed')->count() !== $assessments) {
            throw new RuntimeException('Auditoria ou ligações inconsistentes.');
        }
        if ($scenario === 'distinct_analysts' && QualificationAssessment::query()->distinct()->count('analyst_id') !== 2) {
            throw new RuntimeException('Registos de analistas substituídos.');
        }
        if (QualificationAssessment::query()->where('revision', '!=', 1)->exists()) {
            throw new RuntimeException('Versões inesperadas.');
        }
        $report['scenarios'][] = ['name' => $scenario, 'passed' => true, 'overlapping_lock_waits' => $waits, 'requirement_versions' => $sets, 'analyst_records' => $assessments];
    }
    $report['passed'] = true;
} finally {
    foreach ($processes as $process) {
        if ($process->isRunning()) {
            $process->stop();
        }
    }
    if (isset($connection) && $connection->transactionLevel() > 0) {
        $connection->rollBack();
    }
    DB::disconnect('pgsql');
    if ($created && $database !== $original->getDatabaseName() && preg_match('/^compras_receipts_test_[a-f0-9]{12}$/', $database)) {
        $admin->exec('DROP DATABASE "'.$database.'"');
        $report['test_database_dropped'] = true;
    }
}
file_put_contents(base_path('docs/qualificacao-concorrencia-postgresql.json'), json_encode($report, JSON_PRETTY_PRINT | JSON_THROW_ON_ERROR).PHP_EOL);
echo json_encode($report, JSON_PRETTY_PRINT | JSON_THROW_ON_ERROR).PHP_EOL;