Jalle19 / tvheadend-status-manager

src/cli/PersistenceManager.php

Doc Comments +1 added lines, -1 removed lines

@@ -251,7 +251,7 @@
 
 
 	/**
-	 * @param                  $instanceName
+	 * @param                  string $instanceName
 	 * @param ConnectionStatus $connectionStatus
 	 *
 	 * @return bool whether the connection exists in the database

Indentation +17 added lines, -17 removed lines

@@ -94,13 +94,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,
@@ -127,11 +127,11 @@ 
 		$input = new Input();
 		$input->setPrimaryKey($inputStatus->uuid);
 		$input->setInstanceName($instanceName)
-		      ->setStarted(new \DateTime())
-		      ->setInput($inputStatus->input)
-		      ->setWeight($inputStatus->weight)
-		      ->setNetwork(Input::parseNetwork($inputStatus))
-		      ->setMux(Input::parseMux($inputStatus))->save();
+			  ->setStarted(new \DateTime())
+			  ->setInput($inputStatus->input)
+			  ->setWeight($inputStatus->weight)
+			  ->setNetwork(Input::parseNetwork($inputStatus))
+			  ->setMux(Input::parseMux($inputStatus))->save();
 
 		$this->_logger->info('Stored new input (instance: {instanceName}, network: {network}, mux: {mux}, weight: {weight})',
 			[
@@ -237,8 +237,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->info('Stored new subscription (instance: {instanceName}, user: {userName}, channel: {channelName})',
@@ -262,8 +262,8 @@ 
 
 		// Find the latest matching subscription
 		$subscription = SubscriptionQuery::create()->filterByInstanceName($instanceName)
-		                                 ->filterBySubscriptionId($stateChange->getSubscriptionId())
-		                                 ->addDescendingOrderByColumn('started')->findOne();
+										 ->filterBySubscriptionId($stateChange->getSubscriptionId())
+										 ->addDescendingOrderByColumn('started')->findOne();
 
 		// EPG grab subscriptions are not stored so we don't want to log these with a high level
 		if ($subscription === null)
@@ -312,7 +312,7 @@ 
 	private function hasConnection($instanceName, ConnectionStatus $connectionStatus)
 	{
 		return ConnectionQuery::create()->filterByInstanceName($instanceName)->filterByPeer($connectionStatus->peer)
-		                      ->filterByStarted($connectionStatus->started)->findOne() !== null;
+							  ->filterByStarted($connectionStatus->started)->findOne() !== null;
 	}
 
 
@@ -348,7 +348,7 @@ 
 	private function hasChannel($instanceName, $channelName)
 	{
 		return ChannelQuery::create()->filterByInstanceName($instanceName)->filterByName($channelName)
-		                   ->findOne() !== null;
+						   ->findOne() !== null;
 	}
 
 
@@ -371,9 +371,9 @@ 
 		$userId = $user !== null ? $user->getId() : null;
 
 		return SubscriptionQuery::create()->filterByInstance($instance)->filterByUserId($userId)
-		                        ->filterByChannel($channel)
-		                        ->filterBySubscriptionId($subscription->id)->filterByStarted($subscription->start)
-		                        ->findOne() !== null;
+								->filterByChannel($channel)
+								->filterBySubscriptionId($subscription->id)->filterByStarted($subscription->start)
+								->findOne() !== null;
 	}
 
 }

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/StatusManager.php

Unused Use Statements -1 removed lines

@@ -2,7 +2,6 @@
 
 namespace Jalle19\StatusManager;
 
-use Jalle19\StatusManager\Database;
 use Jalle19\StatusManager\Event\ConnectionSeenEvent;
 use Jalle19\StatusManager\Event\Events;
 use Jalle19\StatusManager\Event\InputSeenEvent;

Braces +2 added lines, -4 removed lines

@@ -225,14 +225,12 @@
 
 					$this->_eventDispatcher->dispatch(Events::INSTANCE_STATE_REACHABLE,
 						new InstanceStateEvent($instance));
-				}
-				catch (\Exception $e)
+				} catch (\Exception $e)
 				{
 					$this->_eventDispatcher->dispatch(Events::INSTANCE_STATE_UNREACHABLE,
 						new InstanceStateEvent($instance));
 				}
-			}
-			else
+			} else
 			{
 				$this->_eventDispatcher->dispatch(Events::INSTANCE_STATE_MAYBE_REACHABLE,
 					new InstanceStateEvent($instance));

src/cli/InstanceStateManager.php

Braces +1 added lines, -2 removed lines

@@ -110,8 +110,7 @@
 			$this->_logger->info('Retrying instance {instanceName} during next cycle', [
 				'instanceName' => $instance->getName(),
 			]);
-		}
-		else
+		} else
 			$instanceState->incrementRetryCount();
 	}