Task\TaskBundle\DependencyInjection\TaskCompilerPass

Complexity

Total Complexity

7

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Importance

Changes	1
Bugs	0	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
C	process()	0	38	7

<?php

namespace Task\TaskBundle\DependencyInjection;

use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Reference;

/**
 * Compiler pass which collects worker services.
 *
 * @author @wachterjohannes <johannes.wachter@massiveart.com>
 */
class TaskCompilerPass implements CompilerPassInterface
{
    const SCHEDULER_ID = 'task.scheduler';
    const INTERVAL_TAG = 'task.interval';
    const KEY_ATTRIBUTE = 'key';
    const INTERVAL_ATTRIBUTE = 'interval';
    const WORKLOAD_ATTRIBUTE = 'workload';
    const CREATE_FUNCTION_NAME = 'createTaskAndSchedule';

    /**
     * {@inheritdoc}
     */
    public function process(ContainerBuilder $container)
    {
        if (!$container->has(self::SCHEDULER_ID)) {
            return;
        }

        $schedulerDefinition = $container->getDefinition(self::SCHEDULER_ID);

        $taggedServices = $container->findTaggedServiceIds(self::INTERVAL_TAG);
        foreach ($taggedServices as $id => $tags) {
            $handlerDefinition = $container->getDefinition($id);
            $tag = $handlerDefinition->getTag(HandlerCompilerPass::HANDLER_TAG);

            $handler = $tag[0][HandlerCompilerPass::HANDLER_NAME_ATTRIBUTE];

            // remove all tasks with $id and not completed
            foreach ($tags as $attributes) {
                $interval = $attributes[self::INTERVAL_ATTRIBUTE];
                $workload = isset($attributes[self::WORKLOAD_ATTRIBUTE]) ? $attributes[self::WORKLOAD_ATTRIBUTE] : null;
                $key = isset($attributes[self::KEY_ATTRIBUTE]) ? $attributes[self::KEY_ATTRIBUTE] : null;

                if (!$key) {
                    $key = $handler . '_' . $interval . '_' . serialize($workload);
                }


                $schedulerDefinition->addMethodCall(
                    self::CREATE_FUNCTION_NAME,
                    [
                        $handler,
                        $interval,
                        $workload,
                        $key,
                    ]
                );
            }
        }
    }
}