rkrx / php-service-dispatcher

rector.php

Indentation +6 added lines, -6 removed lines

@@ -9,13 +9,13 @@
 use Rector\Set\ValueObject\LevelSetList;
 
 return static function (RectorConfig $rectorConfig): void {
-    $rectorConfig->paths([
-        __DIR__ . '/src',
-        __DIR__ . '/tests',
-    ]);
+	$rectorConfig->paths([
+		__DIR__ . '/src',
+		__DIR__ . '/tests',
+	]);
 
-    // register a single rule
-    $rectorConfig->rule(InlineConstructorDefaultToPropertyRector::class);
+	// register a single rule
+	$rectorConfig->rule(InlineConstructorDefaultToPropertyRector::class);
 
 	$rectorConfig->skip([RemoveUselessParamTagRector::class]);
 	$rectorConfig->skip([MixedTypeRector::class]);

Spacing +3 added lines, -3 removed lines

@@ -8,10 +8,10 @@
 use Rector\Php80\Rector\FunctionLike\MixedTypeRector;
 use Rector\Set\ValueObject\LevelSetList;
 
-return static function (RectorConfig $rectorConfig): void {
+return static function(RectorConfig $rectorConfig): void {
     $rectorConfig->paths([
-        __DIR__ . '/src',
-        __DIR__ . '/tests',
+        __DIR__.'/src',
+        __DIR__.'/tests',
     ]);
 
     // register a single rule

src/Builder/SqliteBuilder.php

Spacing +1 added lines, -1 removed lines

@@ -7,7 +7,7 @@
 use PDO;

 

 class SqliteBuilder {

-	private MethodInvoker|null $methodInvoker = null;

+	private MethodInvoker | null $methodInvoker = null;

 	

 	/**

 	 * @param string $filename

src/AttributeRepositories/MySQLAttributeRepository.php

Spacing +25 added lines, -25 removed lines

@@ -51,7 +51,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)');
 		}
@@ -62,7 +62,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]);
@@ -75,9 +75,9 @@ 
 	 * @return MySQLAttributeRepository|void
 	 */
 	public function register(string $key) {
-		$this->handleException(function () use ($key) {
-			if($this->services === null) {
-				if($this->getServiceKeys === null) {
+		$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 {
@@ -87,8 +87,8 @@ 
 					$this->getServiceKeys->closeCursor();
 				}
 			}
-			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]);
@@ -101,15 +101,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;
@@ -124,10 +124,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')]);
 		});
 	}
@@ -138,10 +138,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')]);
 		});
 	}
@@ -152,10 +152,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')]);
 		});
 	}
@@ -168,7 +168,7 @@ 
 	public function lockAndIterateServices(?DateTimeInterface $now, callable $fn): int {
 		$data = (object) ['count' => 0];
 			$services = $this->fetchServices($now);
-			foreach($services as $service) {
+			foreach ($services as $service) {
 				try {
 					$this->lock($service->getKey());
 					$fn($service);
@@ -185,15 +185,15 @@ 
 	 * @return Service[]
 	 */
 	private function fetchServices(DateTimeInterface $now) {
-		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 {
 				$services = $this->selectOverdueServices->fetchAll(PDO::FETCH_ASSOC);
 				$result = [];
-				foreach($services as $service) {
+				foreach ($services as $service) {
 					$result[] = new Service($service['service_key']);
 				}
 				return $result;
@@ -213,7 +213,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 {
@@ -236,13 +236,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);
@@ -265,10 +265,10 @@ 
 	private function checkIfOldTableVersion() {
 		$serviceNextRunField = $this->pdo->query("SHOW COLUMNS FROM `{$this->tableName}` LIKE 'service_next_run';")->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`;");
 			$serviceTimeoutField = $this->pdo->query("SHOW COLUMNS FROM `{$this->tableName}` LIKE 'service_timeout';")->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 +4 added lines, -4 removed lines

@@ -74,7 +74,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;
@@ -91,7 +91,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;
@@ -105,7 +105,7 @@ 
 		$this->selectServices->execute(['dt' => $now->format(self::SQLITE_DATETIME_FORMAT)]);
 		try {
 			$services = $this->selectServices->fetchAll(PDO::FETCH_ASSOC);
-			foreach($services as $service) {
+			foreach ($services as $service) {
 				yield new Service(key: $service['service_key']);
 			}
 		} finally {
@@ -119,7 +119,7 @@ 
 	 */
 	private function migrate(int $version, string $statement): void {
 		$currentVersion = (int) $this->pdo->query('PRAGMA user_version')->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

@@ -51,7 +51,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;
@@ -64,8 +64,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->key, $this->services)) {
+		return $this->attributeRepository->lockAndIterateServices($dt, function(Service $service) {
+			if (!array_key_exists($service->key, $this->services)) {
 				return;
 			}
 			$eventParams = ['serviceName' => $service->key];
@@ -73,7 +73,7 @@ 
 				$this->fireEvent('service-start', $eventParams);
 				$serviceData = $this->services[$service->key];
 				$this->attributeRepository->setLastTryDate($service->key, 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);
@@ -81,13 +81,13 @@ 
 				$this->attributeRepository->setLastRunDate($service->key, 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);
@@ -101,10 +101,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);