FOS\ElasticaBundle\DependencyInjection\FOSElasticaExtension

Complexity

Total Complexity

96

Size/Duplication

Total Lines	722
Duplicated Lines	3.74 %

Coupling/Cohesion

Components	1
Dependencies	9

Test Coverage

Coverage

89.01%

Importance

Changes

0

25 Methods

Rating	Name	Duplication	Size	Complexity
B	load()	0	60	9
A	getConfiguration()	0	4	1
A	loadClients()	0	24	3
B	loadIndexes()	5	54	6
A	loadIndexTemplates()	4	32	3
A	loadIndexFinder()	0	9	1
A	loadIndexConfig()	0	30	5
B	buildCallback()	0	25	7
A	transformServiceReference()	0	4	2
A	loadIndexSerializerIntegration()	0	21	5
B	loadIndexPersistenceIntegration()	0	20	6
A	loadElasticaToModelTransformer()	0	22	2
A	loadModelToElasticaTransformer()	0	20	3
A	loadObjectPersister()	0	37	4
A	loadIndexPagerProvider()	0	33	5
B	loadIndexListener()	0	59	9
B	getDoctrineEvents()	0	32	7
A	loadTypeFinder()	0	26	3
A	loadIndexManager()	9	9	1
A	loadIndexTemplateManager()	9	9	1
A	loadDriver()	0	10	2
A	loadSerializer()	0	11	2
A	createDefaultManagerAlias()	0	17	4
A	getClient()	0	8	2
A	registerMessengerConfiguration()	0	12	3

<?php

