rkrx / php-service-dispatcher

src/AttributeRepositories/SqliteAttributeRepository.php

Spacing +3 added lines, -3 removed lines

@@ -61,13 +61,13 @@ 
 	 */
 	public function store($key, $timeout, array $data = array()) {
 		$key = trim(strtolower($key));
-		if(!in_array($key, $this->services)) {
+		if (!in_array($key, $this->services)) {
 			$this->services[] = $key;
 		} else {
 			throw new Exception("Duplicate service: {$key}");
 		}
 
-		if($this->has($key)) {
+		if ($this->has($key)) {
 			$this->updateService->bindValue('key', $key);
 			$this->updateService->bindValue('timeout', $timeout);
 			$this->updateService->execute();
@@ -109,7 +109,7 @@ 
 		$this->selectServices->execute();
 		$services = $this->selectServices->fetchAll(PDO::FETCH_ASSOC);
 		$result = array();
-		foreach($services as $service) {
+		foreach ($services as $service) {
 			$result[] = $service['service_key'];
 		}
 		$this->selectServices->closeCursor();

src/Dispatchers/DefaultDispatcher.php

Spacing +9 added lines, -9 removed lines

@@ -51,7 +51,7 @@ 
 	 * @return $this
 	 */
 	public function on($event, $fn) {
-		if(!array_key_exists($event, $this->listeners)) {
+		if (!array_key_exists($event, $this->listeners)) {
 			$this->listeners[$event] = array();
 		}
 		$this->listeners[$event][] = $fn;
@@ -65,11 +65,11 @@ 
 	public function run() {
 		$services = $this->attributeRepository->fetchServices();
 		$count = 0;
-		foreach($services as $service) {
-			if(!array_key_exists($service, $this->services)) {
+		foreach ($services as $service) {
+			if (!array_key_exists($service, $this->services)) {
 				continue;
 			}
-			if(array_key_exists($service, $this->standardTimeouts)) {
+			if (array_key_exists($service, $this->standardTimeouts)) {
 				$standardTimeout = $this->standardTimeouts[$service];
 			} else {
 				$standardTimeout = 0;
@@ -81,7 +81,7 @@ 
 			try {
 				$this->fireEvent('service-start', $eventParams);
 				$this->attributeRepository->markTry($service);
-				if($this->methodInvoker !== null) {
+				if ($this->methodInvoker !== null) {
 					$this->methodInvoker->invoke($this->services[$service], $eventParams);
 				} else {
 					call_user_func($this->services[$service], $service);
@@ -92,7 +92,7 @@ 
 			} catch (\Exception $e) {
 				$eventParams['exception'] = $e;
 				$this->fireEvent('service-failure', $eventParams);
-				if($this->logger !== null) {
+				if ($this->logger !== null) {
 					$this->logger->critical("{$service}: {$e->getMessage()}", array('exception' => $e));
 				} else {
 					throw new Exception("{$service}: {$e->getMessage()}", $e->getCode(), $e);
@@ -107,14 +107,14 @@ 
 	 * @param array $params
 	 */
 	private function fireEvent($event, $params) {
-		if(array_key_exists($event, $this->listeners)) {
+		if (array_key_exists($event, $this->listeners)) {
 			try {
-				foreach($this->listeners[$event] as $listener) {
+				foreach ($this->listeners[$event] as $listener) {
 					$this->methodInvoker->invoke($listener, $params);
 				}
 			} 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/Dispatchers/DefaultDispatcher/Service.php

Spacing +1 added lines, -1 removed lines

@@ -45,7 +45,7 @@
 		$lastRunTime = clone $this->getAttributes()->getLastRunTime();
 		$lastRunTime->modify("+{$this->interval} seconds");
 		$lastRunTime->setTimezone(new DateTimeZone('UTC'));
-		return ;
+		return;
 	}
 
 	/**