HttpStatisticsLogger::storeStatisticsUrl() - Code Metrics - Inspection of "Merge pull request #115 from francislavoie/stats-u..." - beyondcode/laravel-websockets - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 4c12fb...9d8e2f )

by Alexandru

created 2020-08-13 07:04 UTC

HttpStatisticsLogger::storeStatisticsUrl() A

↳ Parent: HttpStatisticsLogger

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	10
rs	9.9332
c	0
b	0
f	0
cc	2
nc	2
nop	0

<?php

namespace BeyondCode\LaravelWebSockets\Statistics\Logger;

use BeyondCode\LaravelWebSockets\Apps\App;
use BeyondCode\LaravelWebSockets\Statistics\Http\Controllers\WebSocketStatisticsEntriesController;
use BeyondCode\LaravelWebSockets\Statistics\Statistic;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager;
use Clue\React\Buzz\Browser;
use function GuzzleHttp\Psr7\stream_for;
use Ratchet\ConnectionInterface;

class HttpStatisticsLogger implements StatisticsLogger
{
    /** @var \BeyondCode\LaravelWebSockets\Statistics\Statistic[] */
    protected $statistics = [];

    /** @var \BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager */
    protected $channelManager;

    /** @var \Clue\React\Buzz\Browser */
    protected $browser;

    public function __construct(ChannelManager $channelManager, Browser $browser)
    {
        $this->channelManager = $channelManager;

        $this->browser = $browser;
    }

    public function webSocketMessage(ConnectionInterface $connection)
    {
        $this
            ->findOrMakeStatisticForAppId($connection->app->id)
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            ->webSocketMessage();
    }

    public function apiMessage($appId)
    {
        $this
            ->findOrMakeStatisticForAppId($appId)
            ->apiMessage();
    }

    public function connection(ConnectionInterface $connection)
    {
        $this
            ->findOrMakeStatisticForAppId($connection->app->id)
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            ->connection();
    }

    public function disconnection(ConnectionInterface $connection)
    {
        $this
            ->findOrMakeStatisticForAppId($connection->app->id)
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            ->disconnection();
    }

    protected function findOrMakeStatisticForAppId($appId): Statistic
    {
        if (! isset($this->statistics[$appId])) {
            $this->statistics[$appId] = new Statistic($appId);
        }

        return $this->statistics[$appId];
    }

    public function save()
    {
        foreach ($this->statistics as $appId => $statistic) {
            if (! $statistic->isEnabled()) {
                continue;
            }

            $postData = array_merge($statistic->toArray(), [
                'secret' => App::findById($appId)->secret,
            ]);

            $this
                ->browser
                ->post(
                    $this->storeStatisticsUrl(),
                    ['Content-Type' => 'application/json'],
                    stream_for(json_encode($postData))
                );

            $currentConnectionCount = $this->channelManager->getConnectionCount($appId);
            $statistic->reset($currentConnectionCount);
        }
    }

    protected function storeStatisticsUrl(): string
    {
        $action = [WebSocketStatisticsEntriesController::class, 'store'];

        $overridenUrl = config('websockets.statistics.base_url_override');

        return $overridentUrl

            ? $overridenUrl.action($action, [], false)
            : action($action);
    }
}


1			<?php
2
3			namespace BeyondCode\LaravelWebSockets\Statistics\Logger;
4
5			use BeyondCode\LaravelWebSockets\Apps\App;
6			use BeyondCode\LaravelWebSockets\Statistics\Http\Controllers\WebSocketStatisticsEntriesController;
7			use BeyondCode\LaravelWebSockets\Statistics\Statistic;
8			use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager;
9			use Clue\React\Buzz\Browser;
10			use function GuzzleHttp\Psr7\stream_for;
11			use Ratchet\ConnectionInterface;
12
13			class HttpStatisticsLogger implements StatisticsLogger
14			{
15			/** @var \BeyondCode\LaravelWebSockets\Statistics\Statistic[] */
16			protected $statistics = [];
17
18			/** @var \BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager */
19			protected $channelManager;
20
21			/** @var \Clue\React\Buzz\Browser */
22			protected $browser;
23
24			public function __construct(ChannelManager $channelManager, Browser $browser)
25			{
26			$this->channelManager = $channelManager;
27
28			$this->browser = $browser;
29			}
30
31			public function webSocketMessage(ConnectionInterface $connection)
32			{
33			$this
34			->findOrMakeStatisticForAppId($connection->app->id)
			0 ignored issues – show Bug introduced 2018-12-04 21:28 UTC by Report Bug Copy Issue Report Accessing `app` on the interface `Ratchet\ConnectionInterface` suggest that you code against a concrete implementation. How about adding an `instanceof` check? If you access a property on an interface, you most likely code against a concrete implementation of the interface. Available Fixes Adding an additional type check: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeInterface $object) { if ($object instanceof SomeClass) { $a = $object->a; } } Changing the type hint: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeClass $object) { $a = $object->a; } Loading history...
