Jalle19 / tvheadend-status-manager

src/cli/Database/InputQuery.php

Indentation +3 added lines, -3 removed lines

@@ -27,9 +27,9 @@
 	public function filterBySubscriptionStatus($instanceName, SubscriptionStatus $status)
 	{
 		return $this->filterByInstanceName($instanceName)
-		            ->filterByNetwork(Subscription::parseNetwork($status))
-		            ->filterByMux(Subscription::parseMux($status))
-		            ->addDescendingOrderByColumn('started');
+					->filterByNetwork(Subscription::parseNetwork($status))
+					->filterByMux(Subscription::parseMux($status))
+					->addDescendingOrderByColumn('started');
 	}
 
 }

src/cli/Console/Commands/TvheadendStatusManagerCommand.php

Indentation +3 added lines, -3 removed lines

@@ -79,9 +79,9 @@
 		$aliases         = [':logger' => $logger, ':loop' => $eventLoop];
 
 		$injector->share($configuration)
-		         ->share($logger)
-		         ->share($eventDispatcher)
-		         ->share($eventLoop);
+				 ->share($logger)
+				 ->share($eventDispatcher)
+				 ->share($eventLoop);
 
 		// Create managers
 		$statusManager        = $injector->make('Jalle19\StatusManager\Manager\StatusManager', $aliases);

Spacing +2 added lines, -2 removed lines

@@ -100,7 +100,7 @@ 
 		$eventDispatcher->addSubscriber($inputErrorManager);
 
 		// Configure the event loop and start the application
