blax-software
/
laravel-websockets
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

improve name

This commit is contained in:
freek 2018-12-01 15:21:31 +01:00
parent 54ee17c6b2
commit d7c6321d51
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/WebSockets/Channels/Channel.php
View File

@ -14,7 +14,7 @@ class Channel
protected $channelName; protected $channelName;
/** @var \Ratchet\ConnectionInterface[] */ /** @var \Ratchet\ConnectionInterface[] */
protected $subscriptions = []; protected $subscribedConnections = [];
public function __construct(string $channelName) public function __construct(string $channelName)
{ {
@ -23,12 +23,12 @@ class Channel
public function hasConnections(): bool public function hasConnections(): bool
{ {
return count($this->subscriptions) > 0; return count($this->subscribedConnections) > 0;
} }
public function getSubscriptions(): array public function getSubscribedConnections(): array
{ {
return $this->subscriptions; return $this->subscribedConnections;
} }
protected function verifySignature(ConnectionInterface $connection, stdClass $payload) protected function verifySignature(ConnectionInterface $connection, stdClass $payload)
@ -59,7 +59,7 @@ class Channel
public function unsubscribe(ConnectionInterface $connection) public function unsubscribe(ConnectionInterface $connection)
{ {
unset($this->subscriptions[$connection->socketId]); unset($this->subscribedConnections[$connection->socketId]);
if (! $this->hasConnections()) { if (! $this->hasConnections()) {
DashboardLogger::vacated($connection, $this->channelName); DashboardLogger::vacated($connection, $this->channelName);
@ -70,7 +70,7 @@ class Channel
{ {
$hadConnectionsPreviously = $this->hasConnections(); $hadConnectionsPreviously = $this->hasConnections();
$this->subscriptions[$connection->socketId] = $connection; $this->subscribedConnections[$connection->socketId] = $connection;
if (! $hadConnectionsPreviously) { if (! $hadConnectionsPreviously) {
DashboardLogger::occupied($connection, $this->channelName); DashboardLogger::occupied($connection, $this->channelName);
@ -81,7 +81,7 @@ class Channel
public function broadcast($payload) public function broadcast($payload)
{ {
foreach ($this->subscriptions as $connection) { foreach ($this->subscribedConnections as $connection) {
$connection->send(json_encode($payload)); $connection->send(json_encode($payload));
} }
} }
@ -92,7 +92,7 @@ class Channel
return $this->broadcast($payload); return $this->broadcast($payload);
} }
foreach ($this->subscriptions as $connection) { foreach ($this->subscribedConnections as $connection) {
if ($connection->socketId !== $socketId) { if ($connection->socketId !== $socketId) {
$connection->send(json_encode($payload)); $connection->send(json_encode($payload));
} }
@ -107,8 +107,8 @@ class Channel
public function toArray(): array public function toArray(): array
{ {
return [ return [
'occupied' => count($this->subscriptions) > 0, 'occupied' => count($this->subscribedConnections) > 0,
'subscription_count' => count($this->subscriptions) 'subscription_count' => count($this->subscribedConnections)
]; ];
} }
} }