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