Added a middleware to manage client instances + renamed parameter

Author: sebprt

src/ClientMiddleware.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace Kiboko\Component\Flow\RabbitMQ;
+
+use Bunny\Client;
+
+class ClientMiddleware
+{
+    private static ?Client $instance = null;
+
+    public static function getInstance(
+        string $host,
+        string $vhost,
+        ?string $user,
+        ?string $password,
+        ?int $port = null,
+    ): Client {
+        if (null === self::$instance) {
+            self::$instance = new Client([
+                'host' => $host,
+                'port' => $port,
+                'vhost' => $vhost,
+                'user' => $user,
+                'password' => $password,
+            ]);
+
+            self::$instance->connect();
+        }
+
+        return self::$instance;
+    }
+}

src/Extractor.php

@@ -14,10 +14,10 @@
     private Channel $channel;
 
     public function __construct(
-        private Client $connection,
+        private Client $client,
         private string $topic,
     ) {
-        $this->channel = $this->connection->channel();
+        $this->channel = $this->client->channel();
 
         $this->channel->queueDeclare(
             queue: $this->topic,

src/Loader.php

@@ -15,11 +15,11 @@
     private Channel $channel;
 
     public function __construct(
-        private Client $connection,
+        private Client $client,
         private string $topic,
         private ?string $exchange = null,
     ) {
-        $this->channel = $this->connection->channel();
+        $this->channel = $this->client->channel();
 
         $this->channel->queueDeclare(
             queue: $this->topic,

src/Rejection.php

@@ -14,12 +14,12 @@
     private Channel $channel;
 
     public function __construct(
-        private Client $connection,
+        private Client $client,
         private string $stepUuid,
         private string $topic,
         private ?string $exchange = null,
     ) {
-        $this->channel = $this->connection->channel();
+        $this->channel = $this->client->channel();
         $this->channel->queueDeclare(
             queue: $this->topic,
             passive: false,
@@ -32,7 +32,7 @@ public function __construct(
     public function teardown(): void
     {
         $this->channel->close();
-        $this->connection->stop();
+        $this->client->stop();
     }
 
     public static function withoutAuthentication(

src/StateManager.php

@@ -17,12 +17,12 @@ class StateManager
     private readonly Channel $channel;
 
     public function __construct(
-        private readonly Client $connection,
+        private readonly Client $client,
         private readonly string $topic,
         private readonly int $lineThreshold = 1000,
         private readonly ?string $exchange = null,
     ) {
-        $this->channel = $this->connection->channel();
+        $this->channel = $this->client->channel();
 
         $this->channel->queueDeclare(
             queue: $this->topic,