Subscribe to new event

Author: mbabker

config/services.yaml

@@ -95,6 +95,7 @@ services:
             - { name: kernel.event_listener, event: 'gos_web_socket.client_disconnected', method: onClientDisconnect }
             - { name: kernel.event_listener, event: 'gos_web_socket.client_error', method: onClientError }
             - { name: kernel.event_listener, event: 'gos_web_socket.client_rejected', method: onClientRejected }
+            - { name: kernel.event_listener, event: 'gos_web_socket.connection_rejected', method: onConnectionRejected }
             - { name: monolog.logger, channel: websocket }
 
     gos_web_socket.event_listener.close_pusher_connections:

src/EventListener/ClientEventListener.php

@@ -10,6 +10,7 @@
 use Gos\Bundle\WebSocketBundle\Event\ClientDisconnectedEvent;
 use Gos\Bundle\WebSocketBundle\Event\ClientErrorEvent;
 use Gos\Bundle\WebSocketBundle\Event\ClientRejectedEvent;
+use Gos\Bundle\WebSocketBundle\Event\ConnectionRejectedEvent;
 use Psr\Log\LoggerAwareInterface;
 use Psr\Log\LoggerAwareTrait;
 
@@ -117,6 +118,9 @@ public function onClientError(ClientErrorEvent $event): void
         );
     }
 
+    /**
+     * @deprecated to be removed in 4.0
+     */
     public function onClientRejected(ClientRejectedEvent $event): void
     {
         if (null !== $this->logger) {
@@ -128,4 +132,11 @@ public function onClientRejected(ClientRejectedEvent $event): void
             );
         }
     }
+
+    public function onConnectionRejected(ConnectionRejectedEvent $event): void
+    {
+        if (null !== $this->logger) {
+            $this->logger->warning('Connection rejected');
+        }
+    }
 }

tests/EventListener/ClientEventListenerTest.php

@@ -10,6 +10,7 @@
 use Gos\Bundle\WebSocketBundle\Event\ClientDisconnectedEvent;
 use Gos\Bundle\WebSocketBundle\Event\ClientErrorEvent;
 use Gos\Bundle\WebSocketBundle\Event\ClientRejectedEvent;
+use Gos\Bundle\WebSocketBundle\Event\ConnectionRejectedEvent;
 use Gos\Bundle\WebSocketBundle\EventListener\ClientEventListener;
 use PHPUnit\Framework\MockObject\MockObject;
 use PHPUnit\Framework\TestCase;
@@ -220,7 +221,7 @@ public function testThereIsNoActionWhenNoLoggerIsSetOnTheClientRejectedEvent():
     {
         $event = new ClientRejectedEvent('localhost', null);
 
-        (new ClientEventListener($this->clientStorage, $this->authenticationProvider))->onClientRejected($event);
+        $this->listener->onClientRejected($event);
     }
 
     public function testTheClientRejectionIsLogged(): void
@@ -231,4 +232,23 @@ public function testTheClientRejectionIsLogged(): void
 
         self::assertTrue($this->logger->hasWarningThatContains('Client rejected, bad origin'));
     }
+
+    /**
+     * @doesNotPerformAssertions
+     */
+    public function testThereIsNoActionWhenNoLoggerIsSetOnTheConnectionRejectedEvent(): void
+    {
+        $event = new ConnectionRejectedEvent($this->createMock(ConnectionInterface::class), null);
+
+        $this->listener->onConnectionRejected($event);
+    }
+
+    public function testTheConnectionRejectionIsLogged(): void
+    {
+        $event = new ConnectionRejectedEvent($this->createMock(ConnectionInterface::class), null);
+
+        $this->listener->onConnectionRejected($event);
+
+        self::assertTrue($this->logger->hasWarningThatContains('Connection rejected'));
+    }
 }