-		$eventLoop->addPeriodicTimer($configuration->getUpdateInterval(), function () use ($eventDispatcher)
+		$eventLoop->addPeriodicTimer($configuration->getUpdateInterval(), function() use ($eventDispatcher)
 		{
 			// Emit an event on each tick
 			$eventDispatcher->dispatch(Events::MAIN_LOOP_TICK);
@@ -153,7 +153,7 @@ 
 		$manager = new ConnectionManagerSingle();
 		$manager->setConfiguration([
 			'classname'  => 'Propel\\Runtime\\Connection\\ConnectionWrapper',
-			'dsn'        => 'sqlite:' . $configuration->getDatabasePath(),
+			'dsn'        => 'sqlite:'.$configuration->getDatabasePath(),
 			'user'       => null,
 			'password'   => '',
 			'attributes' => [

src/cli/Database/ConnectionQuery.php

Indentation +3 added lines, -3 removed lines

@@ -22,9 +22,9 @@
 	public function hasConnection($instanceName, ConnectionStatus $connectionStatus)
 	{
 		return $this->filterByInstanceName($instanceName)
-		            ->filterByPeer($connectionStatus->peer)
-		            ->filterByStarted($connectionStatus->started)
-		            ->findOne() !== null;
+					->filterByPeer($connectionStatus->peer)
+					->filterByStarted($connectionStatus->started)
+					->findOne() !== null;
 	}
 
 }

src/cli/Database/ChannelQuery.php

Indentation +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
 	public function hasChannel($instanceName, $channelName)
 	{
 		return $this->filterByInstanceName($instanceName)->filterByName($channelName)
-		            ->findOne() !== null;
+					->findOne() !== null;
 	}
 
 }

src/cli/Database/Input.php

Indentation +3 added lines, -3 removed lines

@@ -23,9 +23,9 @@
 		$this->setPrimaryKey($inputStatus->uuid);
 
 		return $this->setInput($inputStatus->input)
-		            ->setWeight($inputStatus->weight)
-		            ->setNetwork(self::parseNetwork($inputStatus))
-		            ->setMux(self::parseMux($inputStatus));
+					->setWeight($inputStatus->weight)
+					->setNetwork(self::parseNetwork($inputStatus))
+					->setMux(self::parseMux($inputStatus));
 	}
 
 

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
 	 */
 	public function getFriendlyName()
 	{
-		return $this->getNetwork() . '/' . $this->getMux();
+		return $this->getNetwork().'/'.$this->getMux();
 	}
 
 

src/cli/Database/SubscriptionQuery.php

Indentation +5 added lines, -5 removed lines

@@ -34,9 +34,9 @@ 
 		$userId = $user !== null ? $user->getId() : null;
 
 		return $this->filterByInstance($instance)->filterByUserId($userId)
-		            ->filterByChannel($channel)
-		            ->filterBySubscriptionId($subscription->id)->filterByStarted($subscription->start)
-		            ->findOne() !== null;
+					->filterByChannel($channel)
+					->filterBySubscriptionId($subscription->id)->filterByStarted($subscription->start)
+					->findOne() !== null;
 	}
 
 
@@ -49,8 +49,8 @@ 
 	public function getNewestMatching($instanceName, $subscriptionId)
 	{
 		return $this->filterByInstanceName($instanceName)
-		            ->filterBySubscriptionId($subscriptionId)
-		            ->addDescendingOrderByColumn('started')->findOne();
+					->filterBySubscriptionId($subscriptionId)
+					->addDescendingOrderByColumn('started')->findOne();
 	}
 
 

src/cli/Manager/PersistenceManager.php

Indentation +8 added lines, -8 removed lines

@@ -116,13 +116,13 @@ 
 			$this->onUserSeen($instanceName, $connectionStatus->user);
 
 			$user = UserQuery::create()->filterByInstanceName($instanceName)->filterByName($connectionStatus->user)
-			                 ->findOne();
+							 ->findOne();
 		}
 
 		$connection = new Connection();
 		$connection->setInstanceName($instanceName)->setPeer($connectionStatus->peer)
-		           ->setUser($user)
-		           ->setStarted($connectionStatus->started)->setType($connectionStatus->type)->save();
+				   ->setUser($user)
+				   ->setStarted($connectionStatus->started)->setType($connectionStatus->type)->save();
 
 		$this->logger->info('Stored new connection (instance: {instanceName}, peer: {peer})', [
 			'instanceName' => $instanceName,
@@ -150,8 +150,8 @@ 
 
 		$input = new Input();
 		$input->setInstanceName($instanceName)
-		      ->setStarted(new \DateTime())
-		      ->setFromInputStatus($inputStatus)->save();
+			  ->setStarted(new \DateTime())
+			  ->setFromInputStatus($inputStatus)->save();
 
 		$this->logger
 			->info('Stored new input (instance: {instanceName}, network: {network}, mux: {mux}, weight: {weight})',
@@ -215,8 +215,8 @@ 
 
 		$subscription = new Subscription();
 		$subscription->setInstance($instance)->setInput($input)->setUser($user)->setChannel($channel)
-		             ->setSubscriptionId($status->id)->setStarted($status->start)->setTitle($status->title)
-		             ->setService($status->service);
+					 ->setSubscriptionId($status->id)->setStarted($status->start)->setTitle($status->title)
+					 ->setService($status->service);
 		$subscription->save();
 
 		$this->logger
@@ -243,7 +243,7 @@ 
 
 		// Find the latest matching subscription
 		$subscription = SubscriptionQuery::create()
-		                                 ->getNewestMatching($instanceName, $stateChange->getSubscriptionId());
+										 ->getNewestMatching($instanceName, $stateChange->getSubscriptionId());
 
 		// EPG grab subscriptions are not stored so we don't want to log these with a high level
 		if ($subscription === null)

tests/cli/Manager/StatusManagerTest.php

Indentation +5 added lines, -5 removed lines

@@ -21,14 +21,14 @@
 	{
 		/* @var EventSubscriberInterface|\PHPUnit_Framework_MockObject_MockObject $statusManager */
 		$statusManager = $this->getMockBuilder('\Jalle19\StatusManager\Manager\StatusManager')
-		                      ->setConstructorArgs([$this->configuration, $this->logger, $this->eventDispatcher])
-		                      ->setMethods(['onMainLoopStarted', 'onMainLoopTick'])
-		                      ->getMock();
+							  ->setConstructorArgs([$this->configuration, $this->logger, $this->eventDispatcher])
+							  ->setMethods(['onMainLoopStarted', 'onMainLoopTick'])
+							  ->getMock();
 
 		$statusManager->expects($this->once())
-		              ->method('onMainLoopStarted');
+					  ->method('onMainLoopStarted');
 		$statusManager->expects($this->once())
-		              ->method('onMainLoopTick');
+					  ->method('onMainLoopTick');
 
 		$this->eventDispatcher->addSubscriber($statusManager);
 		$this->eventDispatcher->dispatch(Events::MAIN_LOOP_STARTING);

tests/cli/Manager/InstanceStateManagerTest.php

Indentation +12 added lines, -12 removed lines

@@ -25,23 +25,23 @@
 	{
 		/* @var EventSubscriberInterface|\PHPUnit_Framework_MockObject_MockObject|InstanceStateManager $instanceStateManager */
 		$instanceStateManager = $this->getMockBuilder('\Jalle19\StatusManager\Manager\InstanceStateManager')
-		                             ->setConstructorArgs([$this->configuration, $this->logger, $this->eventDispatcher])
-		                             ->setMethods([
-			                             'onInstanceStatusCollectionRequest',
-			                             'onInstanceReachable',
-			                             'onInstanceUnreachable',
-			                             'onInstanceMaybeReachable',
-		                             ])
-		                             ->getMock();
+									 ->setConstructorArgs([$this->configuration, $this->logger, $this->eventDispatcher])
+									 ->setMethods([
+										 'onInstanceStatusCollectionRequest',
+										 'onInstanceReachable',
+										 'onInstanceUnreachable',
+										 'onInstanceMaybeReachable',
+									 ])
+									 ->getMock();
 
 		$instanceStateManager->expects($this->once())
-		                     ->method('onInstanceStatusCollectionRequest');
+							 ->method('onInstanceStatusCollectionRequest');
 		$instanceStateManager->expects($this->once())
-		                     ->method('onInstanceReachable');
+							 ->method('onInstanceReachable');
 		$instanceStateManager->expects($this->once())
-		                     ->method('onInstanceUnreachable');
+							 ->method('onInstanceUnreachable');
 		$instanceStateManager->expects($this->once())
-		                     ->method('onInstanceMaybeReachable');
+							 ->method('onInstanceMaybeReachable');
 
 		// Start triggering events and assert that the instance state is as expected
 		$this->eventDispatcher->addSubscriber($instanceStateManager);