@@ -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) |