Improved the state management

src/State.php

@@ -14,8 +14,8 @@
 
     public function __construct(
         private readonly StateManager $manager,
+        private readonly string $jobCode,
         private readonly string $stepCode,
-        private readonly string $stepLabel,
     ) {
     }
 
@@ -52,11 +52,11 @@
         $this->manager->teardown($this);
     }
 
     public function toArray(): array
     {
         return [
-            'code' => $this->stepCode,
-            'label' => $this->stepLabel ?: $this->stepCode,
+            'jobCode' => $this->jobCode,
+            'stepCode' => $this->stepCode,
             'metrics' => iterator_to_array($this->walkMetrics()),
         ];
     }

src/StateManager.php

@@ -10,8 +10,8 @@
 
 class StateManager
 {
     private array $steps = [];
     private array $tearedDown = [];
     private int $messageCount = 0;
     private int $lineCount = 0;
     private readonly Channel $channel;
@@ -38,14 +38,59 @@
         $this->channel->close();
     }
 
+    public static function withoutAuthentication(
+        string $host,
+        string $vhost,
+        string $topic,
+        ?string $exchange = null,
+        ?int $port = null,
+        ?int $lineThreshold = 1000,
+    ): self {
+        $connection = new Client([
+            'host' => $host,
+            'port' => $port,
+            'vhost' => $vhost,
+            'user' => 'guest',
+            'password' => 'guest',
+        ]);
+        $connection->connect();
+
+        return new self(connection: $connection, topic: $topic, lineThreshold: $lineThreshold, exchange: $exchange);
+    }
+
+    public static function withAuthentication(
+        string $host,
+        string $vhost,
+        string $topic,
+        string $user,
+        string $password,
+        ?string $exchange = null,
+        ?int $port = null,
+        ?int $lineThreshold = 1000,
+    ): self {
+        $connection = new Client([
+            'host' => $host,
+            'port' => $port,
+            'vhost' => $vhost,
+            'user' => $user,
+            'password' => $password,
+        ]);
+        $connection->connect();
+
+        return new self(connection: $connection, topic: $topic, lineThreshold: $lineThreshold, exchange: $exchange);
+    }
+
+
     public function stepState(
+       string $jobCode,
        string $stepCode,
-       string $stepLabel,
     ): State {
-        return $this->steps[] = new State($this, $stepCode, $stepLabel);
+        $this->steps[] = $state = new State($this, $jobCode, $stepCode);
+
+        return $state;
     }
 
     public function trySend($count): void
     {
         $this->lineCount += $count;
 
@@ -75,11 +120,12 @@
         $this->channel->publish(
             json_encode([
                 'messageNumber' => ++$this->messageCount,
-                'id' => Uuid::uuid4(),
+                'execution' => getenv('EXECUTION_ID'),
                 'date' => ['date' => $date->format('c'), 'tz' => $date->getTimezone()->getName()],
                 'stepsUpdates' => array_map(fn (State $step) => $step->toArray(), $this->steps),
             ], \JSON_THROW_ON_ERROR),
             [
+                'type' => 'update',
                 'content-type' => 'application/json',
             ],
             $this->exchange,