rkrx / php-service-dispatcher

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

@@ -56,7 +56,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 @@ 
 	 * @return int Number of successfully executed services
 	 */
 	public function run() {
-		return $this->attributeRepository->lockAndIterateServices(function (Service $service) {
-			if(!array_key_exists($service->getKey(), $this->services)) {
+		return $this->attributeRepository->lockAndIterateServices(function(Service $service) {
+			if (!array_key_exists($service->getKey(), $this->services)) {
 				return;
 			}
-			if(array_key_exists($service->getKey(), $this->standardTimeouts)) {
+			if (array_key_exists($service->getKey(), $this->standardTimeouts)) {
 				$standardTimeout = $this->standardTimeouts[$service->getKey()];
 			} else {
 				$standardTimeout = 0;
@@ -82,18 +82,18 @@ 
 			];
 			try {
 				$this->fireEvent('service-start', $eventParams);
-				if($this->methodInvoker !== null) {
+				if ($this->methodInvoker !== null) {
 					$result = $this->methodInvoker->invoke($this->services[$service->getKey()], $eventParams);
 				} else {
 					$result = call_user_func($this->services[$service->getKey()], $service);
 				}
-				if($result !== false) {
+				if ($result !== false) {
 					$this->fireEvent('service-success', $eventParams);
 				}
 			} catch (Throwable $e) {
 				$eventParams['exception'] = $e;
 				$this->fireEvent('service-failure', $eventParams);
-				if($this->logger !== null) {
+				if ($this->logger !== null) {
 					$this->logger->critical("{$service}: {$e->getMessage()}", ['exception' => $e]);
 				} else {
 					throw new RuntimeException("{$service}: {$e->getMessage()}", (int) $e->getCode(), $e);
@@ -107,14 +107,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));
 				}
 			}

src/AttributeRepositories/SqliteAttributeRepository.php

Spacing +5 added lines, -5 removed lines

@@ -65,13 +65,13 @@ 
 	 */
 	public function store($key, $timeout, array $data = []) {
 		$key = trim(strtolower($key));
-		if(!in_array($key, $this->services)) {
+		if (!in_array($key, $this->services)) {
 			$this->services[] = $key;
 		} else {
 			throw new RuntimeException("Duplicate service: {$key}");
 		}
 
-		if($this->has($key)) {
+		if ($this->has($key)) {
 			$this->updateService->execute(['key' => $key, 'timeout' => $timeout]);
 		} else {
 			$this->insertService->execute(['key' => $key, 'timeout' => $timeout, 'try' => '2000-01-01 00:00:00', 'run' => '2000-01-01 00:00:00']);
@@ -88,7 +88,7 @@ 
 	public function lockAndIterateServices($fn) {
 		$count = 0;
 		$services = $this->fetchServices();
-		foreach($services as $service) {
+		foreach ($services as $service) {
 			$this->updateTryDate->execute(['key' => $service->getKey()]);
 			$this->pdo->exec('BEGIN EXCLUSIVE TRANSACTION');
 			try {
@@ -97,7 +97,7 @@ 
 				$this->updateRunDate->execute(['key' => $service->getKey()]);
 				$count++;
 				$this->pdo->exec('COMMIT');
-			} catch(Throwable $e) {
+			} catch (Throwable $e) {
 				$this->pdo->exec('ROLLBACK');
 				throw $e;
 			}
@@ -112,7 +112,7 @@ 
 		$this->selectServices->execute();
 		try {
 			$services = $this->selectServices->fetchAll(PDO::FETCH_ASSOC);
-			foreach($services as $service) {
+			foreach ($services as $service) {
 				yield new Service($service['service_key']);
 			}
 		} finally {

src/AttributeRepositories/MySQLAttributeRepository.php

Spacing +6 added lines, -6 removed lines

@@ -37,7 +37,7 @@ 
 		$pdo->exec("CREATE TABLE IF NOT EXISTS `{$tableName}` (`service_key` VARCHAR(255) NOT NULL DEFAULT '', `service_last_try` DATETIME NULL DEFAULT '2000-01-01 00:00:00', `service_last_run` DATETIME NULL DEFAULT '2000-01-01 00:00:00', `service_timeout` INT UNSIGNED NULL DEFAULT '0', PRIMARY KEY (`service_key`));");
 		
 		$skipLocked = '';
-		if($options['skip-locked'] ?? false) {
+		if ($options['skip-locked'] ?? false) {
 			$skipLocked = ' SKIP LOCKED';
 		}
 		$this->selectServices = $pdo->prepare("SELECT service_key FROM `{$tableName}` WHERE DATE_ADD(service_last_run, INTERVAL service_timeout SECOND) <= NOW() ORDER BY GREATEST(service_last_try, service_last_run) ASC FOR UPDATE{$skipLocked};");
@@ -68,13 +68,13 @@ 
 	 */
 	public function store($key, $timeout, array $data = []) {
 		$key = trim(strtolower($key));
-		if(!in_array($key, $this->services)) {
+		if (!in_array($key, $this->services)) {
 			$this->services[] = $key;
 		} else {
 			throw new RuntimeException("Duplicate service: {$key}");
 		}
 
-		if($this->has($key)) {
+		if ($this->has($key)) {
 			$this->updateService->execute(['key' => $key, 'timeout' => $timeout]);
 		} else {
 			$this->insertService->execute(['key' => $key, 'timeout' => $timeout, 'try' => '2000-01-01 00:00:00', 'run' => '2000-01-01 00:00:00']);
@@ -91,7 +91,7 @@ 
 	public function lockAndIterateServices($fn) {
 		$count = 0;
 		$services = $this->fetchServices();
-		foreach($services as $service) {
+		foreach ($services as $service) {
 			$this->updateTryDate->execute(['key' => $service->getKey()]);
 			$this->pdo->exec('START TRANSACTION');
 			try {
@@ -100,7 +100,7 @@ 
 				$this->updateRunDate->execute(['key' => $service->getKey()]);
 				$count++;
 				$this->pdo->exec('COMMIT');
-			} catch(Throwable $e) {
+			} catch (Throwable $e) {
 				$this->pdo->exec('ROLLBACK');
 				throw $e;
 			}
@@ -115,7 +115,7 @@ 
 		$this->selectServices->execute();
 		try {
 			$services = $this->selectServices->fetchAll(PDO::FETCH_ASSOC);
-			foreach($services as $service) {
+			foreach ($services as $service) {
 				yield new Service($service['service_key']);
 			}
 		} finally {