add tests for php serializer.

Author: makasim

pkg/enqueue-bundle/Events/PhpSerializerEventTransformer.php

@@ -14,14 +14,7 @@ class PhpSerializerEventTransformer implements EventTransformer
      */
     public function toMessage($eventName, Event $event = null)
     {
-        if (version_compare(Kernel::VERSION, '3.0', '<')) {
-            throw new \LogicException(
-                'This transformer does not work on Symfony prior 3.0. '.
-                'The event contains eventDispatcher and therefor could not be serialized. '.
-                'You have to register a transformer for every async event. '.
-                'Read the doc: https://github.com/php-enqueue/enqueue-dev/blob/master/docs/bundle/async_events.md#event-transformer'
-            );
-        }
+        $this->assertSymfony30OrHigher();
 
         $message = new Message();
         $message->setBody(serialize($event));
@@ -34,6 +27,20 @@ public function toMessage($eventName, Event $event = null)
      */
     public function toEvent($eventName, PsrMessage $message)
     {
+        $this->assertSymfony30OrHigher();
+
         return unserialize($message->getBody());
     }
+
+    private function assertSymfony30OrHigher()
+    {
+        if (version_compare(Kernel::VERSION, '3.0', '<')) {
+            throw new \LogicException(
+                'This transformer does not work on Symfony prior 3.0. '.
+                'The event contains eventDispatcher and therefor could not be serialized. '.
+                'You have to register a transformer for every async event. '.
+                'Read the doc: https://github.com/php-enqueue/enqueue-dev/blob/master/docs/bundle/async_events.md#event-transformer'
+            );
+        }
+    }
 }

pkg/enqueue-bundle/Tests/Unit/Events/PhpSerializerEventTransformerTest.php

@@ -0,0 +1,86 @@
+<?php
+
+namespace Enqueue\Bundle\Tests\Unit\Events;
+
+use Enqueue\Bundle\Events\EventTransformer;
+use Enqueue\Bundle\Events\PhpSerializerEventTransformer;
+use Enqueue\Client\Message;
+use Enqueue\Null\NullMessage;
+use Enqueue\Test\ClassExtensionTrait;
+use PHPUnit\Framework\TestCase;
+use Symfony\Component\EventDispatcher\GenericEvent;
+use Symfony\Component\HttpKernel\Kernel;
+
+class PhpSerializerEventTransformerTest extends TestCase
+{
+    use ClassExtensionTrait;
+
+    public function testShouldImplementEventTransformerInterface()
+    {
+        $this->assertClassImplements(EventTransformer::class, PhpSerializerEventTransformer::class);
+    }
+
+    public function testCouldBeConstructedWithoutAnyArguments()
+    {
+        new PhpSerializerEventTransformer();
+    }
+
+    public function testShouldReturnMessageWithPhpSerializedEventAsBodyOnToMessage()
+    {
+        if (version_compare(Kernel::VERSION, '3.0', '<')) {
+            $this->markTestSkipped('This functionality only works on Symfony 3.0 or higher');
+        }
+
+        $transformer = new PhpSerializerEventTransformer();
+
+        $message = $transformer->toMessage(new GenericEvent('theSubject'));
+
+        $this->assertInstanceOf(Message::class, $message);
+        $this->assertEquals(serialize(new GenericEvent('theSubject')), $message->getBody());
+    }
+
+    public function testShouldReturnEventUnserializedFromMessageBodyOnToEvent()
+    {
+        if (version_compare(Kernel::VERSION, '3.0', '<')) {
+            $this->markTestSkipped('This functionality only works on Symfony 3.0 or higher');
+        }
+
+        $message = new NullMessage();
+        $message->setBody(serialize(new GenericEvent('theSubject')));
+
+        $transformer = new PhpSerializerEventTransformer();
+
+        $event = $transformer->toEvent('anEventName', $message);
+
+        $this->assertInstanceOf(GenericEvent::class, $event);
+        $this->assertEquals('tehSubject', $event->getSubject());
+    }
+
+    public function testThrowNotSupportedExceptionOnSymfonyPrior30OnToMessage()
+    {
+        if (version_compare(Kernel::VERSION, '3.0', '>=')) {
+            $this->markTestSkipped('This functionality only works on Symfony 3.0 or higher');
+        }
+
+        $this->expectException(\LogicException::class);
+        $this->expectExceptionMessage('This transformer does not work on Symfony prior 3.0.');
+
+        $transformer = new PhpSerializerEventTransformer();
+
+        $transformer->toMessage(new GenericEvent());
+    }
+
+    public function testThrowNotSupportedExceptionOnSymfonyPrior30OnToEvent()
+    {
+        if (version_compare(Kernel::VERSION, '3.0', '>=')) {
+            $this->markTestSkipped('This functionality only works on Symfony 3.0 or higher');
+        }
+
+        $this->expectException(\LogicException::class);
+        $this->expectExceptionMessage('This transformer does not work on Symfony prior 3.0.');
+
+        $transformer = new PhpSerializerEventTransformer();
+
+        $transformer->toEvent('anEvent', new NullMessage());
+    }
+}