<?php

namespace Akeneo\Tool\Bundle\BatchBundle\DependencyInjection\Compiler;

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

/**
 * Compiler pass to register tagged jobs to the registry
 *
 * @author    Gildas Quemener <gildas.quemener@gmail.com>
 * @copyright 2013 Akeneo SAS (http://www.akeneo.com)
 * @license   http://opensource.org/licenses/MIT MIT
 */
class RegisterJobsPass implements CompilerPassInterface
{
    /** @staticvar string The registry id */
    const REGISTRY_ID = 'akeneo_batch.job.job_registry';

    /** @staticvar string */
    const SERVICE_TAG = 'akeneo_batch.job';

    /** @staticvar string */
    const DEFAULT_CONNECTOR = 'default';

    /** @staticvar string */
    const DEFAULT_JOB_TYPE = 'default';

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

        $registryDefinition = $container->getDefinition(self::REGISTRY_ID);
        foreach ($container->findTaggedServiceIds(self::SERVICE_TAG) as $serviceId => $tags) {
            foreach ($tags as $tag) {
                $connector = isset($tag['connector']) ? $tag['connector'] : self::DEFAULT_CONNECTOR;
                $type = isset($tag['type']) ? $tag['type'] : self::DEFAULT_JOB_TYPE;
                $feature = $tag['feature'] ?? null;
                $job = new Reference($serviceId);
                $registryDefinition->addMethodCall('register', [$job, $type, $connector, $feature]);
            }
        }
    }
}