ArrayChannelManager::findOrCreate() - Code Metrics - Inspection of "Update ChannelManager (#41)" - beyondcode/laravel-websockets - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( db6d79...ec96ca )

by Marcel

created 2018-12-10 19:47 UTC

ArrayChannelManager::findOrCreate() A

↳ Parent: ArrayChannelManager

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

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

<?php

namespace BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManagers;

use Ratchet\ConnectionInterface;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\Channel;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\PrivateChannel;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\PresenceChannel;

class ArrayChannelManager implements ChannelManager
{
    /** @var string */
    protected $appId;

    /** @var array */
    protected $channels = [];

    public function findOrCreate(string $appId, string $channelName): Channel
    {
        if (! isset($this->channels[$appId][$channelName])) {
            $channelClass = $this->determineChannelClass($channelName);

            $this->channels[$appId][$channelName] = new $channelClass($channelName);
        }

        return $this->channels[$appId][$channelName];
    }

    public function find(string $appId, string $channelName): ?Channel
    {
        return $this->channels[$appId][$channelName] ?? null;
    }

    protected function determineChannelClass(string $channelName): string
    {
        if (starts_with($channelName, 'private-')) {
            return PrivateChannel::class;
        }

        if (starts_with($channelName, 'presence-')) {
            return PresenceChannel::class;
        }

        return Channel::class;
    }

    public function getChannels(string $appId): array
    {
        return $this->channels[$appId] ?? [];
    }

    public function getConnectionCount(string $appId): int
    {
        return collect($this->getChannels($appId))
            ->sum(function ($channel) {
                return count($channel->getSubscribedConnections());
            });
    }

    public function removeFromAllChannels(ConnectionInterface $connection)
    {
        if (! isset($connection->app)) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

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

        /*
         * Remove the connection from all channels.
         */
        collect(array_get($this->channels, $connection->app->id, []))->each->unsubscribe($connection);
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

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

        /*
         * Unset all channels that have no connections so we don't leak memory.
         */
        collect(array_get($this->channels, $connection->app->id, []))
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            ->reject->hasConnections()
                    ->each(function (Channel $channel, string $channelName) use ($connection) {
                        unset($this->channels[$connection->app->id][$channelName]);
                    });

        if (count(array_get($this->channels, $connection->app->id, [])) === 0) {
interface SomeInterface { }
class SomeClass implements SomeInterface {
    public $a;
}

function someFunction(SomeInterface $object) {
    if ($object instanceof SomeClass) {
        $a = $object->a;
    }
}
            unset($this->channels[$connection->app->id]);
        }
    }
}


1			<?php
2
3			namespace BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManagers;
4
5			use Ratchet\ConnectionInterface;
6			use BeyondCode\LaravelWebSockets\WebSockets\Channels\Channel;
7			use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager;
8			use BeyondCode\LaravelWebSockets\WebSockets\Channels\PrivateChannel;
9			use BeyondCode\LaravelWebSockets\WebSockets\Channels\PresenceChannel;
10
11			class ArrayChannelManager implements ChannelManager
12			{
13			/** @var string */
14			protected $appId;
15
16			/** @var array */
17			protected $channels = [];
18
19			public function findOrCreate(string $appId, string $channelName): Channel
20			{
21			if (! isset($this->channels[$appId][$channelName])) {
22			$channelClass = $this->determineChannelClass($channelName);
23
24			$this->channels[$appId][$channelName] = new $channelClass($channelName);
25			}
26
27			return $this->channels[$appId][$channelName];
28			}
29
30			public function find(string $appId, string $channelName): ?Channel
31			{
32			return $this->channels[$appId][$channelName] ?? null;
33			}
34
35			protected function determineChannelClass(string $channelName): string
36			{
37			if (starts_with($channelName, 'private-')) {
38			return PrivateChannel::class;
39			}
40
41			if (starts_with($channelName, 'presence-')) {
42			return PresenceChannel::class;
43			}
44
45			return Channel::class;
46			}
47
48			public function getChannels(string $appId): array
49			{
50			return $this->channels[$appId] ?? [];
51			}
52
53			public function getConnectionCount(string $appId): int
54			{
55			return collect($this->getChannels($appId))
56			->sum(function ($channel) {
57			return count($channel->getSubscribedConnections());
58			});
59			}
60
61			public function removeFromAllChannels(ConnectionInterface $connection)
62			{
63			if (! isset($connection->app)) {
			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...
64			return;
65			}
66
67			/*
68			* Remove the connection from all channels.
69			*/
70			collect(array_get($this->channels, $connection->app->id, []))->each->unsubscribe($connection);
			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...
71
72			/*
73			* Unset all channels that have no connections so we don't leak memory.
74			*/
75			collect(array_get($this->channels, $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...
76			->reject->hasConnections()
77			->each(function (Channel $channel, string $channelName) use ($connection) {
78			unset($this->channels[$connection->app->id][$channelName]);
79			});
80
81			if (count(array_get($this->channels, $connection->app->id, [])) === 0) {
			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...
82			unset($this->channels[$connection->app->id]);
83			}
84			}
85			}
86

beyondcode / laravel-websockets

Push — master ( db6d79...ec96ca )

ArrayChannelManager::findOrCreate() A

Complexity

Size

Duplication

Importance

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Duplication Side-by-Side

Filter issues like