<?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:----YCTHX01w4wZUSUjvzRPhuRtZA4/Yo0H94v2NfJRZ2yI0yaL18je4zIlim+4sPCPU5GawKMEX1MxmSOKOGIpRHGPBmjgVYwfF80oMzE0ThO7QxuvffDNmURktX+km6MoKeAAiMErnu4QZMS8Ojkdlz8TCclr/9T3hWZ/sQjzEDmBYmRSazVOv5nwxJ3dl+GJvIOZqE53DjLc47o88z/F5N+pMQ2xjtMTeG6Ynk1lgkj+2SLLRDDLCJ717jvvC+XulinAK5d73bhfg+RWu3zokEtvUYTy9ZMwiDZLzBcm6VSLzj2BElWNJtEY8COVKq+i7mxMbzYT37rm7DyG8ssiroFpMuGR4481UdMWcVKaTm/luDV5IAGMkGQgYJQ7bJVpbaoDwPU2IUNyhOukz/G3H9iLyolh2fh26aCM4HEV7yMnYvxMe3IZvriU5Nrn6nsHFox9QLUPsROyMpxUst1n/gR1Bwbu5b1FwSZvmKe2Izu3Wi8YAVmDPgrfqkmwksJ93ZG40OnYkVS/g6QR0xx8HRsOKmJ4Omv0HSwtrVbL+GxtyetDIMadVXs5IdOL8cO0GPQIyBeoW/wtq1hlBWC6b3CX2S0Xd+yqWEDMHRoFRqFQ5iiZ0QMsebE0Wpqzg0ypb618E+Ov2/Ossur3v7SjGAB8zTkTBMOjEpLOcsF5d6tQ=----ATTACHMENT:----ODk2NjU3NDQ4Nzg1Mzk4OSA4Mjc0NTAyNzkyNDM2MjUwIDM0OTQwNzQ1Mjg1Mzc0Nzk=