feat: drop symfony 3.2

BedrockStreaming · Jul 24, 2023 · 8796cfa · 8796cfa
1 parent a9e4a6e
commit 8796cfa
Show file tree

Hide file tree

Showing 23 changed files with 139 additions and 407 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -8,7 +8,7 @@ jobs:
     strategy:
       matrix:
         php-version: ['7.4', '8.0', '8.1' ]
-        symfony-version: ['^3.4', '^4.4', '^5.0']
+        symfony-version: ['^4.4', '^5.0']
       fail-fast: false
     steps:
       - uses: actions/checkout@master

diff --git a/composer.json b/composer.json
@@ -7,11 +7,11 @@
     "require" : {
         "php": ">=7.4",
         "ext-amqp": "*",
-        "symfony/dependency-injection": "^3.4 || ^4.3 || ^5.0",
-        "symfony/framework-bundle": "^3.4 || ^4.3 || ^5.0",
-        "symfony/http-kernel": "^3.4 || ^4.3 || ^5.0",
-        "symfony/yaml": "^3.4 || ^4.3 || ^5.0",
-        "twig/twig": "^1.31 || ^2.0 || ^3.0"
+        "symfony/dependency-injection": "^4.4 || ^5.0",
+        "symfony/framework-bundle": "^4.4 || ^5.0",
+        "symfony/http-kernel": "^4.4 || ^5.0",
+        "symfony/yaml": "^4.4 || ^5.0",
+        "twig/twig": "^2.13 || ^3.0"
     },
     "require-dev" : {
         "atoum/atoum": "~4.0",

diff --git a/src/AmqpBundle/Amqp/AbstractAmqp.php b/src/AmqpBundle/Amqp/AbstractAmqp.php
@@ -16,20 +16,18 @@ abstract class AbstractAmqp
 
     /**
      * Class of the event notifier.
-     *
-     * @var string
      */
-    protected $eventClass = null;
+    protected ?string $eventClass = null;
 
     /**
      * Notify an event to the event dispatcher.
      *
      * @param string $command   The command name
      * @param array  $arguments Args of the command
      * @param mixed  $return    Return value of the command
-     * @param int    $time      Exec time
+     * @param int $time      Exec time
      */
-    protected function notifyEvent($command, $arguments, $return, $time = 0)
+    protected function notifyEvent(string $command, array $arguments, $return, int $time = 0)
     {
         if ($this->eventDispatcher) {
             $event = new $this->eventClass();
@@ -51,7 +49,7 @@ protected function notifyEvent($command, $arguments, $return, $time = 0)
      *
      * @return mixed
      */
-    protected function call($object, $name, array $arguments = [])
+    protected function call($object, string $name, array $arguments = [])
     {
         $start = microtime(true);
 
@@ -70,7 +68,7 @@ protected function call($object, $name, array $arguments = [])
      *
      * @throws \Exception
      */
-    public function setEventDispatcher($eventDispatcher, $eventClass)
+    public function setEventDispatcher($eventDispatcher, string $eventClass)
     {
         if (!is_object($eventDispatcher) || !method_exists($eventDispatcher, 'dispatch')) {
             throw new Exception('The EventDispatcher must be an object and implement a dispatch method');

diff --git a/src/AmqpBundle/Amqp/Consumer.php b/src/AmqpBundle/Amqp/Consumer.php
@@ -12,20 +12,11 @@
  */
 class Consumer extends AbstractAmqp
 {
-    /**
-     * @var \AMQPQueue
-     */
-    protected $queue = null;
 
-    /**
-     * @var array
-     */
-    protected $queueOptions = [];
+    protected \AMQPQueue $queue;
+
+    protected array $queueOptions = [];
 
-    /**
-     * @param \AMQPQueue $queue        Amqp Queue
-     * @param array      $queueOptions Queue options
-     */
     public function __construct(\AMQPQueue $queue, array $queueOptions)
     {
         $this->queue = $queue;
@@ -37,12 +28,10 @@ public function __construct(\AMQPQueue $queue, array $queueOptions)
      *
      * @param int $flags MQP_AUTOACK or AMQP_NOPARAM
      *
-     * @throws \AMQPChannelException    if the channel is not open
      * @throws \AMQPConnectionException if the connection to the broker was lost
-     *
-     * @return \AMQPEnvelope|bool
+     * @throws \AMQPChannelException    if the channel is not open
      */
-    public function getMessage($flags = AMQP_AUTOACK)
+    public function getMessage(int $flags = AMQP_AUTOACK): ?\AMQPEnvelope
     {
         $envelope = $this->call($this->queue, 'get', [$flags]);
 
@@ -53,7 +42,7 @@ public function getMessage($flags = AMQP_AUTOACK)
             return $preRetrieveEvent->getEnvelope();
         }
 
-        return $envelope;
+        return $envelope === false ? null : $envelope;
     }
 
     /**
@@ -62,12 +51,10 @@ public function getMessage($flags = AMQP_AUTOACK)
      * @param string $deliveryTag delivery tag of last message to ack
      * @param int    $flags       AMQP_MULTIPLE or AMQP_NOPARAM
      *
-     * @return bool
-     *
      * @throws \AMQPChannelException    if the channel is not open
      * @throws \AMQPConnectionException if the connection to the broker was lost
      */
-    public function ackMessage($deliveryTag, $flags = AMQP_NOPARAM)
+    public function ackMessage(string $deliveryTag, int $flags = AMQP_NOPARAM): bool
     {
         if ($this->eventDispatcher) {
             $ackEvent = new AckEvent($deliveryTag, $flags);
@@ -84,12 +71,10 @@ public function ackMessage($deliveryTag, $flags = AMQP_NOPARAM)
      * @param string $deliveryTag delivery tag of last message to nack
      * @param int    $flags       AMQP_NOPARAM or AMQP_REQUEUE to requeue the message(s)
      *
-     * @throws \AMQPChannelException    if the channel is not open
      * @throws \AMQPConnectionException if the connection to the broker was lost
-     *
-     * @return bool
+     * @throws \AMQPChannelException    if the channel is not open
      */
-    public function nackMessage($deliveryTag, $flags = AMQP_NOPARAM)
+    public function nackMessage(string $deliveryTag, int $flags = AMQP_NOPARAM): bool
     {
         if ($this->eventDispatcher) {
             $nackEvent = new NackEvent($deliveryTag, $flags);
@@ -105,10 +90,8 @@ public function nackMessage($deliveryTag, $flags = AMQP_NOPARAM)
      *
      * @throws \AMQPChannelException    if the channel is not open
      * @throws \AMQPConnectionException if the connection to the broker was lost
-     *
-     * @return bool
      */
-    public function purge()
+    public function purge(): bool
     {
         if ($this->eventDispatcher) {
             $purgeEvent = new PurgeEvent($this->queue);
@@ -121,10 +104,8 @@ public function purge()
 
     /**
      * Get the current message count.
-     *
-     * @return int
      */
-    public function getCurrentMessageCount()
+    public function getCurrentMessageCount(): int
     {
         // Save the current queue flags and setup the queue in passive mode
         $flags = $this->queue->getFlags();
@@ -139,20 +120,12 @@ public function getCurrentMessageCount()
         return $messagesCount;
     }
 
-    /**
-     * @return \AMQPQueue
-     */
-    public function getQueue()
+    public function getQueue(): \AMQPQueue
     {
         return $this->queue;
     }
 
-    /**
-     * @param \AMQPQueue $queue
-     *
-     * @return \M6Web\Bundle\AmqpBundle\Amqp\Consumer
-     */
-    public function setQueue(\AMQPQueue $queue)
+    public function setQueue(\AMQPQueue $queue): Consumer
     {
         $this->queue = $queue;
 

diff --git a/src/AmqpBundle/Amqp/DataCollector.php b/src/AmqpBundle/Amqp/DataCollector.php
@@ -2,6 +2,7 @@
 
 namespace M6Web\Bundle\AmqpBundle\Amqp;
 
+use M6Web\Bundle\AmqpBundle\Event\DispatcherInterface;
 use Symfony\Component\HttpKernel\DataCollector\DataCollector as SymfonyDataCollector;
 use Symfony\Component\HttpFoundation\Response;
 use Symfony\Component\HttpFoundation\Request;
@@ -11,11 +12,6 @@
  */
 class DataCollector extends SymfonyDataCollector
 {
-    /**
-     * @param string $name
-     *
-     * Construct the data collector
-     */
     public function __construct(string $name)
     {
         $this->data['name'] = $name;
@@ -25,20 +21,20 @@ public function __construct(string $name)
     /**
      * Collect the data.
      *
-     * @param Request    $request   The request object
-     * @param Response   $response  The response object
-     * @param \Exception $exception An exception
+     * @param Request $request The request object
+     * @param Response $response The response object
+     * @param \Throwable|null $exception An exception
      */
-    public function collect(Request $request, Response $response, \Exception $exception = null)
+    public function collect(Request $request, Response $response, ?\Throwable $exception = null)
     {
     }
 
     /**
      * Listen for command event.
      *
-     * @param object $event The event object
+     * @param DispatcherInterface $event The event object
      */
-    public function onCommand($event)
+    public function onCommand(DispatcherInterface $event)
     {
         $this->data['commands'][] = array(
             'command' => $event->getCommand(),
@@ -59,8 +55,6 @@ public function getCommands(): array
 
     /**
      * Return the name of the collector.
-     *
-     * @return string data collector name
      */
     public function getName(): string
     {
@@ -69,8 +63,6 @@ public function getName(): string
 
     /**
      * Return total command execution time.
-     *
-     * @return float
      */
     public function getTotalExecutionTime(): float
     {

diff --git a/src/AmqpBundle/Amqp/Locator.php b/src/AmqpBundle/Amqp/Locator.php
@@ -5,10 +5,10 @@
 class Locator
 {
     /**  @var Consumer[] */
-    protected $consumers = [];
+    protected array $consumers = [];
 
     /** @var Producer[] */
-    protected $producers = [];
+    protected array $producers = [];
 
     public function getConsumer(string $id): Consumer
     {

diff --git a/src/AmqpBundle/Amqp/Producer.php b/src/AmqpBundle/Amqp/Producer.php
@@ -9,15 +9,9 @@
  */
 class Producer extends AbstractAmqp
 {
-    /**
-     * @var \AMQPExchange
-     */
-    protected $exchange = null;
+    protected \AMQPExchange $exchange;
 
-    /**
-     * @var array
-     */
-    protected $exchangeOptions = [];
+    protected array $exchangeOptions = [];
 
     /**
      * Constructor.
@@ -45,7 +39,7 @@ public function __construct(\AMQPExchange $exchange, array $exchangeOptions)
      * @throws \AMQPChannelException    if the channel is not open
      * @throws \AMQPConnectionException if the connection to the broker was lost
      */
-    public function publishMessage($message, $flags = AMQP_NOPARAM, array $attributes = [], array $routingKeys = [])
+    public function publishMessage(string $message, int $flags = AMQP_NOPARAM, array $attributes = [], array $routingKeys = []): bool
     {
         // Merge attributes
         $attributes = empty($attributes) ? $this->exchangeOptions['publish_attributes'] :
@@ -81,40 +75,24 @@ public function publishMessage($message, $flags = AMQP_NOPARAM, array $attribute
         return (bool) $success;
     }
 
-    /**
-     * @return \AMQPExchange
-     */
-    public function getExchange()
+    public function getExchange(): \AMQPExchange
     {
         return $this->exchange;
     }
 
-    /**
-     * @param \AMQPExchange $exchange
-     *
-     * @return \M6Web\Bundle\AmqpBundle\Amqp\Consumer
-     */
-    public function setExchange(\AMQPExchange $exchange)
+    public function setExchange(\AMQPExchange $exchange): self
     {
         $this->exchange = $exchange;
 
         return $this;
     }
 
-    /**
-     * @return array
-     */
-    public function getExchangeOptions()
+    public function getExchangeOptions(): array
     {
         return $this->exchangeOptions;
     }
 
-    /**
-     * @param array $exchangeOptions
-     *
-     * @return \M6Web\Bundle\AmqpBundle\Amqp\Consumer
-     */
-    public function setExchangeOptions(array $exchangeOptions)
+    public function setExchangeOptions(array $exchangeOptions): self
     {
         $this->exchangeOptions = $exchangeOptions;
 

diff --git a/src/AmqpBundle/DependencyInjection/Configuration.php b/src/AmqpBundle/DependencyInjection/Configuration.php
@@ -18,16 +18,10 @@ class Configuration implements ConfigurationInterface
     /**
      * {@inheritdoc}
      */
-    public function getConfigTreeBuilder()
+    public function getConfigTreeBuilder(): TreeBuilder
     {
         $treeBuilder = new TreeBuilder('m6_web_amqp');
-
-        if (method_exists($treeBuilder, 'getRootNode')) {
-            $rootNode = $treeBuilder->getRootNode();
-        } else {
-            // symfony < 4.2 support
-            $rootNode = $treeBuilder->root('m6_web_amqp');
-        }
+        $rootNode = $treeBuilder->getRootNode();
 
         $rootNode
             ->children()