rkrx / php-service-dispatcher

src/AttributeRepositories/MySQLAttributeRepository.php

Spacing +26 added lines, -26 removed lines

@@ -53,7 +53,7 @@ 
 		$this->tableName = $tableName;
 		$this->options = $options;
 		$this->pdo = $pdo;
-		if($options['use-locking'] ?? true) {
+		if ($options['use-locking'] ?? true) {
 			$this->lock = $pdo->prepare('SELECT GET_LOCK(:name, 0)');
 			$this->unlock = $pdo->prepare('SELECT RELEASE_LOCK(:name)');
 		}
@@ -64,7 +64,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]);
@@ -77,9 +77,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 {
@@ -89,8 +89,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]);
@@ -103,15 +103,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;
@@ -126,10 +126,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')]);
 		});
 	}
@@ -140,10 +140,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')]);
 		});
 	}
@@ -154,10 +154,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')]);
 		});
 	}
@@ -170,7 +170,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);
@@ -187,15 +187,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;
@@ -215,7 +215,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 {
@@ -238,13 +238,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);
@@ -259,7 +259,7 @@ 
 	 * @return mixed
 	 */
 	private function retry(Closure $fn) {
-		return $this->handleException(function () use ($fn) {
+		return $this->handleException(function() use ($fn) {
 			return $fn();
 		});
 	}
@@ -269,10 +269,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`;");
 			}