Pass WampRequest to TopicInterface::registerPeriodicTimer

docs/topics.md

@@ -205,7 +205,7 @@ To implement an example fulfilling a scenario of "every 5 minutes all subscriber
 
 You will need to add these two methods to your Topic:
 
-- `public function registerPeriodicTimer(Topic $topic): void`
+- `public function registerPeriodicTimer(Topic $topic, WampRequest $request): void`
 - `public function setPeriodicTimer(TopicPeriodicTimer $periodicTimer): void`
 
 The `Gos\Bundle\WebSocketBundle\Topic\TopicPeriodicTimerTrait` is available to help implement the interface.
@@ -215,6 +215,7 @@ The `Gos\Bundle\WebSocketBundle\Topic\TopicPeriodicTimerTrait` is available to h
 
 namespace App\Websocket\Topic;
 
+use Gos\Bundle\WebSocketBundle\Router\WampRequest;
 use Gos\Bundle\WebSocketBundle\Topic\TopicPeriodicTimerInterface;
 use Gos\Bundle\WebSocketBundle\Topic\TopicPeriodicTimerTrait;
 use Ratchet\Wamp\Topic;
@@ -223,7 +224,7 @@ class AcmePeriodicTopic extends AcmeTopic implements TopicPeriodicTimerInterface
 {
     use TopicPeriodicTimerTrait;
 
-    public function registerPeriodicTimer(Topic $topic): void
+    public function registerPeriodicTimer(Topic $topic, WampRequest $request): void
     {
         // Adds the periodic timer the first time a client connects to the topic
         $this->periodicTimer->addPeriodicTimer(

src/Server/App/Dispatcher/TopicDispatcher.php

@@ -204,7 +204,7 @@ public function dispatch(
 
             if (!$this->topicPeriodicTimer->isRegistered($appTopic) && 0 !== \count($topic)) {
                 try {
-                    $appTopic->registerPeriodicTimer($topic);
+                    $appTopic->registerPeriodicTimer($topic, $request);
                 } catch (\Throwable $e) {
                     if (null !== $this->logger) {
                         $this->logger->error(

src/Topic/TopicPeriodicTimerInterface.php

@@ -2,11 +2,12 @@
 
 namespace Gos\Bundle\WebSocketBundle\Topic;
 
+use Gos\Bundle\WebSocketBundle\Router\WampRequest;
 use Ratchet\Wamp\Topic;
 
 interface TopicPeriodicTimerInterface
 {
-    public function registerPeriodicTimer(Topic $topic): void;
+    public function registerPeriodicTimer(Topic $topic, WampRequest $request): void;
 
     public function setPeriodicTimer(TopicPeriodicTimer $periodicTimer): void;
 }

tests/Server/App/Dispatcher/TopicDispatcherTest.php

@@ -432,7 +432,7 @@ public function getName(): string
                 return 'topic.handler';
             }
 
-            public function registerPeriodicTimer(Topic $topic): void
+            public function registerPeriodicTimer(Topic $topic, WampRequest $request): void
             {
                 $this->registered = true;
             }