rkrx / php-service-dispatcher

src/AttributeRepositories/MySQLAttributeRepository.php

Spacing +27 added lines, -27 removed lines

@@ -52,7 +52,7 @@ 
 	) {
 		$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
 		$this->pdo = $pdo;
-		if($this->options['use-locking'] ?? true) {
+		if ($this->options['use-locking'] ?? true) {
 			$this->lock = $pdo->prepare('SELECT GET_LOCK(:name, 0)');
 			$this->unlock = $pdo->prepare('SELECT RELEASE_LOCK(:name)');
 		}
@@ -63,7 +63,7 @@ 
 	 * @return bool
 	 */
 	public function has(string $key) {
-		if($this->hasService === null) {
+		if ($this->hasService === null) {
 			$this->hasService = $this->pdo->prepare("SELECT COUNT(*) FROM `{$this->tableName}` WHERE service_key=:key;");
 		}
 		$this->hasService->execute(['key' => $key]);
@@ -76,9 +76,9 @@ 
 	 * @return $this
 	 */
 	public function register(string $key) {
-		return $this->handleException(function () use ($key) {
-			if($this->services === null) {
-				if($this->getServiceKeys === null) {
+		return $this->handleException(function() use ($key) {
+			if ($this->services === null) {
+				if ($this->getServiceKeys === null) {
 					$this->getServiceKeys = $this->pdo->prepare("SELECT `service_key` FROM `{$this->tableName}`;");
 				}
 				try {
@@ -91,8 +91,8 @@ 
 				}
 			}
 			
-			if(!in_array($key, $this->services, true)) {
-				if($this->registerRow === null) {
+			if (!in_array($key, $this->services, true)) {
+				if ($this->registerRow === null) {
 					$this->registerRow = $this->pdo->prepare("INSERT INTO `{$this->tableName}` (`service_key`) VALUES (:key)");
 				}
 				$this->registerRow->execute(['key' => $key]);
@@ -107,15 +107,15 @@ 
 	 * @return object
 	 */
 	public function getRowByKey(string $key) {
-		if($this->getData === null) {
+		if ($this->getData === null) {
 			$this->getData = $this->pdo->prepare("SELECT service_key, service_last_try, service_last_run, service_next_run FROM `{$this->tableName}` WHERE service_key=:key;");
 		}
 		try {
-			$this->handleException(function () use ($key) {
+			$this->handleException(function() use ($key) {
 				$this->getData->execute(['key' => $key]);
 			});
 			$result = $this->getData->fetchObject();
-			if(!is_object($result)) {
+			if (!is_object($result)) {
 				throw new RuntimeException('Row not found');
 			}
 			return $result;
@@ -130,10 +130,10 @@ 
 	 * @return void
 	 */
 	public function setLastTryDate(string $key, DateTimeInterface $datetime): void {
-		if($this->updateTryDate === null) {
+		if ($this->updateTryDate === null) {
 			$this->updateTryDate = $this->pdo->prepare("INSERT INTO `{$this->tableName}` (service_key, service_last_try) VALUES (:key, :dt) ON DUPLICATE KEY UPDATE service_last_try=:dt");
 		}
-		$this->handleException(function () use ($key, $datetime) {
+		$this->handleException(function() use ($key, $datetime) {
 			$this->updateTryDate->execute(['key' => $key, 'dt' => $datetime->format('Y-m-d H:i:s')]);
 		});
 	}
@@ -144,10 +144,10 @@ 
 	 * @return void
 	 */
 	public function setLastRunDate(string $key, DateTimeInterface $datetime): void {
-		if($this->updateRunDate === null) {
+		if ($this->updateRunDate === null) {
 			$this->updateRunDate = $this->pdo->prepare("INSERT INTO `{$this->tableName}` (service_key, service_last_run) VALUES (:key, :dt) ON DUPLICATE KEY UPDATE service_last_run=:dt");
 		}
-		$this->handleException(function () use ($key, $datetime) {
+		$this->handleException(function() use ($key, $datetime) {
 			$this->updateRunDate->execute(['key' => $key, 'dt' => $datetime->format('Y-m-d H:i:s')]);
 		});
 	}
@@ -158,10 +158,10 @@ 
 	 * @return void
 	 */
 	public function setNextRunDate(string $key, DateTimeInterface $datetime): void {
-		if($this->updateNextDate === null) {
+		if ($this->updateNextDate === null) {
 			$this->updateNextDate = $this->pdo->prepare("INSERT INTO `{$this->tableName}` (service_key, service_next_run) VALUES (:key, :dt) ON DUPLICATE KEY UPDATE service_next_run=:dt");
 		}
-		$this->handleException(function () use ($key, $datetime) {
+		$this->handleException(function() use ($key, $datetime) {
 			$this->updateNextDate->execute(['key' => $key, 'dt' => $datetime->format('Y-m-d H:i:s')]);
 		});
 	}
@@ -175,7 +175,7 @@ 
 		$now ??= new DateTimeImmutable();
 		$data = (object) ['count' => 0];
 		$services = $this->fetchServices($now);
-		foreach($services as $service) {
+		foreach ($services as $service) {
 			try {
 				$this->lock($service->key);
 				$fn($service);
@@ -192,16 +192,16 @@ 
 	 * @return Service[]
 	 */
 	private function fetchServices(DateTimeInterface $now): array {
-		if($this->selectOverdueServices === null) {
+		if ($this->selectOverdueServices === null) {
 			$this->selectOverdueServices = $this->pdo->prepare("SELECT service_key, service_last_try, service_last_run, service_next_run FROM `{$this->tableName}` WHERE IFNULL(service_next_run, DATE('2000-01-01')) <= :dt ORDER BY service_last_try;");
 		}
-		return $this->handleException(function () use ($now) {
+		return $this->handleException(function() use ($now) {
 			$this->selectOverdueServices->execute(['dt' => $now->format('Y-m-d H:i:d')]);
 			try {
 				/** @var list<array{service_key: string}> $services */
 				$services = $this->selectOverdueServices->fetchAll(PDO::FETCH_ASSOC);
 				$result = [];
-				foreach($services as $service) {
+				foreach ($services as $service) {
 					$result[] = new Service($service['service_key']);
 				}
 				return $result;
@@ -221,7 +221,7 @@ 
 			$lockName = sprintf('%s%s', $this->options['lock-prefix'] ?? '', $key);
 			$this->lock->execute(['name' => $lockName]);
 			$lockObtained = $this->lock->fetchColumn(0);
-			if(!$lockObtained) {
+			if (!$lockObtained) {
 				throw new RuntimeException(sprintf('Could not obtain lock "%s"', $lockName));
 			}
 		} finally {
@@ -245,13 +245,13 @@ 
 		try {
 			return $fn();
 		} catch (PDOException $e) {
-			if($e->getCode() === self::MYSQL_ERR_TABLE_MSSING) {
+			if ($e->getCode() === self::MYSQL_ERR_TABLE_MSSING) {
 				// Field is missing, let's have a look what is going on...
 				$this->pdo->exec("CREATE TABLE IF NOT EXISTS `{$this->tableName}` (`service_key` VARCHAR(255) NOT NULL DEFAULT '', `service_last_try` DATETIME NULL DEFAULT NULL, `service_last_run` DATETIME NULL DEFAULT NULL, `service_next_run` DATETIME NULL DEFAULT NULL, PRIMARY KEY (`service_key`));");
 				return $this->retry($fn);
 			}
 			
-			if($e->getCode() === self::MYSQL_ERR_TABLE_COLUMN_MSSING) {
+			if ($e->getCode() === self::MYSQL_ERR_TABLE_COLUMN_MSSING) {
 				// Field is missing, let's have a look what is going on...
 				$this->checkIfOldTableVersion();
 				return $this->retry($fn);
@@ -271,19 +271,19 @@ 
 	
 	private function checkIfOldTableVersion(): void {
 		$stmt = $this->pdo->query("SHOW COLUMNS FROM `{$this->tableName}` LIKE 'service_next_run';");
-		if($stmt === false) {
+		if ($stmt === false) {
 			throw new RuntimeException('Could not check if service_next_run field exists');
 		}
 		$serviceNextRunField = $stmt->fetchAll(PDO::FETCH_ASSOC);
 
-		if(!count($serviceNextRunField)) {
+		if (!count($serviceNextRunField)) {
 			$this->pdo->exec("ALTER TABLE `{$this->tableName}` ADD COLUMN `service_next_run` DATETIME NULL DEFAULT NULL AFTER `service_last_run`;");
 			$stmt = $this->pdo->query("SHOW COLUMNS FROM `{$this->tableName}` LIKE 'service_timeout';");
-			if($stmt === false) {
+			if ($stmt === false) {
 				throw new RuntimeException('Could not check if service_timeout field exists');
 			}
 			$serviceTimeoutField = $stmt->fetchAll(PDO::FETCH_ASSOC);
-			if(count($serviceTimeoutField)) {
+			if (count($serviceTimeoutField)) {
 				$this->pdo->exec("UPDATE `{$this->tableName}` SET service_next_run = DATE_ADD(service_last_run, INTERVAL service_timeout SECOND)");
 				$this->pdo->exec("ALTER TABLE `{$this->tableName}` DROP COLUMN `service_timeout`;");
 			}

src/AttributeRepositories/SqliteAttributeRepository.php

Spacing +5 added lines, -5 removed lines

@@ -75,7 +75,7 @@ 
 		try {
 			$this->getData->execute(['key' => $key]);
 			$result = $this->getData->fetchObject();
-			if(!is_object($result)) {
+			if (!is_object($result)) {
 				throw new RuntimeException('Row not found');
 			}
 			return $result;
@@ -92,7 +92,7 @@ 
 	public function lockAndIterateServices(DateTimeInterface $now, callable $fn): int {
 		$count = 0;
 		$services = $this->fetchServices($now);
-		foreach($services as $service) {
+		foreach ($services as $service) {
 			$fn($service);
 		}
 		return $count;
@@ -107,7 +107,7 @@ 
 		try {
 			/** @var iterable<array{service_key: string}> $services */
 			$services = $this->selectServices->fetchAll(PDO::FETCH_ASSOC);
-			foreach($services as $service) {
+			foreach ($services as $service) {
 				yield new Service(key: $service['service_key']);
 			}
 		} finally {
@@ -122,11 +122,11 @@ 
 	private function migrate(int $version, string $statement): void {
 		/** @var PDOStatement|false $stmt */
 		$stmt = $this->pdo->query('PRAGMA user_version');
-		if($stmt === false) {
+		if ($stmt === false) {
 			throw new RuntimeException('Failed to get user_version');
 		}
 		$currentVersion = (int) $stmt->fetchColumn(0);
-		if($currentVersion < $version) {
+		if ($currentVersion < $version) {
 			$this->pdo->exec($statement);
 			$this->pdo->exec("PRAGMA user_version={$version}");
 		}

src/Dispatchers/DefaultDispatcher.php

Spacing +9 added lines, -9 removed lines

@@ -55,7 +55,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;
@@ -69,8 +69,8 @@ 
 	public function run(?DateTimeInterface $now = null): int {
 		/** @var DateTimeInterface $dt */
 		$dt = $now ?? new DateTimeImmutable();
-		return $this->attributeRepository->lockAndIterateServices($dt, function (Service $service) {
-			if(!array_key_exists($service->key, $this->services)) {
+		return $this->attributeRepository->lockAndIterateServices($dt, function(Service $service) {
+			if (!array_key_exists($service->key, $this->services)) {
 				return;
 			}
 			$eventParams = ['serviceName' => $service->key];
@@ -78,7 +78,7 @@ 
 				$this->fireEvent('service-start', $eventParams);
 				$serviceData = $this->services[$service->key];
 				$this->attributeRepository->setLastTryDate($service->key, new DateTimeImmutable());
-				if($this->methodInvoker !== null) {
+				if ($this->methodInvoker !== null) {
 					$result = $this->methodInvoker->invoke($serviceData->fn, $eventParams);
 				} else {
 					$result = call_user_func($serviceData->fn, $service);
@@ -86,13 +86,13 @@ 
 				$this->attributeRepository->setLastRunDate($service->key, new DateTimeImmutable());
 				$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);
@@ -106,10 +106,10 @@ 
 	 * @param array<string, mixed> $params
 	 */
 	private function fireEvent(string $event, array $params): void {
-		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);

src/Common/DateTimeHelper.php

Spacing +3 added lines, -3 removed lines

@@ -16,7 +16,7 @@ 
 	 */

 	public static function create($init = null): DateTime {

 		try {

-			if($init instanceof DateTimeInterface) {

+			if ($init instanceof DateTimeInterface) {

 				return new DateTime($init->format('c'));

 			}

 			return new DateTime($init ?? 'now');

@@ -31,10 +31,10 @@ 
 	 */

 	public static function createImmutable($init = null): DateTimeImmutable {

 		try {

-			if($init instanceof DateTimeImmutable) {

+			if ($init instanceof DateTimeImmutable) {

 				return $init;

 			}

-			if($init instanceof DateTimeInterface) {

+			if ($init instanceof DateTimeInterface) {

 				return new DateTimeImmutable($init->format('c'));

 			}

 			return new DateTimeImmutable($init ?? 'now');

src/Common/IntervalParser.php

Spacing +13 added lines, -13 removed lines

@@ -17,20 +17,20 @@ 
 	 * @return DateTimeImmutable
 	 */
 	public static function getNext($interval, ?DateTimeInterface $now = null): DateTimeImmutable {
-		if($now === null) {
+		if ($now === null) {
 			$now = new DateTimeImmutable();
 		} else {
 			$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;
 			}
 		}
-		if($result === null) {
+		if ($result === null) {
 			throw new RuntimeException('No alternative lays in the future');
 		}
 		return $result;
@@ -42,12 +42,12 @@ 
 	 * @return Generator<DateTimeImmutable>
 	 */
 	private static function parse($interval, DateTimeImmutable $now): Generator {
-		if(is_array($interval)) {
-			foreach($interval as $inner) {
+		if (is_array($interval)) {
+			foreach ($interval as $inner) {
 				/** @var TInterval $inner */
 				yield from self::parse($inner, $now);
 			}
-		} elseif(preg_match('{^\\d+$}', (string) $interval)) {
+		} elseif (preg_match('{^\\d+$}', (string) $interval)) {
 			yield self::parseInt((int) $interval, $now);
 		} else {
 			yield self::parseString((string) $interval, $now);
@@ -69,7 +69,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);
@@ -90,15 +90,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');