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 +1 added lines, -1 removed lines

@@ -98,7 +98,7 @@
 		$eventDispatcher->addSubscriber($persistenceManager);
 
 		// 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);

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));
 	}
 
 

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)