@@ -20,7 +20,7 @@ discard block |
||
| 20 | 20 | { |
| 21 | 21 | $mock = $this->getMockedUserQuery(); |
| 22 | 22 | $mock->expects($this->exactly(4)) |
| 23 | - ->method('filterByName'); |
|
| 23 | + ->method('filterByName'); |
|
| 24 | 24 | |
| 25 | 25 | $ignoredUsers = [ |
| 26 | 26 | 'foo', |
@@ -39,7 +39,7 @@ discard block |
||
| 39 | 39 | { |
| 40 | 40 | $mock = $this->getMockedUserQuery(); |
| 41 | 41 | $mock->expects($this->once()) |
| 42 | - ->method('filterByName'); |
|
| 42 | + ->method('filterByName'); |
|
| 43 | 43 | |
| 44 | 44 | $mock->filterIgnoredUsers([]); |
| 45 | 45 | } |
@@ -51,8 +51,8 @@ discard block |
||
| 51 | 51 | private function getMockedUserQuery() |
| 52 | 52 | { |
| 53 | 53 | return $this->getMockBuilder(UserQuery::class) |
| 54 | - ->setMethods(['filterByName']) |
|
| 55 | - ->getMock(); |
|
| 54 | + ->setMethods(['filterByName']) |
|
| 55 | + ->getMock(); |
|
| 56 | 56 | } |
| 57 | 57 | |
| 58 | 58 | } |
@@ -45,8 +45,8 @@ |
||
| 45 | 45 | |
| 46 | 46 | // Create two clients and connect them |
| 47 | 47 | $this->_clientMock = $this->getMockBuilder(ConnectionInterface::class) |
| 48 | - ->setMethods(['send', 'close']) |
|
| 49 | - ->getMock(); |
|
| 48 | + ->setMethods(['send', 'close']) |
|
| 49 | + ->getMock(); |
|
| 50 | 50 | |
| 51 | 51 | $this->_anotherClientMock = clone $this->_clientMock; |
| 52 | 52 | |
@@ -33,15 +33,15 @@ |
||
| 33 | 33 | // Create the configuration object |
| 34 | 34 | $config = new Configuration(); |
| 35 | 35 | $config->setDatabasePath($configuration['database_path']) |
| 36 | - ->setLogPath($configuration['log_path']) |
|
| 37 | - ->setInstances(self::parseInstances($configuration)) |
|
| 38 | - ->setAccessToken($configuration['access_token']) |
|
| 39 | - ->setUpdateInterval($configuration['update_interval']) |
|
| 40 | - ->setListenAddress($configuration['listen_address']) |
|
| 41 | - ->setListenPort($configuration['listen_port']) |
|
| 42 | - ->setHttpListenPort($configuration['http_listen_port']) |
|
| 43 | - ->setHttpUsername($configuration['http_username']) |
|
| 44 | - ->setHttpPassword($configuration['http_password']); |
|
| 36 | + ->setLogPath($configuration['log_path']) |
|
| 37 | + ->setInstances(self::parseInstances($configuration)) |
|
| 38 | + ->setAccessToken($configuration['access_token']) |
|
| 39 | + ->setUpdateInterval($configuration['update_interval']) |
|
| 40 | + ->setListenAddress($configuration['listen_address']) |
|
| 41 | + ->setListenPort($configuration['listen_port']) |
|
| 42 | + ->setHttpListenPort($configuration['http_listen_port']) |
|
| 43 | + ->setHttpUsername($configuration['http_username']) |
|
| 44 | + ->setHttpPassword($configuration['http_password']); |
|
| 45 | 45 | |
| 46 | 46 | return $config; |
| 47 | 47 | } |
@@ -44,9 +44,9 @@ |
||
| 44 | 44 | ) { |
| 45 | 45 | |
| 46 | 46 | return $this->filterByInstanceName($instanceName) |
| 47 | - ->filterByNetwork(Subscription::parseNetwork($status, $instanceStatus->getAvailableNetworks())) |
|
| 48 | - ->filterByMux(Subscription::parseMux($status, $instanceStatus->getAvailableMuxes())) |
|
| 49 | - ->addDescendingOrderByColumn('started'); |
|
| 47 | + ->filterByNetwork(Subscription::parseNetwork($status, $instanceStatus->getAvailableNetworks())) |
|
| 48 | + ->filterByMux(Subscription::parseMux($status, $instanceStatus->getAvailableMuxes())) |
|
| 49 | + ->addDescendingOrderByColumn('started'); |
|
| 50 | 50 | } |
| 51 | 51 | |
| 52 | 52 | } |
@@ -120,13 +120,13 @@ discard block |
||
| 120 | 120 | $this->onUserSeen($instanceName, $connectionStatus->user); |
| 121 | 121 | |
| 122 | 122 | $user = UserQuery::create()->filterByInstanceName($instanceName)->filterByName($connectionStatus->user) |
| 123 | - ->findOne(); |
|
| 123 | + ->findOne(); |
|
| 124 | 124 | } |
| 125 | 125 | |
| 126 | 126 | $connection = new Connection(); |
| 127 | 127 | $connection->setInstanceName($instanceName)->setPeer($connectionStatus->peer) |
| 128 | - ->setUser($user) |
|
| 129 | - ->setStarted($connectionStatus->started)->setType($connectionStatus->type)->save(); |
|
| 128 | + ->setUser($user) |
|
| 129 | + ->setStarted($connectionStatus->started)->setType($connectionStatus->type)->save(); |
|
| 130 | 130 | |
| 131 | 131 | $this->logger->info('Stored new connection (instance: {instanceName}, peer: {peer})', [ |
| 132 | 132 | 'instanceName' => $instanceName, |
@@ -160,8 +160,8 @@ discard block |
||
| 160 | 160 | |
| 161 | 161 | $input = new Input(); |
| 162 | 162 | $input->setInstanceName($instanceName) |
| 163 | - ->setStarted(new \DateTime()) |
|
| 164 | - ->setFromInputStatus($inputStatus)->save(); |
|
| 163 | + ->setStarted(new \DateTime()) |
|
| 164 | + ->setFromInputStatus($inputStatus)->save(); |
|
| 165 | 165 | |
| 166 | 166 | $this->logger |
| 167 | 167 | ->info('Stored new input (instance: {instanceName}, network: {network}, mux: {mux}, weight: {weight})', |
@@ -217,7 +217,7 @@ discard block |
||
| 217 | 217 | |
| 218 | 218 | // Try to determine which input is used by the subscription |
| 219 | 219 | $input = InputQuery::create()->filterBySubscriptionStatus($instanceName, $event->getInstanceStatus(), $status) |
| 220 | - ->findOne(); |
|
| 220 | + ->findOne(); |
|
| 221 | 221 | |
| 222 | 222 | if ($input === null) |
| 223 | 223 | { |
@@ -232,8 +232,8 @@ discard block |
||
| 232 | 232 | |
| 233 | 233 | $subscription = new Subscription(); |
| 234 | 234 | $subscription->setInstance($instance)->setInput($input)->setUser($user)->setChannel($channel) |
| 235 | - ->setSubscriptionId($status->id)->setStarted($status->start)->setTitle($status->title) |
|
| 236 | - ->setService($status->service); |
|
| 235 | + ->setSubscriptionId($status->id)->setStarted($status->start)->setTitle($status->title) |
|
| 236 | + ->setService($status->service); |
|
| 237 | 237 | $subscription->save(); |
| 238 | 238 | |
| 239 | 239 | $this->logger |
@@ -260,7 +260,7 @@ discard block |
||
| 260 | 260 | |
| 261 | 261 | // Find the latest matching subscription |
| 262 | 262 | $subscription = SubscriptionQuery::create() |
| 263 | - ->getNewestMatching($instanceName, $stateChange->getSubscriptionId()); |
|
| 263 | + ->getNewestMatching($instanceName, $stateChange->getSubscriptionId()); |
|
| 264 | 264 | |
| 265 | 265 | // EPG grab subscriptions are not stored so we don't want to log these with a high level |
| 266 | 266 | if ($subscription === null) |