Please add simplier task loader via DiC

[Koc]

Hello!

First of all - thank you for your work.

I propose add much simpler loader (maybe as chain) for tasks. Easiest way to add sheduled repeated tasks - register they via Symfony's DiC. For example Magento uses XML: http://www.magentocommerce.com/wiki/1_-_installation_and_configuration/how_to_setup_a_cron_job

  <service id="foo.bar">
    <tag name="ninethousand_jobqueue.task" command="%path_to_php% console some:command" cron-expr="0 1 * * *" />
  </service>

[jessegreathouse]

The jobqueue is meant to keep tasks in the data persistence layer so it would be possible to create it if it doesn't already exist as long as it has some identifying attribute. Without an identifying feature it would likely create a new scheduled task every time the DiC was loaded, but with an identifying attribute it could create it unless it already exists.

[Koc]

service DiC tag requies unique id attribute so I think id wouldn't a problem.

[Koc]

So I've created this

        <service id="ololo.project.swiftmailer_job" synthetic="true">
            <tag name="ninethousand_jobqueue.task" command="%path_to_php% console swiftmailer:spool:send" cron-expr="1 * * * *" />
        </service>

<?php

namespace Ololo\Bundle\ProjectBundle\DependencyInjection\Compiler;

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

class RegisterJobsPass implements CompilerPassInterface
{
    public function process(ContainerBuilder $container)
    {
        $jobServicesIds = array();
        foreach ($container->findTaggedServiceIds('ninethousand_jobqueue.task') as $id => $attr) {
            $jobServicesIds[$id] = $attr[0];
        }

        $container->setParameter('ninethousand_jobqueue.jobs_ids', $jobServicesIds);

        $parameter = $container->getParameter('jobqueue.adapter.options');
        $parameter['jobcontrol']['type_mapping']['OloloConsoleJobControl'] = 'Ololo\Bundle\ProjectBundle\JobQueue\ConsoleJobControl'; // just a child of default job control class

        $container->setParameter('jobqueue.adapter.options', $parameter);
    }
}

<?php

namespace Ololo\Bundle\ProjectBundle\Command;

use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;

use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

use NineThousand\Bundle\NineThousandJobqueueBundle\Entity\Job;

class UpdateJobsCommand extends ContainerAwareCommand
{
    protected function configure()
    {
        $this->setName('ololo:project:update-jobs');
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $em = $this->getContainer()->get('doctrine')->getEntityManager('write');

        $jobs = $this->getContainer()->getParameter('ninethousand_jobqueue.jobs_ids');

        foreach($jobs as $name => $job) {

            $jobInQueue = $em->getRepository("NineThousand\Bundle\NineThousandJobqueueBundle\Entity\Job")->findOneBy(array('name' => $name, 'parent' => 0));

            if ($jobInQueue) {

                $jobInQueue->setExecutable($job['command']);
                $jobInQueue->setSchedule($job['cron-expr']);

            } else {

                $jobInQueue = new Job();
                $jobInQueue->setName($name);
                $jobInQueue->setExecutable($job['command']);
                $jobInQueue->setSchedule($job['cron-expr']);
                $jobInQueue->setType('OloloConsoleJobControl');
                $jobInQueue->setCreateDate(new \DateTime());
                $em->persist($jobInQueue);

            }
        }

        $em->flush();
    }
}
``