added unit tests

Author: wachterjohannes

src/Command/ScheduleTaskCommand.php

@@ -34,7 +34,7 @@ protected function configure()
     {
         $this
             ->setDescription('Run pending tasks')
-            ->addArgument('workerName', InputArgument::REQUIRED)
+            ->addArgument('handler', InputArgument::REQUIRED)
             ->addArgument('workload', InputArgument::OPTIONAL);
     }
 
@@ -44,7 +44,7 @@ protected function configure()
     protected function execute(InputInterface $input, OutputInterface $output)
     {
         $this->scheduler
-            ->createTask($input->getArgument('workerName'), $input->getArgument('workload'))
+            ->createTask($input->getArgument('handler'), $input->getArgument('workload'))
             ->schedule();
     }
 }

tests/Unit/Command/RunCommandTest.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace Unit\Command;
+
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Task\SchedulerInterface;
+use Task\TaskBundle\Command\RunCommand;
+
+class RunCommandTest extends \PHPUnit_Framework_TestCase
+{
+    public function testConfigure()
+    {
+        $scheduler = $this->prophesize(SchedulerInterface::class);
+        $command = new RunCommand($scheduler->reveal());
+
+        $this->assertEquals('task:run', $command->getName());
+    }
+
+    public function testRun()
+    {
+        $input = $this->prophesize(InputInterface::class);
+        $output = $this->prophesize(OutputInterface::class);
+
+        $scheduler = $this->prophesize(SchedulerInterface::class);
+        $command = new RunCommand($scheduler->reveal());
+
+        $command->run($input->reveal(), $output->reveal());
+
+        $scheduler->run()->shouldBeCalledTimes(1);
+    }
+}

tests/Unit/Command/ScheduleTaskCommandTest.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace Unit\Command;
+
+use Prophecy\Argument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Task\SchedulerInterface;
+use Task\TaskBuilderInterface;
+use Task\TaskBundle\Command\ScheduleTaskCommand;
+
+class ScheduleTaskCommandTest extends \PHPUnit_Framework_TestCase
+{
+    public function testConfigure()
+    {
+        $scheduler = $this->prophesize(SchedulerInterface::class);
+        $command = new ScheduleTaskCommand($scheduler->reveal());
+
+        $this->assertEquals('task:schedule:task', $command->getName());
+        $this->assertTrue($command->getDefinition()->hasArgument('handler'));
+        $this->assertTrue($command->getDefinition()->hasArgument('workload'));
+    }
+
+    public function runProvider()
+    {
+        return [
+            ['test-handler', 'test-workload'],
+            ['test-handler-1', 'test-workload-1'],
+        ];
+    }
+
+    /**
+     * @dataProvider runProvider
+     */
+    public function testRun($handler, $workload)
+    {
+        $taskBuilder = $this->prophesize(TaskBuilderInterface::class);
+
+        $input = $this->prophesize(InputInterface::class);
+        $output = $this->prophesize(OutputInterface::class);
+
+        $input->bind(Argument::any())->willReturn(true);
+        $input->validate()->willReturn(true);
+        $input->isInteractive()->willReturn(false);
+        $input->hasArgument('command')->willReturn(false);
+
+        $input->getArgument('handler')->willReturn($handler);
+        $input->getArgument('workload')->willReturn($workload);
+
+        $scheduler = $this->prophesize(SchedulerInterface::class);
+        $command = new ScheduleTaskCommand($scheduler->reveal());
+
+        $scheduler->createTask($handler, $workload)->shouldBeCalledTimes(1)->willReturn($taskBuilder->reveal());
+
+        $command->run($input->reveal(), $output->reveal());
+
+        $taskBuilder->schedule()->shouldBeCalledTimes(1);
+    }
+}

tests/Unit/DependencyInjection/HandlerCompilerPassTest.php

@@ -0,0 +1,61 @@
+<?php
+
+namespace Unit\DependencyInjection;
+
+use Prophecy\Argument;
+use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\DependencyInjection\Definition;
+use Task\TaskBundle\DependencyInjection\HandlerCompilerPass;
+
+class HandlerCompilerPassTest extends \PHPUnit_Framework_TestCase
+{
+    public function testProcess()
+    {
+        $containerBuilder = $this->prophesize(ContainerBuilder::class);
+        $definition = $this->prophesize(Definition::class);
+
+        $containerBuilder->has(HandlerCompilerPass::REGISTRY_ID)->willReturn(true);
+        $containerBuilder->findDefinition(HandlerCompilerPass::REGISTRY_ID)->willReturn($definition->reveal());
+
+        $containerBuilder->findTaggedServiceIds(HandlerCompilerPass::HANDLER_TAG)
+            ->willReturn(
+                [
+                    'id-1' => [
+                        ['name' => 'name-1'],
+                    ],
+                    'id-2' => [
+                        ['name' => 'name-2-1'],
+                        ['name' => 'name-2-2'],
+                    ],
+                ]
+            );
+
+        $compilerPass = new HandlerCompilerPass();
+        $compilerPass->process($containerBuilder->reveal());
+
+        $definition->addMethodCall(
+            HandlerCompilerPass::ADD_FUNCTION_NAME,
+            Argument::that(
+                function ($arguments) {
+                    return $arguments[0] === 'name-1' && $arguments[1]->__toString() === 'id-1';
+                }
+            )
+        )->shouldBeCalledTimes(1);
+        $definition->addMethodCall(
+            HandlerCompilerPass::ADD_FUNCTION_NAME,
+            Argument::that(
+                function ($arguments) {
+                    return $arguments[0] === 'name-2-1' && $arguments[1]->__toString() === 'id-2';
+                }
+            )
+        )->shouldBeCalledTimes(1);
+        $definition->addMethodCall(
+            HandlerCompilerPass::ADD_FUNCTION_NAME,
+            Argument::that(
+                function ($arguments) {
+                    return $arguments[0] === 'name-2-2' && $arguments[1]->__toString() === 'id-2';
+                }
+            )
+        )->shouldBeCalledTimes(1);
+    }
+}