Updated the RabbitState class and started to write some tests

Author: sebprt

composer.json

@@ -21,7 +21,8 @@
   "autoload-dev": {
     "psr-4": {
       "unit\\Kiboko\\Component\\Flow\\RabbitMQ\\": "tests/unit/",
-      "functional\\Kiboko\\Component\\Flow\\RabbitMQ\\": "tests/functional/"
+      "functional\\Kiboko\\Component\\Flow\\RabbitMQ\\": "tests/functional/",
+      "integration\\Kiboko\\Component\\Flow\\RabbitMQ\\": "tests/integration/"
     }
   },
   "config": {

src/RabbitState.php

@@ -10,7 +10,8 @@ final class RabbitState implements StateInterface
 {
     private Client $connection;
     private Channel $channel;
-    private array $metrics;
+    private \DateTimeInterface $date;
+    private string $stepUuid;
 
     public function __construct(
         private string $host,
@@ -21,6 +22,9 @@ public function __construct(
         private ?string $vhost = null,
         private ?string $exchange = null,
     ) {
+        $this->date = new \DateTime();
+        $this->stepUuid = $this->generateRandomUuid();
+
         $this->connection = new Client([
             'host' => $this->host,
             'vhost'  => $this->vhost,
@@ -36,19 +40,25 @@ public function __construct(
 
     public function initialize(int $start = 0): void
     {
-        $this->metrics = [
-            'accept' => 0,
-            'reject' => 0,
-        ];
     }
 
     public function accept(int $step = 1): void
     {
-        $this->metrics['accept'] += $step;
-
         $this->channel->publish(
             \json_encode([
-                'Line accepted : ' => $this->metrics['accept']
+                'id' => $this->generateRandomUuid(),
+                'date' => ['date' => $this->date->format('c'), 'tz' => $this->date->getTimezone()->getName()],
+                'stepsUpdates' => [
+                    [
+                        'code' => $this->stepUuid,
+                        'measurements' => [
+                            'increment' => [
+                                'code' => $this->generateRandomUuid(),
+                                'increment' => $step
+                            ]
+                        ]
+                    ]
+                ]
             ]),
             [
                 'content-type' => 'application/json',
@@ -60,11 +70,21 @@ public function accept(int $step = 1): void
 
     public function reject(int $step = 1): void
     {
-        $this->metrics['reject'] += $step;
-
         $this->channel->publish(
             \json_encode([
-                'Line rejected : ' => $this->metrics['reject']
+                'id' => $this->generateRandomUuid(),
+                'date' => ['date' => $this->date->format('c'), 'tz' => $this->date->getTimezone()->getName()],
+                'stepsUpdates' => [
+                    [
+                        'code' => $this->stepUuid,
+                        'measurements' => [
+                            'decrement' => [
+                                'code' => $this->generateRandomUuid(),
+                                'decrement' => $step
+                            ]
+                        ]
+                    ]
+                ]
             ]),
             [
                 'content-type' => 'application/json',
@@ -74,6 +94,16 @@ public function reject(int $step = 1): void
         );
     }
 
+    private function generateRandomUuid(): string
+    {
+        $data = $data ?? random_bytes(16);
+        assert(strlen($data) == 16);
+        $data[6] = chr(ord($data[6]) & 0x0f | 0x40);
+        $data[8] = chr(ord($data[8]) & 0x3f | 0x80);
+
+        return vsprintf('%s%s-%s-%s-%s-%s%s%s', str_split(bin2hex($data), 4));
+    }
+
     public function __destruct()
     {
         $this->channel->close();

tests/integration/IntegrationTestCase.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace integration\Kiboko\Component\Flow\RabbitMQ;
+
+use PHPUnit\Framework\TestCase;
+
+class IntegrationTestCase extends TestCase
+{
+    public function testIfJsonIsCorrect()
+    {
+        $array = [
+            'id' => '7bbbf1bd-9f17-4334-855d-ef77747fbc72',
+            'date' => new \DateTime('now'),
+            'stepsUpdates' => [
+                [
+                    'code' => '90ca518b-5d89-4088-a453-ab0c4779aa2d',
+                    'measurements' => [
+                        'increment' => [
+                            'code' => '752602f1-a184-454f-bc48-c745ca7d9241',
+                            'increment' => 1
+                        ]
+                    ]
+                ]
+            ]
+        ];
+
+        $this->assertArrayHasKey('id', $array);
+    }
+}