rkrx / php-service-dispatcher

src/Dispatchers/DefaultDispatcher.php

Spacing +10 added lines, -10 removed lines

@@ -57,7 +57,7 @@ 
 	 * @return $this
 	 */
 	public function on(string $event, callable $fn) {
-		if(!array_key_exists($event, $this->listeners)) {
+		if (!array_key_exists($event, $this->listeners)) {
 			$this->listeners[$event] = [];
 		}
 		$this->listeners[$event][] = $fn;
@@ -70,8 +70,8 @@ 
 	 */
 	public function run(?DateTimeInterface $now = null): int {
 		$dt = $now ?? date_create_immutable();
-		return $this->attributeRepository->lockAndIterateServices($dt, function (Service $service) {
-			if(!array_key_exists($service->getKey(), $this->services)) {
+		return $this->attributeRepository->lockAndIterateServices($dt, function(Service $service) {
+			if (!array_key_exists($service->getKey(), $this->services)) {
 				return;
 			}
 			$eventParams = ['serviceName' => $service->getKey()];
@@ -79,7 +79,7 @@ 
 				$this->fireEvent('service-start', $eventParams);
 				$serviceData = $this->services[$service->getKey()];
 				$this->attributeRepository->setLastTryDate($service->getKey(), date_create_immutable());
-				if($this->methodInvoker !== null) {
+				if ($this->methodInvoker !== null) {
 					$result = $this->methodInvoker->invoke($serviceData->fn, $eventParams);
 				} else {
 					$result = call_user_func($serviceData->fn, $service);
@@ -87,13 +87,13 @@ 
 				$this->attributeRepository->setLastRunDate($service->getKey(), date_create_immutable());
 				$nextRunDate = IntervalParser::getNext($serviceData->interval);
 				$this->attributeRepository->setNextRunDate($serviceData->key, $nextRunDate);
-				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,10 +107,10 @@ 
 	 * @param array $params
 	 */
 	private function fireEvent(string $event, array $params) {
-		if(array_key_exists($event, $this->listeners)) {
+		if (array_key_exists($event, $this->listeners)) {
 			try {
-				foreach($this->listeners[$event] as $listener) {
-					if($this->methodInvoker !== null) {
+				foreach ($this->listeners[$event] as $listener) {
+					if ($this->methodInvoker !== null) {
 						$this->methodInvoker->invoke($listener, $params);
 					} else {
 						call_user_func($listener, $params['serviceName'] ?? null);
@@ -118,7 +118,7 @@ 
 				}
 			} 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/Common/IntervalParser.php

Spacing +12 added lines, -12 removed lines

@@ -14,7 +14,7 @@ 
 	 * @return DateTimeImmutable
 	 */
 	public static function getNext($interval, ?DateTimeInterface $now = null): DateTimeImmutable {
-		if($now === null) {
+		if ($now === null) {
 			try {
 				$now = new DateTimeImmutable();
 			} catch (Throwable $e) {
@@ -24,10 +24,10 @@ 
 			$now = DateTimeHelper::createImmutable($now);
 		}
 		$result = null;
-		foreach(self::parse($interval, $now) as $date) {
-			if($result === null) {
+		foreach (self::parse($interval, $now) as $date) {
+			if ($result === null) {
 				$result = $date;
-			} elseif($date < $result) {
+			} elseif ($date < $result) {
 				$result = $date;
 			}
 		}
@@ -40,11 +40,11 @@ 
 	 * @return Generator|DateTimeImmutable[]
 	 */
 	private static function parse($interval, DateTimeImmutable $now) {
-		if(is_array($interval)) {
-			foreach($interval as $inner) {
+		if (is_array($interval)) {
+			foreach ($interval as $inner) {
 				yield from self::parse($inner, $now);
 			}
-		} elseif(preg_match('/^\\d+$/', $interval)) {
+		} elseif (preg_match('/^\\d+$/', $interval)) {
 			yield self::parseInt($interval, $now);
 		} else {
 			yield self::parseString($interval, $now);
@@ -66,7 +66,7 @@ 
 	 * @return DateTimeImmutable
 	 */
 	private static function parseString(string $interval, DateTimeImmutable $now): DateTimeImmutable {
-		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;
 			[$hours, $minutes, $seconds] = array_slice($matches, 1);
 			$today = DateTimeHelper::createImmutable($now)->setTime((int) $hours, (int) $minutes, (int) $seconds);
@@ -87,15 +87,15 @@ 
 	 */
 	private static function nearst(array $possibleDates, DateTimeImmutable $now) {
 		$current = null;
-		foreach($possibleDates as $possibleDate) {
-			if($now > $possibleDate) { // The current date is in the past
+		foreach ($possibleDates as $possibleDate) {
+			if ($now > $possibleDate) { // The current date is in the past
 				continue;
 			}
-			if($current === null || $possibleDate < $current) {
+			if ($current === null || $possibleDate < $current) {
 				$current = $possibleDate;
 			}
 		}
-		if($current !== null) {
+		if ($current !== null) {
 			return $current;
 		}
 		throw new RuntimeException('No alternative lays in the future');