TMV\HTTPlugModule\DIFactory\ClientAbstractFactory

Complexity

Total Complexity

12

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Test Coverage

Coverage

61.29%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	31	5
A	retrievePlugins()	0	22	5
A	canCreate()	0	11	2

<?php

declare(strict_types=1);

namespace TMV\HTTPlugModule\DIFactory;

use Http\Client\Common\Plugin;
use Http\Client\Common\PluginClient;
use Psr\Container\ContainerInterface;
use InvalidArgumentException;
use Psr\Http\Client\ClientInterface;
use Laminas\ServiceManager\Exception\ServiceNotCreatedException;
use Laminas\ServiceManager\Exception\ServiceNotFoundException;
use Laminas\ServiceManager\Factory\AbstractFactoryInterface;
use TMV\HTTPlugModule\ClientFactory\AutoDiscoveryFactory;
use TMV\HTTPlugModule\ClientFactory\ClientFactory;
use TMV\HTTPlugModule\PluginFactoryManager;

use function is_array;
use function is_string;

class ClientAbstractFactory implements AbstractFactoryInterface
{
    /**
     * @param string $requestedName
     */
    public function canCreate(ContainerInterface $container, $requestedName): bool
    {
        if (! preg_match('/^httplug\.clients\.[^.]+$/', $requestedName)) {
            return false;
        }

        [,, $clientName] = explode('.', $requestedName);

        $config = $container->get('config')['httplug']['clients'][$clientName] ?? null;

        return is_array($config);
    }

    /**
     * Create an object.
     *
     * @param string $requestedName
     * @param null|array<mixed> $options
     *
     * @throws ServiceNotFoundException if unable to resolve the service
     * @throws ServiceNotCreatedException if an exception is raised when
     *                                    creating a service
     */
    public function __invoke(ContainerInterface $container, $requestedName, array $options = null): ClientInterface
    {
        if (! preg_match('/^httplug\.clients\.[^.]+$/', $requestedName)) {
            throw new InvalidArgumentException('Invalid service name');
        }

        [,, $clientName] = explode('.', $requestedName);

        $config = $container->get('config')['httplug']['clients'][$clientName] ?? null;

        if (! is_array($config)) {
            throw new InvalidArgumentException('Invalid service name');
        }

        if (! empty($config['service'])) {
            $client = $container->get($config['service']);
        } else {
            /** @var ClientFactory $factory */
            $factory = $container->get($config['factory'] ?? AutoDiscoveryFactory::class);
            $client = $factory->createClient($config['config'] ?? []);
        }

        $plugins = $this->retrievePlugins($container, $config['plugins'] ?? []);

        if (0 === count($plugins)) {
            return $client;
        }

        return new PluginClient(
            $client,
            $plugins
        );
    }

    /**
     * @param array<string, mixed> $config
     *
     * @return Plugin[]
     */
    private function retrievePlugins(ContainerInterface $container, array $config): array
    {
        /** @var PluginFactoryManager $pluginFactoryManager */
        $pluginFactoryManager = $container->get(PluginFactoryManager::class);

        $plugins = [];

        foreach ($config as $nameOrConfig) {
            if (is_string($nameOrConfig)) {
                $plugins[] = $container->get($nameOrConfig);
                continue;
            }

            if (! is_array($nameOrConfig) || ! is_string($nameOrConfig['name'] ?? null)) {
                throw new InvalidArgumentException('Invalid client plugin');
            }

            $plugins[] = $pluginFactoryManager->getFactory($nameOrConfig['name'])
                ->createPlugin($nameOrConfig['config'] ?? []);
        }

        return $plugins;
    }
}