rkrx / php-service-dispatcher

src/AttributeRepositories/SqliteAttributeRepository.php

Spacing +3 added lines, -3 removed lines

@@ -61,13 +61,13 @@ 
 	 */
 	public function store($key, $timeout, array $data = array()) {
 		$key = trim(strtolower($key));
-		if(!in_array($key, $this->services)) {
+		if (!in_array($key, $this->services)) {
 			$this->services[] = $key;
 		} else {
 			throw new Exception("Duplicate service: {$key}");
 		}
 
-		if($this->has($key)) {
+		if ($this->has($key)) {
 			$this->updateService->bindValue('key', $key);
 			$this->updateService->bindValue('timeout', $timeout);
 			$this->updateService->execute();
@@ -109,7 +109,7 @@ 
 		$this->selectServices->execute();
 		$services = $this->selectServices->fetchAll(PDO::FETCH_ASSOC);
 		$result = array();
-		foreach($services as $service) {
+		foreach ($services as $service) {
 			$result[] = $service['service_key'];
 		}
 		$this->selectServices->closeCursor();

src/Dispatchers/DefaultDispatcher/Service.php

Spacing +1 added lines, -1 removed lines

@@ -45,7 +45,7 @@
 		$lastRunTime = clone $this->getAttributes()->getLastRunTime();
 		$lastRunTime->modify("+{$this->interval} seconds");
 		$lastRunTime->setTimezone(new DateTimeZone('UTC'));
-		return ;
+		return;
 	}
 
 	/**

src/AttributeRepositories/MySQLAttributeRepository.php

Spacing +3 added lines, -3 removed lines

@@ -61,13 +61,13 @@ 
 	 */
 	public function store($key, $timeout, array $data = array()) {
 		$key = trim(strtolower($key));
-		if(!in_array($key, $this->services)) {
+		if (!in_array($key, $this->services)) {
 			$this->services[] = $key;
 		} else {
 			throw new Exception("Duplicate service: {$key}");
 		}
 
-		if($this->has($key)) {
+		if ($this->has($key)) {
 			$this->updateService->bindValue('key', $key);
 			$this->updateService->bindValue('timeout', $timeout);
 			$this->updateService->execute();
@@ -109,7 +109,7 @@ 
 		$this->selectServices->execute();
 		$services = $this->selectServices->fetchAll(PDO::FETCH_ASSOC);
 		$result = array();
-		foreach($services as $service) {
+		foreach ($services as $service) {
 			$result[] = $service['service_key'];
 		}
 		$this->selectServices->closeCursor();

src/Common/IntervalParser.php

Spacing +6 added lines, -6 removed lines

@@ -9,9 +9,9 @@ 
 	 * @return int
 	 */
 	public static function parse($interval) {
-		if(is_array($interval)) {
+		if (is_array($interval)) {
 			$result = array();
-			foreach($interval as $intervalStr) {
+			foreach ($interval as $intervalStr) {
 				$result[] = self::parseString($intervalStr);
 			}
 			return min($result);
@@ -26,10 +26,10 @@ 
 	 * @throws Exception
 	 */
 	private static function parseString($interval) {
-		if(preg_match('/^\\d+$/', $interval)) {
+		if (preg_match('/^\\d+$/', $interval)) {
 			return $interval;
 		}
-		if(preg_match('/^(\\d{1,2}|\\*):(\\d{1,2}|\\*)(?::(\\d{1,2}|\\*))?$/', $interval, $matches)) {
+		if (preg_match('/^(\\d{1,2}|\\*):(\\d{1,2}|\\*)(?::(\\d{1,2}|\\*))?$/', $interval, $matches)) {
 			$matches[] = 0;
 			list($hours, $minutes, $seconds) = array_slice($matches, 1);
 			$possibleDates = array(
@@ -47,9 +47,9 @@ 
 	 * @throws Exception
 	 */
 	private static function nearst(array $possibleDates) {
-		foreach($possibleDates as $possibleDate) {
+		foreach ($possibleDates as $possibleDate) {
 			$time = strtotime($possibleDate);
-			if($time > time()) {
+			if ($time > time()) {
 				return $time - time();
 			}
 		}

src/Dispatchers/DefaultDispatcher.php

Spacing +9 added lines, -9 removed lines

@@ -53,7 +53,7 @@ 
 	 * @return $this
 	 */
 	public function on($event, $fn) {
-		if(!array_key_exists($event, $this->listeners)) {
+		if (!array_key_exists($event, $this->listeners)) {
 			$this->listeners[$event] = array();
 		}
 		$this->listeners[$event][] = $fn;
@@ -67,11 +67,11 @@ 
 	public function run() {
 		$services = $this->attributeRepository->fetchServices();
 		$count = 0;
-		foreach($services as $service) {
-			if(!array_key_exists($service, $this->services)) {
+		foreach ($services as $service) {
+			if (!array_key_exists($service, $this->services)) {
 				continue;
 			}
-			if(array_key_exists($service, $this->standardTimeouts)) {
+			if (array_key_exists($service, $this->standardTimeouts)) {
 				$standardTimeout = $this->standardTimeouts[$service];
 			} else {
 				$standardTimeout = 0;
@@ -83,7 +83,7 @@ 
 			try {
 				$this->fireEvent('service-start', $eventParams);
 				$this->attributeRepository->markTry($service);
-				if($this->methodInvoker !== null) {
+				if ($this->methodInvoker !== null) {
 					$this->methodInvoker->invoke($this->services[$service], $eventParams);
 				} else {
 					call_user_func($this->services[$service], $service);
@@ -94,7 +94,7 @@ 
 			} catch (\Exception $e) {
 				$eventParams['exception'] = $e;
 				$this->fireEvent('service-failure', $eventParams);
-				if($this->logger !== null) {
+				if ($this->logger !== null) {
 					$this->logger->critical("{$service}: {$e->getMessage()}", array('exception' => $e));
 				} else {
 					throw new Exception("{$service}: {$e->getMessage()}", (int) $e->getCode(), $e);
@@ -109,14 +109,14 @@ 
 	 * @param array $params
 	 */
 	private function fireEvent($event, $params) {
-		if(array_key_exists($event, $this->listeners)) {
+		if (array_key_exists($event, $this->listeners)) {
 			try {
-				foreach($this->listeners[$event] as $listener) {
+				foreach ($this->listeners[$event] as $listener) {
 					$this->methodInvoker->invoke($listener, $params);
 				}
 			} catch (Exception $e) {
 				// Supress exceptions emitted by events
-				if($this->logger !== null) {
+				if ($this->logger !== null) {
 					$this->logger->critical($e->getMessage(), array('exception' => $e));
 				}
 			}