Adds PayloadDeserializerInterface to PayloadDeserializer class

spiral · Dec 12, 2023 · 3c926a2 · 3c926a2
1 parent 650df60
commit 3c926a2
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 1 deletion.
diff --git a/src/Queue/PayloadDeserializer.php b/src/Queue/PayloadDeserializer.php
@@ -10,7 +10,7 @@
 use Spiral\RoadRunner\Jobs\Exception\JobsException;
 use Spiral\RoadRunner\Jobs\Task\ReceivedTaskInterface;
 
-final class PayloadDeserializer
+final class PayloadDeserializer implements PayloadDeserializerInterface
 {
     /**
      * Cache for detected types.

diff --git a/src/Queue/PayloadDeserializerInterface.php b/src/Queue/PayloadDeserializerInterface.php
@@ -8,5 +8,8 @@
 
 interface PayloadDeserializerInterface
 {
+    /**
+     * Deserializes the payload of the given task.
+     */
     public function deserialize(ReceivedTaskInterface $task): mixed;
 }
diff --git a/tests/src/Bootloader/QueueBootloaderTest.php b/tests/src/Bootloader/QueueBootloaderTest.php
@@ -8,6 +8,8 @@
 use Spiral\Core\ConfigsInterface;
 use Spiral\Exceptions\ExceptionReporterInterface;
 use Spiral\Queue\HandlerRegistryInterface;
+use Spiral\RoadRunnerBridge\Queue\PayloadDeserializer;
+use Spiral\RoadRunnerBridge\Queue\PayloadDeserializerInterface;
 use Spiral\Serializer\SerializerInterface;
 use Spiral\RoadRunnerBridge\Queue\Dispatcher;
 use Spiral\RoadRunnerBridge\Queue\PipelineRegistryInterface;
@@ -88,6 +90,14 @@ public function testGetsSerializerInterface(): void
         );
     }
 
+    public function testGetsPayloadDeserializerInterface(): void
+    {
+        $this->assertContainerBoundAsSingleton(
+            PayloadDeserializerInterface::class,
+            PayloadDeserializer::class
+        );
+    }
+
     public function testConfigShouldBeDefined(): void
     {
         $configurator = $this->getContainer()->get(ConfigsInterface::class);