wip

Author: freekmurze

src/Statistics/Logger/HttpStatisticsLogger.php

@@ -57,7 +57,7 @@ public function disconnection(ConnectionInterface $connection)
 
     protected function findOrMakeStatisticForAppId($appId): Statistic
     {
-        if (! isset($this->statistics[$appId])) {
+        if (!isset($this->statistics[$appId])) {
             $this->statistics[$appId] = new Statistic($appId);
         }
 
@@ -68,23 +68,19 @@ public function save()
     {
         foreach ($this->statistics as $appId => $statistic) {
 
-            if (! $statistic->isEnabled()) {
+            if (!$statistic->isEnabled()) {
                 continue;
             }
 
-            $this->browser
+            $this
+                ->browser
                 ->post(
                     action([WebSocketStatisticsEntriesController::class, 'store']),
                     ['Content-Type' => 'application/json'],
                     stream_for(json_encode($statistic->toArray()))
                 );
 
-            // Reset connection and message count
-            $currentConnectionCount = collect($this->channelManager->getChannels($appId))
-                ->sum(function ($channel) {
-                    return count($channel->getSubscribedConnections());
-                });
-
+            $currentConnectionCount = $this->channelManager->getConnectionCount($appId);
             $statistic->reset($currentConnectionCount);
         }
     }

src/WebSockets/Channels/ChannelManager.php

@@ -46,6 +46,12 @@ public function getChannels(string $appId): array
         return $this->channels[$appId] ?? [];
     }
 
+    public function getConnectionCount(string $appId): int
+    {
+        return collect($this->getChannels($appId))
+            ->sum->getSubscribedConnections();
+    }
+
     public function removeFromAllChannels(ConnectionInterface $connection)
     {
         if (!isset($connection->app)) {