Updated the state interface

Author: gplanchat

src/Rejection.php

@@ -8,38 +8,64 @@
 
 final class Rejection implements RejectionInterface
 {
-    private Client $connection;
     private Channel $channel;
 
     public function __construct(
-        string $host,
-        string $vhost,
+        Client $connection,
+        private string $stepUuid,
         private string $topic,
-        ?string $user = 'guest',
-        ?string $password = 'guest',
         private ?string $exchange = null,
-        ?int $port = null,
     ) {
-        $this->connection = new Client([
+        $this->channel = $connection->channel();
+        $this->channel->queueDeclare(
+            queue: $this->topic,
+            passive: false,
+            durable: true,
+            exclusive: false,
+            autoDelete: true,
+        );
+    }
+
+    public static function withoutAuthentication(
+        string $stepUuid,
+        string $host,
+        string $vhost,
+        string $topic,
+        ?string $exchange = null,
+        ?int $port = null,
+    ): self {
+        $connection = new Client([
             'host' => $host,
             'port' => $port,
             'vhost'  => $vhost,
-            'user' => $user,
-            'password' => $password,
+            'user' => 'guest',
+            'password' => 'guest',
         ]);
-        $this->connection->connect();
+        $connection->connect();
 
-        $this->channel = $this->connection->channel();
+        return new self($connection, stepUuid: $stepUuid, topic: $topic, exchange: $exchange);
     }
 
-    public static function withoutAuthentication(
+    public static function withAuthentication(
+        string $stepUuid,
         string $host,
         string $vhost,
         string $topic,
+        ?string $user,
+        ?string $password,
         ?string $exchange = null,
         ?int $port = null,
     ): self {
-        return new self(host: $host, vhost: $vhost, topic: $topic, exchange: $exchange, port: $port);
+        $connection = new Client([
+            'host' => $host,
+            'port' => $port,
+            'vhost'  => $vhost,
+            'user' => $user,
+            'password' => $password,
+        ]);
+        $connection->connect();
+
+        return new self($connection, stepUuid: $stepUuid, topic: $topic, exchange: $exchange);
     }
 
     public function reject(object|array $rejection, ?\Throwable $exception = null): void
@@ -48,6 +74,7 @@ public function reject(object|array $rejection, ?\Throwable $exception = null):
             \json_encode([
                 'item' => $rejection,
                 'exception' => $exception,
+                'step' => $this->stepUuid,
             ]),
             [
                 'content-type' => 'application/json',

src/RabbitState.php src/State.phpsrc/RabbitState.php renamed to src/State.php

@@ -6,40 +6,70 @@
 use Bunny\Client;
 use Kiboko\Contract\Pipeline\StateInterface;
 
-final class RabbitState implements StateInterface
+final class State implements StateInterface
 {
-    private Client $connection;
     private Channel $channel;
-    private \DateTimeInterface $date;
-    private string $stepUuid;
 
     public function __construct(
-        private string $host,
-        private string $user,
-        private string $password,
+        Client $connection,
+        private string $stepUuid,
         private string $topic,
-        private ?int $port = null,
-        private ?string $vhost = null,
         private ?string $exchange = null,
     ) {
-        $this->date = new \DateTime();
-        $this->stepUuid = $this->generateRandomUuid();
+        $this->channel = $connection->channel();
+    }
+
+    public static function withoutAuthentication(
+        string $stepUuid,
+        string $host,
+        string $vhost,
+        string $topic,
+        ?string $exchange = null,
+        ?int $port = null,
+    ): self {
+        $connection = new Client([
+            'host' => $host,
+            'port' => $port,
+            'vhost'  => $vhost,
+            'user' => 'guest',
+            'password' => 'guest',
+        ]);
+        $connection->connect();
 
-        $this->connection = new Client([
-            'host' => $this->host,
-            'vhost'  => $this->vhost,
-            'port' => $this->port,
-            'user' => $this->user,
-            'password' => $this->password,
+        return new self($connection, stepUuid: $stepUuid, topic: $topic, exchange: $exchange);
+    }
+
+    public static function withAuthentication(
+        string $stepUuid,
+        string $host,
+        string $vhost,
+        string $topic,
+        ?string $user,
+        ?string $password,
+        ?string $exchange = null,
+        ?int $port = null,
+    ): self {
+        $connection = new Client([
+            'host' => $host,
+            'port' => $port,
+            'vhost'  => $vhost,
+            'user' => $user,
+            'password' => $password,
         ]);
+        $connection->connect();
 
-        $this->connection->connect();
-        $this->channel = $this->connection->channel();
-        $this->channel->queueDeclare($this->topic);
+        return new self($connection, stepUuid: $stepUuid, topic: $topic, exchange: $exchange);
     }
 
     public function initialize(int $start = 0): void
     {
+        $this->channel->queueDeclare(
+            queue: $this->topic,
+            passive: false,
+            durable: true,
+            exclusive: false,
+            autoDelete: true,
+        );
     }
 
     public function accept(int $step = 1): void