pradosoft / prado

framework/Util/TSignalsDispatcher.php

Spacing +13 added lines, -13 removed lines

@@ -94,17 +94,17 @@ 
 		SIGALRM => self::FX_SIGNAL_ALARM, // Alarm signal.  Sent by pcntl_alarm when the time is over.
 		SIGHUP => self::FX_SIGNAL_HANG_UP, // Hangup signal. Sent to a process when its controlling terminal is closed.
 		SIGINT => self::FX_SIGNAL_INTERRUPT, // Interrupt signal. Typically generated by pressing Ctrl+C.
-		SIGQUIT => self::FX_SIGNAL_QUIT,  // Quit signal. Similar to SIGINT but produces a core dump when received by the process.
-		SIGTRAP => self::FX_SIGNAL_TRAP,  // Trace/breakpoint trap signal. Used by debuggers to catch trace and breakpoint conditions.
+		SIGQUIT => self::FX_SIGNAL_QUIT, // Quit signal. Similar to SIGINT but produces a core dump when received by the process.
+		SIGTRAP => self::FX_SIGNAL_TRAP, // Trace/breakpoint trap signal. Used by debuggers to catch trace and breakpoint conditions.
 		SIGABRT => self::FX_SIGNAL_ABORT, // Abort signal. Sent by the process itself to terminate due to a critical error condition.
 		SIGUSR1 => self::FX_SIGNAL_USER1, // User-defined signal 1.
 		SIGUSR2 => self::FX_SIGNAL_USER2, // User-defined signal 2.
 		SIGTERM => self::FX_SIGNAL_TERMINATE, // Termination signal. Typically used to request graceful termination of a process.
 		SIGCHLD => self::FX_SIGNAL_CHILD, // Child signal. Sent to a parent process when a child process terminates.
-		SIGCONT => self::FX_SIGNAL_CONTINUE,  // Continue signal. Sent to resume a process that has been stopped.
+		SIGCONT => self::FX_SIGNAL_CONTINUE, // Continue signal. Sent to resume a process that has been stopped.
 		SIGTSTP => self::FX_SIGNAL_TERMINAL_STOP, // Terminal stop signal. Sent by pressing Ctrl+Z to suspend the process.
-		SIGTTIN => self::FX_SIGNAL_BACKGROUND_READ,    // Background read signal. Sent to a process when it attempts to read from the terminal while in the background.
-		SIGTTOU => self::FX_SIGNAL_BACKGROUND_WRITE,   // Background write signal. Sent to a process when it attempts to write to the terminal while in the background.
+		SIGTTIN => self::FX_SIGNAL_BACKGROUND_READ, // Background read signal. Sent to a process when it attempts to read from the terminal while in the background.
+		SIGTTOU => self::FX_SIGNAL_BACKGROUND_WRITE, // Background write signal. Sent to a process when it attempts to write to the terminal while in the background.
 		SIGURG => self::FX_SIGNAL_URGENT, // Urgent condition signal. Indicates the arrival of out-of-band data on a socket.
 	];
 
@@ -223,7 +223,7 @@ 
 			static::setAsyncSignals(true);
 		}
 
