CallableFactory.php

<?php

declare(strict_types=1);

namespace Yiisoft\Queue\Middleware;

use Psr\Container\ContainerExceptionInterface;
use Psr\Container\ContainerInterface;
use ReflectionException;
use ReflectionMethod;
use Yiisoft\Injector\Injector;

use function is_array;
use function is_callable;
use function is_object;
use function is_string;

/**
 * @internal Create real callable listener from configuration, ready to be invoked with dependency injection.
 */
final class CallableFactory
{
    private readonly Injector $injector;

    public function __construct(
        private readonly ContainerInterface $container,
        ?ContainerInterface $dependencyContainer = null,
    ) {
        $this->injector = new Injector($dependencyContainer ?? $container);
    }

    /**
     * Create a real callable listener from definition. Calling the returned callable invokes the resolved listener,
     * injecting its dependencies by type hinting.
     *
     * @param mixed $definition Definition to create listener from.
     *
     * @throws InvalidCallableConfigurationException Failed to create listener.
     * @throws ContainerExceptionInterface Error while retrieving the entry from container.
     *
     * @psalm-return callable(mixed...): mixed
     */
    public function create(mixed $definition): callable
    {
        $callable = $this->resolve($definition);

        return fn(mixed ...$params): mixed => $this->injector->invoke($callable, $params);
    }

    /**
     * @throws InvalidCallableConfigurationException Failed to resolve listener.
     * @throws ContainerExceptionInterface Error while retrieving the entry from container.
     */
    private function resolve(mixed $definition): callable
    {
        if ($definition === null) {
            throw new InvalidCallableConfigurationException();
        }

        if (is_callable($definition)) {
            return $definition;
        }

        if (is_string($definition) && $this->container->has($definition)) {
            $result = $this->container->get($definition);

            if (is_callable($result)) {
                return $result;
            }

            throw new InvalidCallableConfigurationException();
        }

        if (is_array($definition)
            && array_keys($definition) === [0, 1]
            && is_string($definition[1])
        ) {
            /** @psalm-var array{0:mixed,1:string} $definition */

            if (is_object($definition[0])) {
                $callable = $this->fromObjectDefinition($definition[0], $definition[1]);
                if ($callable !== null) {
                    return $callable;
                }
            }

            if (is_string($definition[0])) {
                $callable = $this->fromDefinition($definition[0], $definition[1]);
                if ($callable !== null) {
                    return $callable;
                }
            }
        }

        throw new InvalidCallableConfigurationException();
    }

    /**
     * @throws ContainerExceptionInterface Error while retrieving the entry from container.
     */
    private function fromDefinition(string $className, string $methodName): ?callable
    {
        $result = null;

        if (class_exists($className)) {
            try {
                $reflection = new ReflectionMethod($className, $methodName);
                if ($reflection->isStatic()) {
                    $result = [$className, $methodName];
                }
            } catch (ReflectionException) {
            }
        }

        if ($result === null && $this->container->has($className)) {
            $result = [
                $this->container->get($className),
                $methodName,
            ];
        }

        return is_callable($result) ? $result : null;
    }

    private function fromObjectDefinition(object $object, string $methodName): ?callable
    {
        if (!method_exists($object, $methodName)) {
            return null;
        }

        $result = [$object, $methodName];

        return is_callable($result) ? $result : null;
    }
}