Stats interceptor async -> sync (#31)

Author: yatsenkolesh

src/Events/EventHandlersMap.php

@@ -17,18 +17,14 @@ class EventHandlersMap
 
     private StatisticsSenderHandler $statisticsSenderHandler;
 
-    private RelatedUsersStatisticsInterceptor $relatedUsersStatisticsInterceptor;
-
     private array $map;
 
     public function __construct(
         AddUserToBranchHandler $addUserToBranchHandler,
-        StatisticsSenderHandler $statisticsSenderHandler,
-        RelatedUsersStatisticsInterceptor $relatedUsersStatisticsInterceptor
+        StatisticsSenderHandler $statisticsSenderHandler
     ) {
         $this->addUserToBranchHandler = $addUserToBranchHandler;
         $this->statisticsSenderHandler = $statisticsSenderHandler;
-        $this->relatedUsersStatisticsInterceptor = $relatedUsersStatisticsInterceptor;
         $this->map = $this->getInitialMap();
     }
 
@@ -74,7 +70,6 @@ private function getInitialMap(): array
             ],
             SendEventTask::class => [
                 $this->statisticsSenderHandler,
-                $this->relatedUsersStatisticsInterceptor,
             ],
         ];
     }

src/Manager/StatisticsManager.php

@@ -6,6 +6,7 @@
 
 use Abrouter\Client\Events\EventDispatcher;
 use Abrouter\Client\DTO\EventDTOInterface;
+use Abrouter\Client\Events\Handlers\RelatedUsersStatisticsInterceptor;
 use Abrouter\Client\Services\ExperimentsParallelRun\ParallelRunSwitch;
 use Abrouter\Client\Services\Statistics\SendEventTask;
 
@@ -15,21 +16,34 @@ class StatisticsManager
 
     private ParallelRunSwitch $parallelRunSwitch;
 
+    private RelatedUsersStatisticsInterceptor $relatedUsersStatisticsInterceptor;
+
     /**
      * @param EventDispatcher $eventDispatcher
      * @param ParallelRunSwitch $parallelRunSwitch
+     * @param RelatedUsersStatisticsInterceptor $relatedUsersStatisticsInterceptor
      */
-    public function __construct(EventDispatcher $eventDispatcher, ParallelRunSwitch $parallelRunSwitch)
-    {
+    public function __construct(
+        EventDispatcher $eventDispatcher,
+        ParallelRunSwitch $parallelRunSwitch,
+        RelatedUsersStatisticsInterceptor $relatedUsersStatisticsInterceptor
+    ) {
         $this->eventDispatcher = $eventDispatcher;
         $this->parallelRunSwitch = $parallelRunSwitch;
+        $this->relatedUsersStatisticsInterceptor = $relatedUsersStatisticsInterceptor;
     }
 
     public function sendEvent(EventDTOInterface $eventDTO): void
     {
+        $task = new SendEventTask($eventDTO);
+        $isParallelRunningEnabled = $this->parallelRunSwitch->isEnabled();
+        if ($isParallelRunningEnabled) {
+            $this->relatedUsersStatisticsInterceptor->handle($task);
+        }
+
         $this->eventDispatcher->dispatch(
-            new SendEventTask($eventDTO),
-            $this->parallelRunSwitch->isEnabled()
+            $task,
+            $isParallelRunningEnabled
         );
     }
 }