-		foreach(static::SIGNAL_MAP as $signal => $event) {
+		foreach (static::SIGNAL_MAP as $signal => $event) {
 			$handler = pcntl_signal_get_handler($signal);
 
 			if ($handler instanceof self) {
@@ -233,7 +233,7 @@ 
 
 			$callable = is_callable($handler);
 			if ($callable) {
-				$handler = function ($sender, $param) use ($handler) {
+				$handler = function($sender, $param) use ($handler) {
 					return $handler($param->getSignal(), $param->getParameter());
 				};
 				self::$_priorHandlers[$signal][1] = $handler;
@@ -277,7 +277,7 @@ 
 			return false;
 		}
 
-		foreach(self::$_priorHandlers as $signal => $originalCallback) {
+		foreach (self::$_priorHandlers as $signal => $originalCallback) {
 			pcntl_signal($signal, $originalCallback[0]);
 			$uninstallHandler = true;
 			switch ($signal) {
@@ -325,7 +325,7 @@ 
 	{
 		if (isset(static::SIGNAL_MAP[$name])) {
 			$name = static::SIGNAL_MAP[$name];
-		} elseif(strncasecmp('pid:', $name, 4) === 0) {
+		} elseif (strncasecmp('pid:', $name, 4) === 0) {
 			if (is_numeric($pid = trim(substr($name, 4)))) {
 				return TProcessHelper::isRunning((int) $pid);
 			}
@@ -347,7 +347,7 @@ 
 	{
 		if (isset(static::SIGNAL_MAP[$name])) {
 			$name = static::SIGNAL_MAP[$name];
-		} elseif(strncasecmp('pid:', $name, 4) === 0) {
+		} elseif (strncasecmp('pid:', $name, 4) === 0) {
 			if (is_numeric($pid = trim(substr($name, 4)))) {
 				$pid = (int) $pid;
 				return isset(self::$_pidHandlers[$pid]) && self::$_pidHandlers[$pid]->getCount() > 0;
@@ -370,7 +370,7 @@ 
 	{
 		if (isset(static::SIGNAL_MAP[$name])) {
 			$name = static::SIGNAL_MAP[$name];
-		} elseif(strncasecmp('pid:', $name, 4) === 0) {
+		} elseif (strncasecmp('pid:', $name, 4) === 0) {
 			if (!is_numeric($pid = trim(substr($name, 4)))) {
 				throw new TInvalidOperationException('signalsdispatcher_bad_pid', $pid);
 			}
@@ -620,7 +620,7 @@ 
 			$callback = self::$_priorHandlers[SIGALRM][1];
 		}
 
-		foreach($alarmTime !== null ? [$alarmTime] : array_keys(static::$_alarms) as $time) {
+		foreach ($alarmTime !== null ? [$alarmTime] : array_keys(static::$_alarms) as $time) {
 			if (($key = array_search($callback, static::$_alarms[$time] ?? [], true)) !== false) {
 				unset(static::$_alarms[$time][$key]);
 				if (is_array(static::$_alarms[$time] ?? false)) {
@@ -661,7 +661,7 @@ 
 			$nextTime = null;
 			$startTime = time();
 			$signalParam->setAlarmTime($startTime);
-			foreach(static::$_alarms as $alarmTime => $alarms) {
+			foreach (static::$_alarms as $alarmTime => $alarms) {
 				if ($alarmTime <= $startTime) {
 					array_map(fn ($alarm) => $alarm($this, $signalParam), static::$_alarms[$alarmTime]);
 					unset(static::$_alarms[$alarmTime]);

framework/Util/Helpers/TProcessHelper.php

Spacing +4 added lines, -4 removed lines

@@ -161,7 +161,7 @@ 
 
 		if (TProcessHelper::isSystemWindows()) {
 			if (is_string($command)) {
-				$command = '"' . $command . '"';  //Windows, better command support
+				$command = '"' . $command . '"'; //Windows, better command support
 			}
 		}
 		return $command;
@@ -231,7 +231,7 @@ 
 			$output = shell_exec("wmic process where ProcessId={$pid} get priority");
 			preg_match('/^\s*Priority\s*\r?\n\s*(\d+)/m', $output, $matches);
 			if (isset($matches[1])) {
-				$priorityValues = [ // Map Windows Priority Numbers to Linux style Numbers
+				$priorityValues = [// Map Windows Priority Numbers to Linux style Numbers
 					TProcessWindowsPriority::Idle => static::WINDOWS_IDLE_PRIORITY,
 					TProcessWindowsPriority::BelowNormal => static::WINDOWS_BELOW_NORMAL_PRIORITY,
 					TProcessWindowsPriority::Normal => static::WINDOWS_NORMAL_PRIORITY,
@@ -263,7 +263,7 @@ 
 			$pid = getmypid();
 		}
 		if (static::isSystemWindows()) {
-			$priorityValues = [ // The priority cap to windows text priority.
+			$priorityValues = [// The priority cap to windows text priority.
 				-15 => TProcessWindowsPriorityName::Realtime,
 				-10 => TProcessWindowsPriorityName::HighPriority,
 				-5 => TProcessWindowsPriorityName::AboveNormal,
@@ -271,7 +271,7 @@ 
 				9 => TProcessWindowsPriorityName::BelowNormal,
 				PHP_INT_MAX => TProcessWindowsPriorityName::Idle,
 			];
-			foreach($priorityValues as $keyPriority => $priorityName) {
+			foreach ($priorityValues as $keyPriority => $priorityName) {
 				if ($priority <= $keyPriority) {
 					break;
 				}

framework/Util/Behaviors/TCaptureForkLog.php

Spacing +8 added lines, -8 removed lines

@@ -145,7 +145,7 @@ 
 			$logger->deleteLogs();
 			$logs = $logger->deleteProfileLogs();
 			$pid = getmypid();
-			foreach(array_keys($logs) as $key) { // Reset PROFILE_BEGIN to pid.
+			foreach (array_keys($logs) as $key) { // Reset PROFILE_BEGIN to pid.
 				$logs[$key][TLogger::LOG_LEVEL] &= ~TLogger::LOGGED;
 				$logs[$key][TLogger::LOG_PID] = $pid;
 			}
@@ -176,7 +176,7 @@ 
 		if (!$this->_parentConnections) {
 			return;
 		}
-		if($pid && !isset($this->_parentConnections[$pid])) {
+		if ($pid && !isset($this->_parentConnections[$pid])) {
 			return;
 		}
 
@@ -187,11 +187,11 @@ 
 		do {
 			$read = $connections;
 			if (stream_select($read, $write, $except, ($wait || count($childLogs)) ? 1 : 0, 0)) {
-				foreach($read as $pid => $socket) {
+				foreach ($read as $pid => $socket) {
 					$data = fread($socket, 8192);
 					do {
 						$iterate = false;
-						if($data !== false) {
+						if ($data !== false) {
 							if (array_key_exists($pid, $childLogs)) {
 								$childLogs[$pid][0] .= $data;
 							} else {
@@ -234,12 +234,12 @@ 
 					} while ($iterate);
 				}
 			}
-		} while(count($childLogs) || $wait && ($pid && isset($connections[$pid]) || $pid === null && $connections));
+		} while (count($childLogs) || $wait && ($pid && isset($connections[$pid]) || $pid === null && $connections));
 
 		if (!$completeLogs) {
 			return;
 		}
-		foreach(array_merge(...$completeLogs) as $pid => $logs) {
+		foreach (array_merge(...$completeLogs) as $pid => $logs) {
 			Prado::getLogger()->mergeLogs(unserialize($logs));
 		}
 	}
@@ -257,7 +257,7 @@ 
 			return;
 		}
 
-		if(!($logger instanceof TLogger)) {
+		if (!($logger instanceof TLogger)) {
 			$logger = Prado::getLogger();
 		}
 
@@ -294,7 +294,7 @@ 
 					$data = substr($data, $count);
 				}
 			}
-		} while($count !== false && strlen($data) > 0);
+		} while ($count !== false && strlen($data) > 0);
 
 		if ($final) {
 			stream_socket_shutdown($this->_childConnection, STREAM_SHUT_RDWR);

framework/Shell/Actions/TWebServerAction.php

Spacing +1 added lines, -1 removed lines

@@ -113,7 +113,7 @@
 	 */
 	public function getAddress(): string
 	{
-		if(!$this->_address) {
+		if (!$this->_address) {
 			if ($this->getIpv6()) {
 				if ($this->getAll()) {
 					return '[::0]';

framework/TComponent.php

Spacing +5 added lines, -5 removed lines

@@ -514,7 +514,7 @@ 
 		foreach ($classes as $class) {
 			if (isset(self::$_um[$class])) {
 				foreach (self::$_um[$class] as $name => $behavior) {
-					if(is_numeric($name)) {
+					if (is_numeric($name)) {
 						continue;
 					}
 					if (!array_key_exists($name, $classBehaviors)) {
@@ -789,7 +789,7 @@ 
 		}
 
 		if (isset(self::$_um[$lclass = strtolower(static::class)])) {
-			foreach(self::$_um[$lclass] as $pbehavior) {
+			foreach (self::$_um[$lclass] as $pbehavior) {
 				$class = $behavior = $pbehavior->getBehavior();
 				if (is_array($behavior)) {
 					$class = $behavior['class'];
@@ -1454,7 +1454,7 @@ 
 		$name = strtolower($name);
 		$responses = [];
 
-		if($param instanceof IEventParameter) {
+		if ($param instanceof IEventParameter) {
 			$param->setEventName($name);
 		}
 
@@ -1818,7 +1818,7 @@ 
 		$behaviorObject->setName($name);
 		$isClassBehavior = $behaviorObject instanceof IClassBehavior;
 		unset(self::$_um[$class][$name]);
-		if(empty(self::$_um[$class])) {
+		if (empty(self::$_um[$class])) {
 			unset(self::$_um[$class]);
 		}
 		$results = $behaviorObject->raiseEvent('fxDetachClassBehavior', null, $param);
@@ -1840,7 +1840,7 @@ 
 			return $this->_m[$behaviorname];
 		}
 		if ((class_exists($behaviorname, false) || interface_exists($behaviorname, false)) && $this->_m) {
-			foreach($this->_m->toArray() as $behavior) {
+			foreach ($this->_m->toArray() as $behavior) {
 				if ($behavior instanceof $behaviorname) {
 					return $behavior;
 				}

framework/Util/TDbLogRoute.php

Spacing +7 added lines, -7 removed lines

@@ -126,7 +126,7 @@ 
 			$command->bindValue(':category', $log[TLogger::LOG_CATEGORY]);
 			$command->bindValue(':prefix', $this->getLogPrefix($log));
 			$command->bindValue(':logtime', sprintf('%F', $log[TLogger::LOG_TIME]));
-			if(!$command->execute()) {
+			if (!$command->execute()) {
 				throw new TLogException('dblogroute_insert_failed', $this->_logTable);
 			}
 		}
@@ -146,7 +146,7 @@ 
 	 * @return string The where clause for the various SQL statements.
 	 * @since 4.3.0
 	 */
-	protected function getLogWhere(?int $level, null|string|array $categories, ?float $minTime, ?float $maxTime, &$values): string
+	protected function getLogWhere(?int $level, null | string | array $categories, ?float $minTime, ?float $maxTime, &$values): string
 	{
 		$where = '';
 		$values = [];
@@ -155,12 +155,12 @@ 
 			$values[':level'] = $level;
 		}
 		if ($categories !== null) {
-			if(is_string($categories)) {
+			if (is_string($categories)) {
 				$categories = array_map('trim', explode(',', $categories));
 			}
 			$i = 0;
 			$or = '';
-			foreach($categories as $category) {
+			foreach ($categories as $category) {
 				$c = $category[0] ?? 0;
 				if ($c === '!' || $c === '~') {
 					if ($where) {
@@ -214,7 +214,7 @@ 
 	 * @return string The where clause for the various SQL statements..
 	 * @since 4.3.0
 	 */
-	public function getDBLogCount(?int $level = null, null|string|array $categories = null, ?float $minTime = null, ?float $maxTime = null)
+	public function getDBLogCount(?int $level = null, null | string | array $categories = null, ?float $minTime = null, ?float $maxTime = null)
 	{
 		$values = [];
 		$where = $this->getLogWhere($level, $categories, $minTime, $maxTime, $values);
@@ -238,7 +238,7 @@ 
 	 * @return \Prado\Data\TDbDataReader the logs from the database.
 	 * @since 4.3.0
 	 */
-	public function getDBLogs(?int $level = null, null|string|array $categories = null, ?float $minTime = null, ?float $maxTime = null, string $order = '', string $limit = '')
+	public function getDBLogs(?int $level = null, null | string | array $categories = null, ?float $minTime = null, ?float $maxTime = null, string $order = '', string $limit = '')
 	{
 		$values = [];
 		if ($order) {
@@ -266,7 +266,7 @@ 
 	 * @return int the number of logs in the database.
 	 * @since 4.3.0
 	 */
-	public function deleteDBLog(?int $level = null, null|string|array $categories = null, ?float $minTime = null, ?float $maxTime = null)
+	public function deleteDBLog(?int $level = null, null | string | array $categories = null, ?float $minTime = null, ?float $maxTime = null)
 	{
 		$values = [];
 		$where = $this->getLogWhere($level, $categories, $minTime, $maxTime, $values);

framework/Util/TLogger.php

Spacing +11 added lines, -11 removed lines

@@ -142,8 +142,8 @@ 
 	 */
 	public function __construct(bool $flushShutdown = true)
 	{
-		if($flushShutdown) {
-			register_shutdown_function(function () {
+		if ($flushShutdown) {
+			register_shutdown_function(function() {
 				$this->onFlushLogs();
 				// flush any logs in the shutdown function.
 				register_shutdown_function([$this, 'onFlushLogs'], $this, true);
@@ -214,7 +214,7 @@ 
 	 * @return int The number of logs.
 	 * @since 4.3.0
 	 */
-	public function getLogCount(null|bool|int $selector = null): int
+	public function getLogCount(null | bool | int $selector = null): int
 	{
 		if ($selector === null) {// logs @TLogRoute::processLogs after removing logged elements.
 			return count($this->_logs) + $this->_profileLogsCount;
@@ -409,7 +409,7 @@ 
 			return;
 		}
 
-		if(is_bool($sender)) {
+		if (is_bool($sender)) {
 			$final = $sender;
 			$sender = null;
 		}
@@ -424,14 +424,14 @@ 
 		$this->deleteLogs();
 		$this->_flushing = false;
 		if (count($this->_flushingLog)) {
-			foreach($this->_flushingLog as $log) {
+			foreach ($this->_flushingLog as $log) {
 				$this->addLog($log, false); // $final = false to stop any possible recursion w/ low flushCount.
 			}
 		}
 		$this->_flushingLog = null;
 
 		$this->_profileLogsCount = 0;
-		foreach(array_keys($this->_profileLogs) as $key) {
+		foreach (array_keys($this->_profileLogs) as $key) {
 			$this->_profileLogs[$key][static::LOG_LEVEL] |= static::LOGGED;
 		}
 	}
@@ -474,7 +474,7 @@ 
 	 *   [6] => traces, when configured; null when absent
 	 *   [7] => process id)
 	 */
-	public function getLogs(?int $levels = null, null|array|string $categories = null, null|array|string $controls = null, null|int|float $timestamp = null, ?int $pid = null)
+	public function getLogs(?int $levels = null, null | array | string $categories = null, null | array | string $controls = null, null | int | float $timestamp = null, ?int $pid = null)
 	{
 		$this->_levels = $levels;
 		if (!empty($categories) && !is_array($categories)) {
@@ -523,7 +523,7 @@ 
 	public function mergeLogs(array $logs)
 	{
 		$count = count($logs);
-		foreach($logs as $log) {
+		foreach ($logs as $log) {
 			$log[static::LOG_LEVEL] &= ~TLogger::LOGGED;
 			$this->addLog($log, !(--$count));
 		}
@@ -556,7 +556,7 @@ 
 	 * @param ?int $pid
 	 * @return array The logs being delete are returned.
 	 */
-	public function deleteLogs(?int $levels = null, null|string|array $categories = null, null|string|array $controls = null, null|int|float $timestamp = null, ?int $pid = null): array
+	public function deleteLogs(?int $levels = null, null | string | array $categories = null, null | string | array $controls = null, null | int | float $timestamp = null, ?int $pid = null): array
 	{
 		$this->_levels = $levels;
 		if (!empty($categories) && !is_array($categories)) {
@@ -640,7 +640,7 @@ 
 			}
 			$c = $category[0] ?? 0;
 			if ($c === '!' || $c === '~') {
-				if(!$exclude) {
+				if (!$exclude) {
 					$category = substr($category, 1);
 					if ($log[static::LOG_CATEGORY] === $category || str_ends_with($category, '*') && strpos($log[static::LOG_CATEGORY], rtrim($category, '*')) === 0) {
 						$exclude = true;
@@ -697,7 +697,7 @@ 
 			}
 			$c = $control[0] ?? 0;
 			if ($c === '!' || $c === '~') {
-				if(!$exclude) {
+				if (!$exclude) {
 					$control = substr($control, 1);
 					if ($log[static::LOG_CONTROL] === $control || str_ends_with($control, '*') && strpos($log[static::LOG_CONTROL], rtrim($control, '*')) === 0) {
 						$exclude = true;