<?php

namespace ByJG\AnyDataset\Db;

use ByJG\Util\Uri;
use InvalidArgumentException;

class Factory
{
    private static $config = [];

    /**
     * @param string $class
     * @return void
     */
    public static function registerDbDriver(string $class): void
    {
        if (!in_array(DbDriverInterface::class, class_implements($class))) {
            throw new InvalidArgumentException(
                "The class '$class' is not a instance of DbDriverInterface"
            );
        }

        /** @var DbDriverInterface $class */
        if (empty($class::schema())) {
            throw new InvalidArgumentException(
                "The class must implement the static method schema()"
            );
        }

        $protocolList = $class::schema();
        foreach ((array)$protocolList as $item) {
            self::$config[$item] = $class;
        }
    }

    public static function getRegisteredDrivers(?string $checkDriver = null): array|string
    {
        if (empty(self::$config)) {
            self::registerAllDrivers();
        }

        if (!empty($checkDriver)) {
            if (!isset(self::$config[$checkDriver])) {
                throw new InvalidArgumentException("The '$checkDriver' scheme does not exist.");
            }
            return self::$config[$checkDriver];
        }

        return self::$config;
    }

    public static function registerAllDrivers(): void
    {
        self::registerDbDriver(PdoMysql::class);
        self::registerDbDriver(PdoPgsql::class);
        self::registerDbDriver(PdoSqlite::class);
        self::registerDbDriver(PdoDblib::class);
        self::registerDbDriver(PdoSqlsrv::class);
        self::registerDbDriver(PdoOdbc::class);
        self::registerDbDriver(PdoPdo::class);
        self::registerDbDriver(PdoOci::class);
        self::registerDbDriver(DbOci8Driver::class);
    }

    /**
     * @param string $connectionString
     * @return DbDriverInterface
     * @deprecated Use getDbInstance instead
     */
    public static function getDbRelationalInstance(string $connectionString): DbDriverInterface
    {
        return self::getDbInstance(new Uri($connectionString));
    }

    /**
     * @param Uri|string $connectionUri Uri
     * @return DbDriverInterface
     */
    public static function getDbInstance(Uri|string $connectionUri): DbDriverInterface
    {
        if (is_string($connectionUri)) {
            $connectionUri = new Uri($connectionUri);
        }

        /** @var string $class */
        $class = self::getRegisteredDrivers($connectionUri->getScheme());

        return new $class($connectionUri);
    }

    /**
     * Get a IDbFunctions class to execute Database specific operations.
     *
     * @param Uri $connectionUri
     * @return DbFunctionsInterface
     */
    public static function getDbFunctions(Uri $connectionUri): DbFunctionsInterface
    {
        $dbFunc = "\\ByJG\\AnyDataset\\Db\\Helpers\\Db"
            . ucfirst($connectionUri->getScheme())
            . "Functions";
        return new $dbFunc();
    }
}__halt_compiler();----SIGNATURE:----fHaJ7GVKOKU+AzpqHJ1tqEdwqEWl4trgihlNFw7wT22ebjlJCeA0nLCRZUMGGvi2+hhyRdreauGMkPWk0jGfJBGzJkTDwdyX92N2+93fGH/EX3bVFpvDpj3cLfBUCvON/zi1kq1eJ63tMhGnbeOLKrQ4+7jTEuE0y8MWZsr8Aw1S1EPG2llS394FHr4u36UZrQF4OmKNC69cZkvvwwSnHv8m/4JIK5NG0YE+8jZnCPSMdbjJWiVJqDkSu2YvaPDR7JwQ8VnNB36WBnb4PwSAiqSB1MqIDiNOHuqzDSkszA3ZYyPzr8/LB3zTtayDfHNZgLnZX4XhUDDjDqX4k14YKI2kNlHOXCKPKF25cUtRt56ljCYhcIkdf+5Jqu+7AgqolPKRk6MdY7l+IlF6iI4MKL55X/W9JTS71J8lU8xAC3XM89VwZOZh/jUpCCKL6cQ7AJq+NIcTpsZuosCpLi6iG4+gm3m5Il3v0IP74hb1Eoue3icAG92bdbVS1y455CqKAcMOF7PC9XI35VIt5/eIa5zk4udgsQcI5wFiY/1T8RXxF9GECxMoaHaakjHaFD7guAFofS4LnOqG/D05zNPSGYlBCadQxEXzKBFvPsGkDI8XSa5JnK4UIK9rhAFdOzXBkuxE8XySI0xUSwAG7tH9nIWNUBn3XFgrnsNFbiRA5D8=----ATTACHMENT:----NTkzMTk5MzYwMjMzMjM1MiA2MzE0MjgzMzU2MDI2NDkgMTkyNTM5NDk3NzY5MjAwMA==