<?php

namespace Fobia\Database\SphinxConnection\Test;

use Fobia\Database\SphinxConnection\SphinxConnection;
use Orchestra\Testbench\TestCase as Orchestra;
use Symfony\Component\Filesystem\Filesystem;

abstract class TestCase extends Orchestra
{
    /**
     * @var SphinxConnection
     */
    protected $db;

    // Logger
    protected $traceLog = null;

    public function toggleTraceLog($toggle = null)
    {
        $d = $this->traceLog;
        if ($toggle !== null) {
            $this->traceLog = (bool) $toggle;
        } else {
            $this->traceLog = !$this->traceLog;
        }
        return $d;
    }

    public function traceLog($log)
    {
        if ($this->traceLog) {
            echo '>> DB Query:: ' . $log . PHP_EOL;
        }
    }

    protected function getQuery()
    {
        /** @var \Illuminate\Database\Connection $db */
        $db = $this->app['db']->connection('sphinx');
        $log = $db->getQueryLog();
        $log = array_shift($log);
        return $log['query'];
    }

    protected function assertQuery($expectedQuery, $actualQuery = null)
    {
        if ($actualQuery instanceof  \Illuminate\Database\Eloquent\Builder
            || $actualQuery instanceof  \Illuminate\Database\Query\Builder) {
            $actualQuery = $actualQuery->toSql();
        }

        $actualQuery = ($actualQuery !== null) ? (string) $actualQuery : $this->getQuery();

        $this->traceLog($actualQuery);

        $actualQuery = mb_strtolower($actualQuery);
        $expectedQuery = mb_strtolower($expectedQuery);

        // $expectedQuery = preg_replace('/\s+/', ' ', $expectedQuery);
        // $actualQuery = preg_replace('/\s+/', ' ', $actualQuery);

        $expectedQuery = preg_replace(
            ['/\n/', '/\s*,\s*/', '/\s+/', '/\s*=\s*/', '/(?<=\()\s+|\s+(?=\))/'],
            [' ', ', ', ' ', ' = ', ''],
            $expectedQuery
        );
        $actualQuery = preg_replace(
            ['/\n/', '/\s*,\s*/', '/\s+/', '/\s*=\s*/', '/(?<=\()\s+|\s+(?=\))/'],
            [' ', ', ', ' ', ' = ', ''],
            $actualQuery
        );

        $this->assertEquals($expectedQuery, $actualQuery);
    }

    // =============================================

    protected function setUp(): void
    {
        if ($this->traceLog === null) {
            $this->traceLog = (bool) getenv('TRACE_QUERY_LOG');
        }
        parent::setUp();
    }

    protected function tearDown(): void
    {
        if (!empty($this->db)) {
            $this->db->flushQueryLog();
            $this->db->disconnect();
        }

        parent::tearDown();
    }

    /**
     * @param \Illuminate\Foundation\Application $app
     *
     * @return array
     */
    protected function getPackageProviders($app)
    {
        return [
            \Fobia\Database\SphinxConnection\SphinxServiceProvider::class,
        ];
    }

    /**
     * @param \Illuminate\Foundation\Application $app
     */
    protected function getEnvironmentSetUp($app)
    {
        $this->initializeDirectory($this->getTempDirectory());

        $app['config']->set('database.default', 'sphinx');
        $app['config']->set('database.connections.sphinx', [
            'driver' => 'sphinx',
            'host' =>  getenv('SPHINX_HOST') ?: '127.0.0.1',
            'port' => getenv('SPHINX_PORT') ?: 9306,
            'database' => null, // 'SphinxRT',
            'username' => '',
            // 'password' => '',
            // 'charset' => 'utf8',
            // 'prefix' => '',
            // 'collation' => null,
        ]);

        $app->bind('path.public', function () {
            return $this->getTempDirectory();
        });

        $app['config']->set('app.key', '6rE9Nz59bGRbeMATftriyQjrpF7DcOQm');
    }

    /**
     * @param \Illuminate\Foundation\Application $app
     */
    protected function setUpDatabase($app = null)
    {
        if ($app == null) {
            $app = $this->app;
        }

        if ($this->db === null) {
            $this->db = $app['db']->connection('sphinx');
            //$this->db = \DB::connection('sphinx');
        }

        try {
            $this->db->reconnect();
        } catch (\Exception $e) {
            $this->db = $app['db']->connection('sphinx');
        }

        $this->db->enableQueryLog();
    }

    protected function initializeDirectory($directory)
    {
        $fs = new Filesystem();
        if ($fs->exists($directory)) {
            $fs->remove($directory);
        }
        $fs->mkdir($directory);
    }

    public function getTempDirectory($suffix = '')
    {
        return dirname(__FILE__) . '/temp' . ($suffix == '' ? '' : '/' . $suffix);
    }
}