<?php

declare(strict_types=1);

// Runner de migrations SQL.
// Appelé sur le serveur après chaque rsync : php database/migrate.php

$baseDir = dirname(__DIR__);
$envFile = $baseDir . '/.env';

if (!file_exists($envFile)) {
    fwrite(STDERR, "Fichier .env introuvable : $envFile\n");
    exit(1);
}

$env = [];
foreach (file($envFile, FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES) as $line) {
    $line = trim($line);
    if ($line === '' || str_starts_with($line, '#')) {
        continue;
    }
    [$k, $v] = array_pad(explode('=', $line, 2), 2, '');
    $env[trim($k)] = trim($v, '"\'');
}

$dsn  = $env['DB_DSN']  ?? '';
$user = $env['DB_USER'] ?? '';
$pass = $env['DB_PASS'] ?? '';

if (!$dsn) {
    fwrite(STDERR, "DB_DSN manquant dans .env\n");
    exit(1);
}

$pdo = new PDO($dsn, $user, $pass, [
    PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
]);

// Crée la table de suivi si elle n'existe pas encore
$pdo->exec('
    CREATE TABLE IF NOT EXISTS schema_migrations (
        name       TEXT      NOT NULL PRIMARY KEY,
        applied_at TIMESTAMP NOT NULL DEFAULT NOW()
    )
');

// Migrations déjà appliquées
$applied = array_flip(
    $pdo->query('SELECT name FROM schema_migrations ORDER BY name')
        ->fetchAll(PDO::FETCH_COLUMN)
);

// Fichiers de migration dans le même dossier, triés par nom
$files = glob(__DIR__ . '/migration_*.sql') ?: [];
sort($files);

$count = 0;
foreach ($files as $file) {
    $name = basename($file);
    if (isset($applied[$name])) {
        continue;
    }

    $sql = file_get_contents($file);
    if ($sql === false || trim($sql) === '') {
        echo "  ⚠  $name : fichier vide ou illisible, ignoré\n";
        continue;
    }

    echo "  → $name ... ";
    $pdo->exec($sql);
    $pdo->prepare('INSERT INTO schema_migrations (name) VALUES (?)')
        ->execute([$name]);
    echo "✓\n";
    $count++;
}

if ($count === 0) {
    echo "  (aucune migration en attente)\n";
} else {
    echo "  $count migration(s) appliquée(s).\n";
}