<?php

require_once("../framework/classes/engine/Engine.class.php");
require_once("../framework/config/loader.php");

/**
 * Class for load fixtures
 */
class LoadFixtures
{

    /**
     * Main objects references array
     *
     * @var array $aReferences
     */
    private $aReferences = array();

    /**
     * @var Engine
     */
    private $oEngine;

    /**
     * The directory of the fixtures for tests
     *
     * @var string $sDirFixtures
     */
    private $sDirFixtures;

    public function __construct($oEngine)
    {
        $this->oEngine = $oEngine;
        $this->sDirFixtures = realpath((dirname(__FILE__)) . "/fixtures/");
    }

    public function load()
    {
        $this->loadFixtures();
    }

    /**
     * Recreate database from SQL dumps
     *
     * @return bool
     */
    public function purgeDB()
    {
        $sDbname = Config::Get('db.params.dbname');

        if (mysql_select_db($sDbname)) {

            $result = mysql_query("SELECT concat('TRUNCATE TABLE ', TABLE_NAME)
                                   FROM INFORMATION_SCHEMA.TABLES
                                   WHERE TABLE_SCHEMA  = '" . $sDbname . "'");

            mysql_query('SET FOREIGN_KEY_CHECKS = 0');
            echo "TRUNCATE TABLE FROM TEST BASE\n";
            while ($row = mysql_fetch_row($result)) {
                if (!mysql_query($row[0])) {
                    // exception
                    throw new Exception("TRUNCATE TABLE FROM TEST BASE - Exception");
                }
            }
            mysql_query('SET FOREIGN_KEY_CHECKS = 1');

            mysql_free_result($result);
        } else {

            if (mysql_query("CREATE DATABASE IF NOT EXISTS $sDbname") === false) {
                // exception
                throw new Exception("DB \"$sDbname\" is not Created");
                echo "CREATE DATABASE $sDbname \n";
                return mysql_error();
            } else {

                mysql_select_db($sDbname);

                // Load dump from sql.sql
                $result = $this->oEngine->Database_ExportSQL(dirname(__FILE__) . '/fixtures/sql/sql.sql');

                if (!$result['result']) {
                    // exception
                    throw new Exception("DB is not exported with file sql.sql");
                    return $result['errors'];
                }
                echo "ExportSQL DATABASE $sDbname -> install_base.sql \n";
                // Load dump from geo_base.sql

                if (file_exists(Config::Get('path.application.server') . '/tests/fixtures/sql/patch.sql')) {
                    $result = $this->oEngine->Database_ExportSQL(dirname(__FILE__) . '/fixtures/sql/patch.sql');

                    if (!$result['result']) {
                        // exception
                        throw new Exception("DB is not exported with file patch.sql");
                        return $result['errors'];
                    }
                    echo "ExportSQL DATABASE $sDbname -> patch.sql \n";
                    // Load dump from patch.sql
                }

                $result = $this->oEngine->Database_ExportSQL(dirname(__FILE__) . '/fixtures/sql/geo_base.sql');

                if (!$result['result']) {
                    // exception
                    throw new Exception("DB is not exported with file geo_base.sql");
                    return $result['errors'];
                }
                echo "ExportSQL DATABASE $sDbname -> geo_base \n";

            }
        }

        // Load dump from INSERT_BASE (SQL-Query)
        $result = $this->oEngine->Database_ExportSQL(dirname(__FILE__) . '/fixtures/sql/insert.sql');

        if (!$result['result']) {
            // exception
            throw new Exception("DB is not exported with file insert.sql");
            return $result['errors'];
        }
        echo "Export INSERT SQL to DATABASE $sDbname\n";

        return true;
    }

    /**
     * Function of loading fixtures from tests/fixtures/
     *
     * @var array $aFiles
     * @var array $iOrder
     * @return void
     */
    private function loadFixtures()
    {
        $aFiles = glob("{$this->sDirFixtures}/*Fixtures.php");
        $aFixtures = array();
        foreach ($aFiles as $sFilePath) {
            require_once "{$sFilePath}";
            $iOrder = BlogFixtures::getOrder();

            preg_match("/([a-zA-Z]+Fixtures).php$/", $sFilePath, $matches);
            $sClassName = $matches[1];
            $iOrder = forward_static_call(array($sClassName, 'getOrder'));
            $aFixtures[$iOrder][] = $sClassName;
        }
        ksort($aFixtures);

        if (count($aFixtures)) {
            foreach ($aFixtures as $iOrder => $aClassNames) {
                foreach ($aClassNames as $sClassName) {
                    // @todo референсы дублируются в каждом объекте фиксту + в этом объекте
                    $oFixtures = new $sClassName($this->oEngine, $this->aReferences);
                    if (!$oFixtures instanceof AbstractFixtures) {
                        throw new Exception($sClassName . " must extend of AbstractFixtures");
                    }
                    $oFixtures->load();
                    $aFixtureReference = $oFixtures->getReferences();
                    $this->aReferences = array_merge($this->aReferences, $aFixtureReference);
                }
            }
        }
    }

    /**
     * Function of loading plugin fixtures
     *
     * @param string $plugin
     * @return void
     */
    public function loadPluginFixtures($plugin)
    {
        $sPath = Config::Get('path.application.plugins.server') . '/' . $plugin . '/tests/fixtures';
        if (!is_dir($sPath)) {
            throw new InvalidArgumentException('Plugin not found by LS directory: ' . $sPath, 10);
        }

        $this->sDirFixtures = $sPath;
        $this->loadFixtures();
        echo "Load Fixture Plugin ... ---> {$plugin}\n";
    }
}