patrickjaja / forecast.it.fill

kafka_consume.php

Spacing +2 added lines, -2 removed lines

@@ -6,7 +6,7 @@ 
 // sudo pecl install rdkafka (select php)
 
 $conf = new RdKafka\Conf();
-$conf->set('log_level', (string) LOG_DEBUG);
+$conf->set('log_level', (string)LOG_DEBUG);
 //$conf->set('debug', 'all');
 // Set the group id. This is required when storing offsets on the broker
 $conf->set('group.id', 'myConsumerGroup');
@@ -28,7 +28,7 @@ 
 $topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);
 
 while (true) {
-    $message = $topic->consume(0, 120*10000);
+    $message = $topic->consume(0, 120 * 10000);
     switch ($message->err) {
         case RD_KAFKA_RESP_ERR_NO_ERROR:
             var_dump($message);

src/ForecastAutomation/Serializer/SerializerFacade.php

Spacing +2 added lines, -2 removed lines

@@ -22,9 +22,9 @@
     //ToDo: Support original feature scope ie. normalize attributes path
     // see here https://symfony.com/doc/current/components/serializer.html
     // https://jmsyst.com/libs/serializer
-    public function serialize(object|array $dto, string $format = SerializerConstants::FORMAT_JSON): string
+    public function serialize(object | array $dto, string $format = SerializerConstants::FORMAT_JSON): string
     {
-        return \json_encode((array) $dto, JSON_THROW_ON_ERROR);
+        return \json_encode((array)$dto, JSON_THROW_ON_ERROR);
 //        return $this->getFactory()->createSerializer()->serialize($dto, $format);
     }
 

src/ForecastAutomation/QueueClient/Shared/Plugin/QueuePluginCollection.php

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
 
     public function offsetGet($offset): QueuePluginInterface
     {
-        if (! $this->offsetExists($offset)) {
+        if (!$this->offsetExists($offset)) {
             throw new \Exception(
                 \sprintf(
                     'Unknown Queue %s, please register first to your configured queue dependencyprovider adapter.',

src/ForecastAutomation/AmqpClient/AmqpClientFactory.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         return (new AmqpConnectionFactory(
             [
                 'host' => $_ENV['AMQP_HOST'],
-                'port' => (int) $_ENV['AMQP_PORT'],
+                'port' => (int)$_ENV['AMQP_PORT'],
                 'vhost' => $_ENV['AMQP_VHOST'],
                 'user' => $_ENV['AMQP_USER'],
                 'pass' => $_ENV['AMQP_PASS'],

src/ForecastAutomation/ForecastClient/Shared/Plugin/ForecastClientQueuePluginPlugin.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
             $messageDto->data['needle'],
             $messageDto->data['description'],
             new \DateTime($messageDto->data['created']),
-            (int) $messageDto->data['duration']
+            (int)$messageDto->data['duration']
         );
     }
 }

src/ForecastAutomation/PeriodicalActivityDataImport/Business/PeriodicalActivityDataImportProcess.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
         foreach ($activityDtoCollection as $activityDto) {
             $messages[] =
                 new MessageDto(
-                    ['created' => $activityDto->created->format('c')] + (array) $activityDto,
+                    ['created' => $activityDto->created->format('c')] + (array)$activityDto,
                     ForecastClientQueueConstants::QUEUE_NAME,
                     ForecastClientQueueConstants::IMPORT_EVENT
                 );

src/ForecastAutomation/ForecastDataImport/Business/ForecastDataImportProcess.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
         foreach ($activityDtoCollection as $activityDto) {
             $messages[] =
                 new MessageDto(
-                    ['created' => $activityDto->created->format('c')] + (array) $activityDto,
+                    ['created' => $activityDto->created->format('c')] + (array)$activityDto,
                     ForecastClientQueueConstants::QUEUE_NAME,
                     ForecastClientQueueConstants::IMPORT_EVENT
                 );