35			->webSocketMessage();
36			}
37
38			public function apiMessage($appId)
39			{
40			$this
41			->findOrMakeStatisticForAppId($appId)
42			->apiMessage();
43			}
44
45			public function connection(ConnectionInterface $connection)
46			{
47			$this
48			->findOrMakeStatisticForAppId($connection->app->id)
			0 ignored issues – show Bug introduced 2018-12-04 21:28 UTC by Report Bug Copy Issue Report Accessing `app` on the interface `Ratchet\ConnectionInterface` suggest that you code against a concrete implementation. How about adding an `instanceof` check? If you access a property on an interface, you most likely code against a concrete implementation of the interface. Available Fixes Adding an additional type check: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeInterface $object) { if ($object instanceof SomeClass) { $a = $object->a; } } Changing the type hint: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeClass $object) { $a = $object->a; } Loading history...
49			->connection();
50			}
51
52			public function disconnection(ConnectionInterface $connection)
53			{
54			$this
55			->findOrMakeStatisticForAppId($connection->app->id)
			0 ignored issues – show Bug introduced 2018-12-04 21:28 UTC by Report Bug Copy Issue Report Accessing `app` on the interface `Ratchet\ConnectionInterface` suggest that you code against a concrete implementation. How about adding an `instanceof` check? If you access a property on an interface, you most likely code against a concrete implementation of the interface. Available Fixes Adding an additional type check: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeInterface $object) { if ($object instanceof SomeClass) { $a = $object->a; } } Changing the type hint: interface SomeInterface { } class SomeClass implements SomeInterface { public $a; } function someFunction(SomeClass $object) { $a = $object->a; } Loading history...
56			->disconnection();
57			}
58
59			protected function findOrMakeStatisticForAppId($appId): Statistic
60			{
61			if (! isset($this->statistics[$appId])) {
62			$this->statistics[$appId] = new Statistic($appId);
63			}
64
65			return $this->statistics[$appId];
66			}
67
68			public function save()
69			{
70			foreach ($this->statistics as $appId => $statistic) {
71			if (! $statistic->isEnabled()) {
72			continue;
73			}
74
75			$postData = array_merge($statistic->toArray(), [
76			'secret' => App::findById($appId)->secret,
77			]);
78
79			$this
80			->browser
81			->post(
82			$this->storeStatisticsUrl(),
83			['Content-Type' => 'application/json'],
84			stream_for(json_encode($postData))
85			);
86
87			$currentConnectionCount = $this->channelManager->getConnectionCount($appId);
88			$statistic->reset($currentConnectionCount);
89			}
90			}
91
92			protected function storeStatisticsUrl(): string
93			{
94			$action = [WebSocketStatisticsEntriesController::class, 'store'];
95
96			$overridenUrl = config('websockets.statistics.base_url_override');
97
98			return $overridentUrl
			0 ignored issues – show Bug introduced 2020-08-13 06:49 UTC by Report Bug Copy Issue Report The variable `$overridentUrl` does not exist. Did you mean `$overridenUrl`? This check looks for variables that are accessed but have not been defined. It raises an issue if it finds another variable that has a similar name. The variable may have been renamed without also renaming all references. Loading history...
99			? $overridenUrl.action($action, [], false)
100			: action($action);
101			}
102			}
103

beyondcode / laravel-websockets

Push — master ( 4c12fb...9d8e2f )

HttpStatisticsLogger::storeStatisticsUrl() A

Complexity

Size

Duplication

Importance

Available Fixes

Available Fixes

Available Fixes

Duplication Side-by-Side

Filter issues like