/** Datei: library/ARUNOX/Migrations/BaseMigration.php **/
<?php
	/**
	 * ARUNOX\Migrations\Migration
	 *
	 * Abstract base class for defining migrations in the ARUNOX Framework.
	 * Provides a consistent structure for the `up()` and optional `down()` methods.
	 *
	 * @version         1.0.0
	 * @author          Sparky
	 * @copyright       2025 ARUNOX
	 */
	
	namespace ARUNOX\Migrations;
	
	use ARUNOX\Core\Database;
	
	abstract class BaseMigration
	{
		/**
		 * Applies the migration logic.
		 */
		abstract public function up(): void;
		
		/**
		 * Reverts the migration logic (optional).
		 */
		public function down(): void
		{
			// Optional implementation for rollback logic
		}
		
		/**
		 * Provides access to the Database instance.
		 *
		 * @return Database
		 */
		protected function db(): Database
		{
			return Database::getInstance();
		}
	}

/** Datei: library/ARUNOX/Migrations/Manager.php **/
<?php
	/**
	 * ARUNOX\Migrations\Manager
	 *
	 * Handles database migrations, including plugin-specific migrations.
	 * Utilizes the Entity for database interactions.
	 * Automatically identifies and executes pending migrations.
	 *
	 * @version         1.0.0
	 * @version         1.0.0
	 */
	
	namespace ARUNOX\Migrations;
	
	use Exception;
	
	class Manager
	{
		private static array $directories = [];
		private static Entity $entity;
		
		/**
		 * Initializes the Manager with root directories for migrations.
		 *
		 * @param array $rootDirs
		 */
		public static function init(array $rootDirs): void
		{
			foreach ($rootDirs as $root) {
				self::$directories[] = rtrim($root, '/') . '/migrations';
			}
			
			self::$entity = new Entity();
			self::$entity->initTable();
		}
		
		/**
		 * Runs all pending migrations.
		 */
		public static function run(): void
		{
			$applied = self::$entity->getApplied();
			$files = self::getFiles();
			
			foreach ($files as $file) {
				$name = basename($file, '.php');
				if (!in_array($name, $applied)) {
					self::execute($file, $name);
				}
			}
		}
		
		/**
		 * Finds all migration files in the specified directories.
		 *
		 * @return array
		 */
		private static function getFiles(): array
		{
			$files = [];
			
			foreach (self::$directories as $dir) {
				if (is_dir($dir)) {
					$files = array_merge($files, glob($dir . '/*.php'));
				}
			}
			
			return $files;
		}
		
		/**
		 * Executes a single migration file.
		 *
		 * @param string $file
		 * @param string $name
		 */
		private static function execute(string $file, string $name): void
		{
			try {
				Database::begin();
				
				require_once $file;
				
				if (!class_exists($name)) {
					throw new Exception("Migration class {$name} not found in {$file}");
				}
				
				$migration = new $name();
				if (!$migration instanceof Migration) {
					throw new Exception("Migration class {$name} must extend the abstract Migration class");
				}
				
				$migration->up();
				self::$entity->record($name);
				
				Database::commit();
				echo "Migration {$name} executed successfully.\n";
			} catch (Exception $e) {
				Database::rollback();
				echo "Migration {$name} failed: " . $e->getMessage() . "\n";
			}
		}
	}

/** Datei: library/ARUNOX/Migrations/Entity.php **/
<?php
	/**
	 * ARUNOX\Migrations\Entity
	 *
	 * Manages database interactions for the migrations table.
	 * Ensures proper tracking of executed migrations.
	 *
	 * @author          Sparky
	 * @copyright       2025 ARUNOX
	 * @version         1.0.3
	 */
	
	namespace ARUNOX\Migrations;
	
	use ARUNOX\Core\Database;
	
	class Entity
	{
		private string $table = 'migrations';
		
		/**
		 * Ensures the migrations table exists.
		 */
		public function initTable(): void
		{
			Database::query(
				"CREATE TABLE IF NOT EXISTS {$this->table} (
                id INT AUTO_INCREMENT PRIMARY KEY,
                migration VARCHAR(255) NOT NULL UNIQUE,
                executed_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
            )")->execute();
		}
		
		/**
		 * Retrieves the list of applied migrations.
		 *
		 * @return array
		 */
		public function getApplied(): array
		{
			return Database::query("SELECT migration FROM {$this->table}")
						   ->fetchAll(\PDO::FETCH_COLUMN);
		}
		
		/**
		 * Records a migration as executed.
		 *
		 * @param string $migration
		 */
		public function record(string $migration): void
		{
			Database::query("INSERT INTO {$this->table} (migration) VALUES (:migration)")
					->bind(['migration' => $migration])
					->execute();
		}
	}