Merge pull request #48 from thephpleague/improve_coverage

Improve code coverage
thephpleague · Oct 30, 2016 · b7922ae · b7922ae
2 parents d693866 + 7908620
commit b7922ae
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 1 deletion.
diff --git a/spec/QueueCommandNormalizerSpec.php b/spec/QueueCommandNormalizerSpec.php
@@ -36,6 +36,8 @@ function it_normalizes_queue_command_and_delegates_message_to_aggregate(Message
             'name' => 'queue',
             'data' => ['key' => 'value'],
         ]);
+
+        $this->supportsNormalization($queueCommand)->shouldReturn(true);
     }
 
     function it_denormalizes_queue_command_and_delegates_message_to_aggregate(Message $message, AggregateNormalizer $aggregate)
@@ -52,5 +54,7 @@ function it_denormalizes_queue_command_and_delegates_message_to_aggregate(Messag
         $queueCommand->shouldHaveType(QueueCommand::class);
         $queueCommand->getCommand()->shouldReturn($message);
         $queueCommand->getName()->shouldReturn('queue');
+
+        $this->supportsDenormalization($normalized, QueueCommand::class)->shouldReturn(true);
     }
 }
diff --git a/spec/QueueMiddlewareSpec.php b/spec/QueueMiddlewareSpec.php
@@ -4,6 +4,7 @@
 
 use Bernard\Message;
 use Bernard\Producer;
+use League\Tactician\Bernard\QueueCommand;
 use League\Tactician\Bernard\QueuedCommand;
 use League\Tactician\Bernard\QueueMiddleware;
 use League\Tactician\Middleware;
@@ -48,7 +49,7 @@ function ($command) use ($middleware) {
         );
     }
 
-    function it_unwraps_a_command(Producer $producer, Message $command, Middleware $middleware)
+    function it_unwraps_an_already_queued_command(Producer $producer, Message $command, Middleware $middleware)
     {
         $queuedCommand = new QueuedCommand($command->getWrappedObject());
         $producer->produce($command)->shouldNotBeCalled();
@@ -62,4 +63,19 @@ function ($command) use ($middleware) {
             }
         );
     }
+
+    function it_unwraps_a_wrapped_command(Producer $producer, Command $command, Middleware $middleware)
+    {
+        $queuedCommand = new QueuedCommand(new QueueCommand($command->getWrappedObject()));
+        $producer->produce(Argument::any())->shouldNotBeCalled();
+
+        $middleware->execute($command, Argument::type('callable'))->shouldBeCalled();
+
+        $this->execute(
+            $queuedCommand,
+            function ($command) use ($middleware) {
+                return $middleware->getWrappedObject()->execute($command, function () {});
+            }
+        );
+    }
 }