Core\Queue\MongoQueueFactory::__invoke()

Complexity

Conditions	4
Paths	8

Size

Total Lines	29
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	12
CRAP Score	4

Importance

Changes

0

<?php
    public function __invoke(ContainerInterface $container, $requestedName, array $options = null)
    {
        /* @var \Doctrine\ODM\MongoDB\DocumentManager $dm */
        $config = $container->get('config');
        $config = $config['slm_queue']['queues'][$requestedName] ?? [];
        $dm = $container->get('Core/DocumentManager');

        // @codeCoverageIgnoreStart
        if (isset($config['dns'])) {
            $client = new \MongoDB\Client($config['dns']);
        } else {
            $client = $dm->getConnection()->getMongoClient()->getClient();
        }
        // @codeCoverageIgnoreEnd

        if (!isset($config['db'])) {
            $config['db'] = $dm->getConfiguration()->getDefaultDB();
        }

        if (!isset($config['collection'])) {
            $config['collection'] = 'core.queue';
        }

        $collection = $client->selectCollection($config['db'], $config['collection']);
        $jobPlugins = $container->get(JobPluginManager::class);

        $service = new MongoQueue($collection, $requestedName, $jobPlugins);
        
        return $service;    
    }