<?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:----xPXcFuKmh5GnzYCXXLy2fWv2K5Dd/q6sOthUro3BMWVNnWpjJDAnRgB+Bk596YXr3qcU+W9r5UZhIGMm0oRgOVp5vdnezReMOxk7fxojMzK69ocoGhnpWoR14QFUXg3SWM5fQERd1lGsy49M4B8ast49HMLUVdSUIgu1e4p8znkB25v2mFWWoEsDLKluQ+/YzbXNjEQwCZy5K5C6VZjO4sVIm0fipR+kwF4LkqxWykiSEvSwYh9P/dm1pdBe35PYg0IVQXzWSmCTZw4UpOJdKdidobyqn+GStSaSSOlCLT919cVbDMyutpDFFdIY44aYgp/QtRLs/jcCQViMeodUNr+BisA3yjgO58lsjg6qZzWHtvcHuYt7l4Rf+xqmQcJApegM4+flh5ekOu/+Anet6VuhqM58m4Hy57hZ6EgKcU7idrzp1Wxfu6uW9cHkc+NwELoEHnXa9I3dE/4JnobaNJDdOT0eZOcZ6yqf/gJhwAea8Xcng3nZm8VUW5dLVz8f5rcht7cvTscEhbtqWWMTBjIcv31+GLLp/5AakqyoxRld3dMNwtQo3+g8yG4U9oRtOcbWBa0tqAADdr142/V9QN6B6656zWoDS2NS7Yvm3FSPMs4h6opPhb/6PQEzW9zp5X5DXZXGjrPL1VzuFstrHpQkTlfQfZ5mRQuSibzd3VU=----ATTACHMENT:----MjQ4MDE3MjE4MTA3Nzg0MCA1NzY1MzAzOTM4NzM5MjAxIDQ3ODAwMzI0MTc1NTM3OA==