@@ -91,13 +91,13 @@ discard block |
||
| 91 | 91 | $this->onUserSeen($instanceName, $connectionStatus->user); |
| 92 | 92 | |
| 93 | 93 | $user = UserQuery::create()->filterByInstanceName($instanceName)->filterByName($connectionStatus->user) |
| 94 | - ->findOne(); |
|
| 94 | + ->findOne(); |
|
| 95 | 95 | } |
| 96 | 96 | |
| 97 | 97 | $connection = new Connection(); |
| 98 | 98 | $connection->setInstanceName($instanceName)->setPeer($connectionStatus->peer) |
| 99 | - ->setUser($user) |
|
| 100 | - ->setStarted($connectionStatus->started)->setType($connectionStatus->type)->save(); |
|
| 99 | + ->setUser($user) |
|
| 100 | + ->setStarted($connectionStatus->started)->setType($connectionStatus->type)->save(); |
|
| 101 | 101 | |
| 102 | 102 | $this->_logger->info('Stored new connection (instance: {instanceName}, peer: {peer})', [ |
| 103 | 103 | 'instanceName' => $instanceName, |
@@ -185,8 +185,8 @@ discard block |
||
| 185 | 185 | |
| 186 | 186 | $subscription = new Subscription(); |
| 187 | 187 | $subscription->setInstance($instance)->setUser($user)->setChannel($channel) |
| 188 | - ->setSubscriptionId($status->id)->setStarted($status->start)->setTitle($status->title) |
|
| 189 | - ->setService($status->service); |
|
| 188 | + ->setSubscriptionId($status->id)->setStarted($status->start)->setTitle($status->title) |
|
| 189 | + ->setService($status->service); |
|
| 190 | 190 | $subscription->save(); |
| 191 | 191 | |
| 192 | 192 | $this->_logger->info('Stored new subscription (instance: {instanceName}, user: {userName}, channel: {channelName})', |
@@ -210,8 +210,8 @@ discard block |
||
| 210 | 210 | |
| 211 | 211 | // Find the latest matching subscription |
| 212 | 212 | $subscription = SubscriptionQuery::create()->filterByInstanceName($instanceName) |
| 213 | - ->filterBySubscriptionId($stateChange->getSubscriptionId()) |
|
| 214 | - ->addDescendingOrderByColumn('started')->findOne(); |
|
| 213 | + ->filterBySubscriptionId($stateChange->getSubscriptionId()) |
|
| 214 | + ->addDescendingOrderByColumn('started')->findOne(); |
|
| 215 | 215 | |
| 216 | 216 | if ($subscription === null) |
| 217 | 217 | { |
@@ -259,7 +259,7 @@ discard block |
||
| 259 | 259 | private function hasConnection($instanceName, ConnectionStatus $connectionStatus) |
| 260 | 260 | { |
| 261 | 261 | return ConnectionQuery::create()->filterByInstanceName($instanceName)->filterByPeer($connectionStatus->peer) |
| 262 | - ->filterByStarted($connectionStatus->started)->findOne() !== null; |
|
| 262 | + ->filterByStarted($connectionStatus->started)->findOne() !== null; |
|
| 263 | 263 | } |
| 264 | 264 | |
| 265 | 265 | |
@@ -284,7 +284,7 @@ discard block |
||
| 284 | 284 | private function hasChannel($instanceName, $channelName) |
| 285 | 285 | { |
| 286 | 286 | return ChannelQuery::create()->filterByInstanceName($instanceName)->filterByName($channelName) |
| 287 | - ->findOne() !== null; |
|
| 287 | + ->findOne() !== null; |
|
| 288 | 288 | } |
| 289 | 289 | |
| 290 | 290 | |
@@ -307,9 +307,9 @@ discard block |
||
| 307 | 307 | $userId = $user !== null ? $user->getId() : null; |
| 308 | 308 | |
| 309 | 309 | return SubscriptionQuery::create()->filterByInstance($instance)->filterByUserId($userId) |
| 310 | - ->filterByChannel($channel) |
|
| 311 | - ->filterBySubscriptionId($subscription->id)->filterByStarted($subscription->start) |
|
| 312 | - ->findOne() !== null; |
|
| 310 | + ->filterByChannel($channel) |
|
| 311 | + ->filterBySubscriptionId($subscription->id)->filterByStarted($subscription->start) |
|
| 312 | + ->findOne() !== null; |
|
| 313 | 313 | } |
| 314 | 314 | |
| 315 | 315 | } |
@@ -251,7 +251,7 @@ |
||
| 251 | 251 | |
| 252 | 252 | |
| 253 | 253 | /** |
| 254 | - * @param $instanceName |
|
| 254 | + * @param string $instanceName |
|
| 255 | 255 | * @param ConnectionStatus $connectionStatus |
| 256 | 256 | * |
| 257 | 257 | * @return bool whether the connection exists in the database |