/*
 * This file is part of the FOSElasticaBundle package.
 *
 * (c) FriendsOfSymfony <https://friendsofsymfony.github.com/>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace FOS\ElasticaBundle\DependencyInjection;

use Elastica\Client as ElasticaClient;
use FOS\ElasticaBundle\Elastica\Client;
use FOS\ElasticaBundle\Manager\RepositoryManagerInterface;
use Symfony\Component\Config\FileLocator;
use Symfony\Component\DependencyInjection\Alias;
use Symfony\Component\DependencyInjection\ChildDefinition;
use Symfony\Component\DependencyInjection\ContainerAwareInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Exception\LogicException;
use Symfony\Component\DependencyInjection\Loader\XmlFileLoader;
use Symfony\Component\DependencyInjection\Reference;
use Symfony\Component\HttpKernel\DependencyInjection\Extension;
use Symfony\Component\Messenger\MessageBusInterface;

class FOSElasticaExtension extends Extension
{
    /**
     * Definition of elastica clients as configured by this extension.
     *
     * @var array
     */
    private $clients = [];

    /**
     * An array of indexes as configured by the extension.
     *
     * @var array
     */
    private $indexConfigs = [];

    /**
     * An array of index templates as configured by the extension.
     *
     * @var array
     */
    private $indexTemplateConfigs = [];

    /**
     * If we've encountered a type mapped to a specific persistence driver, it will be loaded
     * here.
     *
     * @var array
     */
    private $loadedDrivers = [];

    public function load(array $configs, ContainerBuilder $container)
    {
        $configuration = $this->getConfiguration($configs, $container);
        $config = $this->processConfiguration($configuration, $configs);

        $loader = new XmlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));

        if (empty($config['clients']) || empty($config['indexes'])) {
            // No Clients or indexes are defined
            return;
        }

        foreach (['config', 'index', 'persister', 'provider', 'source', 'transformer', 'event_listener', 'commands'] as $basename) {
            $loader->load(\sprintf('%s.xml', $basename));
        }

        if (empty($config['default_client'])) {
            $keys = \array_keys($config['clients']);
            $config['default_client'] = \reset($keys);
        }

        if (empty($config['default_index'])) {
            $keys = \array_keys($config['indexes']);
            $config['default_index'] = \reset($keys);
        }

        if ($this->isConfigEnabled($container, $config['messenger'])) {
            $this->registerMessengerConfiguration($config['messenger'], $container, $loader);
        }

        if (isset($config['serializer'])) {
            $loader->load('serializer.xml');

            $this->loadSerializer($config['serializer'], $container);
        }

        $this->loadClients($config['clients'], $container);
        $container->setAlias('fos_elastica.client', \sprintf('fos_elastica.client.%s', $config['default_client']));
        $container->setAlias(ElasticaClient::class, 'fos_elastica.client');
        $container->setAlias(Client::class, 'fos_elastica.client');

        $this->loadIndexes($config['indexes'], $container);
        $container->setAlias('fos_elastica.index', \sprintf('fos_elastica.index.%s', $config['default_index']));
        $container->setParameter('fos_elastica.default_index', $config['default_index']);

        if ($usedIndexNames = \array_intersect_key($config['indexes'], $config['index_templates'])) {
            throw new \DomainException(\sprintf('Index names "%s" are already in use and can not be used for index templates names', \implode('","', \array_keys($usedIndexNames))));
        }
        $this->loadIndexTemplates($config['index_templates'], $container);

        $container->getDefinition('fos_elastica.config_source.container')->replaceArgument(0, $this->indexConfigs);
        $container
            ->getDefinition('fos_elastica.config_source.template_container')
            ->replaceArgument(0, $this->indexTemplateConfigs);

        $this->loadIndexManager($container);
        $this->loadIndexTemplateManager($container);

        $this->createDefaultManagerAlias($config['default_manager'], $container);
    }

    /**
     * @return Configuration
     */
    public function getConfiguration(array $config, ContainerBuilder $container)
    {
        return new Configuration($container->getParameter('kernel.debug'));
    }

    /**
     * Loads the configured clients.
     *
     * @param array            $clients   An array of clients configurations
     * @param ContainerBuilder $container A ContainerBuilder instance
     */
    private function loadClients(array $clients, ContainerBuilder $container): void
    {
        foreach ($clients as $name => $clientConfig) {
            $clientId = \sprintf('fos_elastica.client.%s', $name);

            $clientDef = new ChildDefinition('fos_elastica.client_prototype');
            $clientDef->replaceArgument(0, $clientConfig);
            $clientDef->replaceArgument(1, null);

            $logger = $clientConfig['connections'][0]['logger'];
            if (false !== $logger) {
                $clientDef->addMethodCall('setLogger', [new Reference($logger)]);
            }

            $clientDef->addTag('fos_elastica.client');

            $container->setDefinition($clientId, $clientDef);

            $this->clients[$name] = [
                'id' => $clientId,
                'reference' => new Reference($clientId),
            ];
        }
    }

    /**
     * Loads the configured indexes.
     *
     * @param array            $indexes   An array of indexes configurations
     * @param ContainerBuilder $container A ContainerBuilder instance
     *
     * @throws \InvalidArgumentException
     */
    private function loadIndexes(array $indexes, ContainerBuilder $container): void
    {
        $indexableCallbacks = [];

        foreach ($indexes as $name => $index) {
            $indexId = \sprintf('fos_elastica.index.%s', $name);
            $indexName = $index['index_name'] ?? $name;

            $indexDef = new ChildDefinition('fos_elastica.index_prototype');
            $indexDef->setFactory([new Reference('fos_elastica.client'), 'getIndex']);
            $indexDef->replaceArgument(0, $indexName);
            $indexDef->addTag('fos_elastica.index', [
                'name' => $name,
            ]);

            if (isset($index['client'])) {
                $client = $this->getClient($index['client']);

                $indexDef->setFactory([$client, 'getIndex']);
            }

            $container->setDefinition($indexId, $indexDef);
            $reference = new Reference($indexId);

            $this->indexConfigs[$name] = [
                'elasticsearch_name' => $indexName,
                'reference' => $reference,
                'model' => $index['persistence']['model'] ?? null,
                'name' => $name,
                'settings' => $index['settings'],
                'index_prototype' => $index['index_prototype'] ?? [],
                'use_alias' => $index['use_alias'],
            ];

            if ($index['finder']) {
                $this->loadIndexFinder($container, $name, $reference);
            }

            $this->loadIndexConfig((array) $index, $this->indexConfigs[$name]);

            if (isset($index['indexable_callback'])) {
                $indexableCallbacks[$name] = $this->buildCallback($index['indexable_callback'], $name);
            }

            $this->loadIndexSerializerIntegration($index['serializer'] ?? [], $container, $reference);

            if (isset($index['persistence'])) {
                $this->loadIndexPersistenceIntegration($index['persistence'], $container, $reference, $name);
            }
        }

        $indexable = $container->getDefinition('fos_elastica.indexable');
        $indexable->replaceArgument(0, $indexableCallbacks);
    }

    /**
     * Loads the configured indexes.
     *
     * @param array            $indexTemplates An array of indexes configurations
     * @param ContainerBuilder $container      A ContainerBuilder instance
     *
     * @throws \InvalidArgumentException
     */
    private function loadIndexTemplates(array $indexTemplates, ContainerBuilder $container): void
    {
        foreach ($indexTemplates as $name => $indexTemplate) {
            $indexId = \sprintf('fos_elastica.index_template.%s', $name);
            $indexTemplateName = $indexTemplate['template_name'] ?? $name;

            $indexDef = new ChildDefinition('fos_elastica.index_template_prototype');
            $indexDef->setFactory([new Reference('fos_elastica.client'), 'getIndexTemplate']);
            $indexDef->replaceArgument(0, $indexTemplateName);
            $indexDef->addTag('fos_elastica.index_template', [
                'name' => $name,
            ]);

            if (isset($indexTemplate['client'])) {
                $client = $this->getClient($indexTemplate['client']);
                $indexDef->setFactory([$client, 'getIndexTemplate']);
            }

            $container->setDefinition($indexId, $indexDef);
            $reference = new Reference($indexId);

            $this->indexTemplateConfigs[$name] = [
                'elasticsearch_name' => $indexTemplateName,
                'reference' => $reference,
                'name' => $name,
                'settings' => $indexTemplate['settings'],
                'template' => $indexTemplate['template'],
            ];

            $this->loadIndexConfig((array) $indexTemplate, $this->indexTemplateConfigs[$name]);
        }
    }

    /**
     * Loads the configured index finders.
     *
     * @param string    $name  The index name
     * @param Reference $index Reference to the related index
     */
    private function loadIndexFinder(ContainerBuilder $container, string $name, Reference $index): void
    {
        $finderId = \sprintf('fos_elastica.finder.%s', $name);
        $finderDef = new ChildDefinition('fos_elastica.finder');
        $finderDef->replaceArgument(0, $index);
        $finderDef->replaceArgument(1, new Reference(\sprintf('fos_elastica.elastica_to_model_transformer.%s', $name)));

        $container->setDefinition($finderId, $finderDef);
    }

    /**
     * Loads the configured $index.
     */
    private function loadIndexConfig(array $index, array &$indexConfig): void
    {
        $indexConfig = \array_merge($indexConfig, [
            'mapping' => [], // An array containing anything that gets sent directly to ElasticSearch
            'config' => [],
        ]);

        foreach ([
            'dynamic_templates',
            'properties',
            '_id',
            '_routing',
            '_source',
        ] as $field) {
            if (isset($index[$field])) {
                $indexConfig['mapping'][$field] = $index[$field];
            }
        }

        foreach ([
            'analyzer',
            'search_analyzer',
            'dynamic',
            'date_detection',
            'dynamic_date_formats',
            'numeric_detection',
        ] as $field) {
            $indexConfig['config'][$field] = \array_key_exists($field, $index) ? $index[$field] : null;
        }
    }

    private function buildCallback($indexCallback, $indexName)
    {
        if (\is_array($indexCallback)) {
            if (!isset($indexCallback[0])) {
                throw new \InvalidArgumentException(\sprintf('Invalid indexable_callback for index "%s"', $indexName));
            }

            $classOrServiceRef = $this->transformServiceReference($indexCallback[0]);
            if ($classOrServiceRef instanceof Reference && !isset($indexCallback[1])) {
                return $classOrServiceRef; // __invoke
            }

            if (!isset($indexCallback[1])) {
                throw new \InvalidArgumentException(\sprintf('Invalid indexable_callback for index "%s"', $indexName));
            }

            return [$classOrServiceRef, $indexCallback[1]];
        }

        if (\is_string($indexCallback)) {
            return $this->transformServiceReference($indexCallback);
        }

        throw new \InvalidArgumentException(\sprintf('Invalid indexable_callback for index "%s"', $indexName));
    }

    private function transformServiceReference($classOrService)
    {
        return 0 === \strpos($classOrService, '@') ? new Reference(\substr($classOrService, 1)) : $classOrService;
    }

    private function loadIndexSerializerIntegration(array $config, ContainerBuilder $container, Reference $indexRef): void
    {
        if ($container->hasDefinition('fos_elastica.serializer_callback_prototype')) {
            $indexSerializerId = \sprintf('%s.serializer.callback', $indexRef);
            $indexSerializerDef = new ChildDefinition('fos_elastica.serializer_callback_prototype');

            if (isset($config['groups'])) {
                $indexSerializerDef->addMethodCall('setGroups', [$config['groups']]);
            }

            if (isset($config['serialize_null'])) {
                $indexSerializerDef->addMethodCall('setSerializeNull', [$config['serialize_null']]);
            }

            if (isset($config['version'])) {
                $indexSerializerDef->addMethodCall('setVersion', [$config['version']]);
            }

            $container->setDefinition($indexSerializerId, $indexSerializerDef);
        }
    }

    /**
     * Loads the optional provider and finder for a type.
     */
    private function loadIndexPersistenceIntegration(array $config, ContainerBuilder $container, Reference $indexRef, string $indexName): void
    {
        if (isset($config['driver'])) {
            $this->loadDriver($container, $config['driver']);
        }

        $elasticaToModelTransformerId = $this->loadElasticaToModelTransformer($config, $container, $indexName);
        $modelToElasticaTransformerId = $this->loadModelToElasticaTransformer($config, $container, $indexName);
        $objectPersisterId = $this->loadObjectPersister($config, $indexRef, $container, $indexName, $modelToElasticaTransformerId);

        if (isset($config['provider'])) {
            $this->loadIndexPagerProvider($config, $container, $indexName);
        }
        if (isset($config['finder'])) {
            $this->loadTypeFinder($config, $container, $elasticaToModelTransformerId, $indexRef, $indexName);
        }
        if (isset($config['listener']) && $config['listener']['enabled']) {
            $this->loadIndexListener($config, $container, $objectPersisterId, $indexName);
        }
    }

    /**
     * Creates and loads an ElasticaToModelTransformer.
     */
    private function loadElasticaToModelTransformer(array $persistenceConfig, ContainerBuilder $container, string $indexName): string
    {
        if (isset($persistenceConfig['elastica_to_model_transformer']['service'])) {
            return $persistenceConfig['elastica_to_model_transformer']['service'];
        }

        /* Note: transformer services may conflict with "prototype.driver", if
         * the index and type names were "prototype" and a driver, respectively.
         */
        $abstractId = \sprintf('fos_elastica.elastica_to_model_transformer.prototype.%s', $persistenceConfig['driver']);
        $serviceId = \sprintf('fos_elastica.elastica_to_model_transformer.%s', $indexName);
        $serviceDef = new ChildDefinition($abstractId);
        $serviceDef->addTag('fos_elastica.elastica_to_model_transformer', ['index' => $indexName]);

        $serviceDef->replaceArgument(1, $persistenceConfig['model']);
        $serviceDef->replaceArgument(2, \array_merge($persistenceConfig['elastica_to_model_transformer'], [
            'identifier' => $persistenceConfig['identifier'],
        ]));
        $container->setDefinition($serviceId, $serviceDef);

        return $serviceId;
    }

    /**
     * Creates and loads a ModelToElasticaTransformer for an index.
     */
    private function loadModelToElasticaTransformer(array $config, ContainerBuilder $container, string $indexName): string
    {
        if (isset($config['model_to_elastica_transformer']['service'])) {
            return $config['model_to_elastica_transformer']['service'];
        }

        $abstractId = $container->hasDefinition('fos_elastica.serializer_callback_prototype') ?
            'fos_elastica.model_to_elastica_identifier_transformer' :
            'fos_elastica.model_to_elastica_transformer';

        $serviceId = \sprintf('fos_elastica.model_to_elastica_transformer.%s', $indexName);
        $serviceDef = new ChildDefinition($abstractId);
        $serviceDef->replaceArgument(0, [
            'identifier' => $config['identifier'],
            'index' => $indexName,
        ]);
        $container->setDefinition($serviceId, $serviceDef);

        return $serviceId;
    }

    /**
     * Creates and loads an object persister for a index.
     */
    private function loadObjectPersister(array $config, Reference $indexRef, ContainerBuilder $container, string $indexName, string $transformerId): string
    {
        if (isset($config['persister']['service'])) {
            return $config['persister']['service'];
        }

        $arguments = [
            $indexRef,
            new Reference($transformerId),
            $config['model'],
        ];

        if ($container->hasDefinition('fos_elastica.serializer_callback_prototype')) {
            $abstractId = 'fos_elastica.object_serializer_persister';
            $callbackId = \sprintf('%s.serializer.callback', $indexRef);
            $arguments[] = [new Reference($callbackId), 'serialize'];
        } else {
            $abstractId = 'fos_elastica.object_persister';
            $mapping = $this->indexConfigs[$indexName]['mapping'];
            $argument = $mapping['properties'];
            $arguments[] = $argument;
        }

        $arguments[] = \array_intersect_key($config['persister'], \array_flip(['refresh']));

        $serviceId = \sprintf('fos_elastica.object_persister.%s', $indexName);
        $serviceDef = new ChildDefinition($abstractId);
        foreach ($arguments as $i => $argument) {
            $serviceDef->replaceArgument($i, $argument);
        }

        $serviceDef->addTag('fos_elastica.persister', ['index' => $indexName]);

        $container->setDefinition($serviceId, $serviceDef);

        return $serviceId;
    }

    /**
     * Loads a pager provider for a index.
     */
    private function loadIndexPagerProvider(array $indexConfig, ContainerBuilder $container, string $indexName): string
    {
        if (isset($indexConfig['provider']['service'])) {
            return $indexConfig['provider']['service'];
        }

        $baseConfig = $indexConfig['provider'];
        unset($baseConfig['service']);

        $driver = $indexConfig['driver'];

        switch ($driver) {
            case 'orm':
            case 'mongodb':
            case 'phpcr':
                $providerDef = new ChildDefinition('fos_elastica.pager_provider.prototype.'.$driver);
                $providerDef->replaceArgument(2, $indexConfig['model']);
                $providerDef->replaceArgument(3, $baseConfig);
                break;
            default:
                throw new \LogicException(\sprintf('The pager provider for driver "%s" does not exist.', $driver));
        }

        /* Note: provider services may conflict with "prototype.driver", if the
         * index and type names were "prototype" and a driver, respectively.
         */
        $providerId = \sprintf('fos_elastica.pager_provider.%s', $indexName);
        $providerDef->addTag('fos_elastica.pager_provider', ['index' => $indexName]);

        $container->setDefinition($providerId, $providerDef);

        return $providerId;
    }

    /**
     * Loads doctrine listeners to handle indexing of new or updated objects.
     */
    private function loadIndexListener(array $indexConfig, ContainerBuilder $container, string $objectPersisterId, string $indexName): string
    {
        if (isset($indexConfig['listener']['service'])) {
            return $indexConfig['listener']['service'];
        }

        /* Note: listener services may conflict with "prototype.driver", if the
         * index names were "prototype" and a driver, respectively.
         */
        $abstractListenerId = \sprintf('fos_elastica.listener.prototype.%s', $indexConfig['driver']);
        $listenerId = \sprintf('fos_elastica.listener.%s', $indexName);
        $listenerDef = new ChildDefinition($abstractListenerId);
        $listenerDef->replaceArgument(0, new Reference($objectPersisterId));
        $listenerDef->replaceArgument(3, $indexConfig['listener']['logger'] ?
            new Reference($indexConfig['listener']['logger']) :
            null
        );
        $listenerConfig = [
            'identifier' => $indexConfig['identifier'],
            'indexName' => $indexName,
        ];

        $tagName = null;
        switch ($indexConfig['driver']) {
            case 'orm':
                $tagName = 'doctrine.event_listener';
                break;
            case 'phpcr':
                $tagName = 'doctrine_phpcr.event_listener';
                break;
            case 'mongodb':
                $tagName = 'doctrine_mongodb.odm.event_listener';
                break;
        }

        if ($indexConfig['listener']['defer']) {
            $listenerDef->addTag(
                'kernel.event_listener',
                ['event' => 'kernel.terminate', 'method' => 'onTerminate']
            );
            $listenerDef->addTag(
                'kernel.event_listener',
                ['event' => 'console.terminate', 'method' => 'onTerminate']
            );
            $listenerConfig['defer'] = true;
        }

        $listenerDef->replaceArgument(2, $listenerConfig);

        if (null !== $tagName) {
            foreach ($this->getDoctrineEvents($indexConfig) as $event) {
                $listenerDef->addTag($tagName, ['event' => $event]);
            }
        }

        $container->setDefinition($listenerId, $listenerDef);

        return $listenerId;
    }

    /**
     * Map Elastica to Doctrine events for the current driver.
     */
    private function getDoctrineEvents(array $indexConfig)
    {
        switch ($indexConfig['driver']) {
            case 'orm':
                $eventsClass = '\Doctrine\ORM\Events';
                break;
            case 'phpcr':
                $eventsClass = '\Doctrine\ODM\PHPCR\Event';
                break;
            case 'mongodb':
                $eventsClass = '\Doctrine\ODM\MongoDB\Events';
                break;
            default:
                throw new \InvalidArgumentException(\sprintf('Cannot determine events for driver "%s"', $indexConfig['driver']));
        }

        $events = [];
        $eventMapping = [
            'insert' => [\constant($eventsClass.'::postPersist')],
            'update' => [\constant($eventsClass.'::postUpdate')],
            'delete' => [\constant($eventsClass.'::preRemove')],
            'flush' => [\constant($eventsClass.'::postFlush')],
        ];

        foreach ($eventMapping as $event => $doctrineEvents) {
            if (isset($indexConfig['listener'][$event]) && $indexConfig['listener'][$event]) {
                $events = \array_merge($events, $doctrineEvents);
            }
        }

        return $events;
    }

    /**
     * Loads a Type specific Finder.
     */
    private function loadTypeFinder(array $typeConfig, ContainerBuilder $container, string $elasticaToModelId, Reference $indexRef, string $indexName): string
    {
        if (isset($typeConfig['finder']['service'])) {
            $finderId = $typeConfig['finder']['service'];
        } else {
            $finderId = \sprintf('fos_elastica.finder.%s', $indexName);
            $finderDef = new ChildDefinition('fos_elastica.finder');
            $finderDef->replaceArgument(0, $indexRef);
            $finderDef->replaceArgument(1, new Reference($elasticaToModelId));
            $container->setDefinition($finderId, $finderDef);
        }

        $arguments = [$indexName, new Reference($finderId)];
        if (isset($typeConfig['repository'])) {
            $arguments[] = $typeConfig['repository'];
        }

        $container->getDefinition('fos_elastica.repository_manager')
            ->addMethodCall('addIndex', $arguments);

        $managerId = \sprintf('fos_elastica.manager.%s', $typeConfig['driver']);
        $container->getDefinition($managerId)
            ->addMethodCall('addEntity', [$typeConfig['model'], $indexName]);

        return $finderId;
    }

    /**
     * Loads the index manager.
     **/
    private function loadIndexManager(ContainerBuilder $container): void
    {
        $indexRefs = \array_map(function ($index) {
            return $index['reference'];
        }, $this->indexConfigs);

        $managerDef = $container->getDefinition('fos_elastica.index_manager');
        $managerDef->replaceArgument(0, $indexRefs);
    }

    /**
     * Load index template manager.
     */
    private function loadIndexTemplateManager(ContainerBuilder $container): void
    {
        $indexTemplateRefs = \array_map(function ($index) {
            return $index['reference'];
        }, $this->indexTemplateConfigs);

        $managerDef = $container->getDefinition('fos_elastica.index_template_manager');
        $managerDef->replaceArgument(0, $indexTemplateRefs);
    }

    /**
     * Makes sure a specific driver has been loaded.
     */
    private function loadDriver(ContainerBuilder $container, string $driver): void
    {
        if (\in_array($driver, $this->loadedDrivers, true)) {
            return;
        }

        $loader = new XmlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
        $loader->load($driver.'.xml');
        $this->loadedDrivers[] = $driver;
    }

    /**
     * Loads and configures the serializer prototype.
     */
    private function loadSerializer(array $config, ContainerBuilder $container): void
    {
        $container->setAlias('fos_elastica.serializer', $config['serializer']);

        $serializer = $container->getDefinition('fos_elastica.serializer_callback_prototype');
        $serializer->setClass($config['callback_class']);

        if (\is_subclass_of($config['callback_class'], ContainerAwareInterface::class)) {

Due to PHP Bug #53727, is_subclass_of might return inconsistent results on some PHP versions if \Symfony\Component\DependencyInjection\ContainerAwareInterface::class can be an interface. If so, you could instead use ReflectionClass::implementsInterface.

            $serializer->addMethodCall('setContainer', [new Reference('service_container')]);
        }
    }

    /**
     * Creates a default manager alias for defined default manager or the first loaded driver.
     */
    private function createDefaultManagerAlias(string $defaultManager, ContainerBuilder $container): void
    {
        if (0 == \count($this->loadedDrivers)) {
            return;
        }

        if (\count($this->loadedDrivers) > 1
            && \in_array($defaultManager, $this->loadedDrivers, true)
        ) {
            $defaultManagerService = $defaultManager;
        } else {
            $defaultManagerService = $this->loadedDrivers[0];
        }

        $container->setAlias('fos_elastica.manager', \sprintf('fos_elastica.manager.%s', $defaultManagerService));
        $container->setAlias(RepositoryManagerInterface::class, 'fos_elastica.manager');
    }

    /**
     * Returns a reference to a client given its configured name.
     *
     * @throws \InvalidArgumentException
     */
    private function getClient(string $clientName): Reference
    {
        if (!\array_key_exists($clientName, $this->clients)) {
            throw new \InvalidArgumentException(\sprintf('The elastica client with name "%s" is not defined', $clientName));
        }

        return $this->clients[$clientName]['reference'];
    }

    private function registerMessengerConfiguration(array $config, ContainerBuilder $container, XmlFileLoader $loader): void
    {
        if (!\interface_exists(MessageBusInterface::class)) {
            throw new LogicException('Messenger support cannot be enabled as the Messenger component is not installed. Try running "composer require symfony/messenger".');
        }

        $loader->load('messenger.xml');

        $container->getDefinition('fos_elastica.async_pager_persister')
            ->replaceArgument(2, $config['message_bus'] ? new Reference($config['message_bus']) : new Reference('messenger.default_bus'))
        ;
    }
}