<?php
require_once __DIR__ . '/config.php';

function run_migrations() {
    try {
        $pdo = db();
        
        // Create migrations table if it doesn't exist
        $pdo->exec("CREATE TABLE IF NOT EXISTS migrations (id INT AUTO_INCREMENT PRIMARY KEY, migration_name VARCHAR(255) NOT NULL, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP)");

        // Get all migration files
        $migration_files = glob(__DIR__ . '/migrations/*.sql');
        sort($migration_files);

        // Get already run migrations
        $stmt = $pdo->query("SELECT migration_name FROM migrations");
        $run_migrations = $stmt->fetchAll(PDO::FETCH_COLUMN);

        foreach ($migration_files as $migration_file) {
            $migration_name = basename($migration_file);

            if (!in_array($migration_name, $run_migrations)) {
                $sql = file_get_contents($migration_file);
                $pdo->exec($sql);

                $stmt = $pdo->prepare("INSERT INTO migrations (migration_name) VALUES (?)");
                $stmt->execute([$migration_name]);

                echo "Migration '" . $migration_name . "' applied successfully.\n";
            }
        }

    } catch (PDOException $e) {
        die("Migration failed: " . $e->getMessage() . "\n");
    }
}

run_migrations();