| Total Complexity | 102 | 
| Total Lines | 632 | 
| Duplicated Lines | 0 % | 
| Changes | 4 | ||
| Bugs | 1 | Features | 0 | 
Complex classes like TCronModule often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes.
Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.
While breaking up the class, it is a good idea to analyze how other classes use TCronModule, and based on these observations, apply Extract Interface, too.
| 1 | <?php  | 
            ||
| 70 | class TCronModule extends \Prado\TModule implements IPermissions  | 
            ||
| 71 | { | 
            ||
| 72 | /** The behavior name for the Shell Log behavior */  | 
            ||
| 73 | public const SHELL_LOG_BEHAVIOR = 'shellLog';  | 
            ||
| 74 | |||
| 75 | public const TASK_KEY = 'task';  | 
            ||
| 76 | |||
| 77 | public const SCHEDULE_KEY = 'schedule';  | 
            ||
| 78 | |||
| 79 | public const NAME_KEY = 'name';  | 
            ||
| 80 | |||
| 81 | public const USERNAME_KEY = 'username';  | 
            ||
| 82 | |||
| 83 | /** Key to global state of the last time SystemCron was run */  | 
            ||
| 84 | public const LAST_CRON_TIME = 'prado:cron:lastcron';  | 
            ||
| 85 | |||
| 86 | /** Key to global state of each task, lastExecTime and ProcessCount */  | 
            ||
| 87 | public const TASKS_INFO = 'prado:cron:tasksinfo';  | 
            ||
| 88 | |||
| 89 | /** The name of the cron user */  | 
            ||
| 90 | public const DEFAULT_CRON_USER = 'cron';  | 
            ||
| 91 | |||
| 92 | /** The separator for TCronMethodTask */  | 
            ||
| 93 | public const METHOD_SEPARATOR = '->';  | 
            ||
| 94 | |||
| 95 | /** The permission for the cron shell */  | 
            ||
| 96 | public const PERM_CRON_SHELL = 'cron_shell';  | 
            ||
| 97 | |||
| 98 | /** @var bool if the module has been initialized */  | 
            ||
| 99 | protected $_initialized = false;  | 
            ||
| 100 | |||
| 101 | /** @var IUserManager user manager instance */  | 
            ||
| 102 | private $_userManager;  | 
            ||
| 103 | |||
| 104 | /** @var TCronTaskInfo[] The info for tasks in the system. */  | 
            ||
| 105 | private $_tasksInfo;  | 
            ||
| 106 | |||
| 107 | /** @var bool whether or not the $_tasks is properties or TCronTask */  | 
            ||
| 108 | private $_tasksInstanced = false;  | 
            ||
| 109 | |||
| 110 | /** @var array[]|TCronTask[] the tasks */  | 
            ||
| 111 | private $_tasks = [];  | 
            ||
| 112 | |||
| 113 | /** @var string The user Id of the tasks without users */  | 
            ||
| 114 | private $_defaultUserName = self::DEFAULT_CRON_USER;  | 
            ||
| 115 | |||
| 116 | /** @var bool enable cron on requests, default false */  | 
            ||
| 117 | private $_enableRequestCron = false;  | 
            ||
| 118 | |||
| 119 | /** @var numeric probability that a request cron will trigger [0.0 to 100.0], default 1.0 (for 1%) */  | 
            ||
| 
                                                                                                    
                        
                         | 
                |||
| 120 | private $_requestCronProbability = 1.0;  | 
            ||
| 121 | |||
| 122 | /** @var null|bool is the app running in cron shell mode or not, or null for auto-detect */  | 
            ||
| 123 | private $_inCronShell;  | 
            ||
| 124 | |||
| 125 | /** @var string the cli class to instance for CLI command line actions; this changes for TDbCronModule */  | 
            ||
| 126 | protected $_shellClass = \Prado\Util\Cron\TShellCronAction::class;  | 
            ||
| 127 | |||
| 128 | /** @var array[] any additional tasks to install from properties */  | 
            ||
| 129 | private $_additionalCronTasks;  | 
            ||
| 130 | |||
| 131 | /**  | 
            ||
| 132 | * Initializes the module. Read the configuration, installs Shell Actions,  | 
            ||
| 133 | * should Request cron be activated.  | 
            ||
| 134 | * @param array|\Prado\Xml\TXmlElement $config  | 
            ||
| 135 | * @throws TConfigurationException when the user manage doesn't exist or is invalid  | 
            ||
| 136 | */  | 
            ||
| 137 | public function init($config)  | 
            ||
| 138 | 	{ | 
            ||
| 139 | $app = $this->getApplication();  | 
            ||
| 140 | |||
| 141 | //Get the IUserManager module from the string  | 
            ||
| 142 | 		if (is_string($this->_userManager)) { | 
            ||
| 143 | 			if (($users = $app->getModule($this->_userManager)) === null) { | 
            ||
| 144 | 				throw new TConfigurationException('cron_usermanager_nonexistent', $this->_userManager); | 
            ||
| 145 | }  | 
            ||
| 146 | 			if (!($users instanceof IUserManager)) { | 
            ||
| 147 | 				throw new TConfigurationException('cron_usermanager_invalid', $this->_userManager); | 
            ||
| 148 | }  | 
            ||
| 149 | $this->_userManager = $users;  | 
            ||
| 150 | }  | 
            ||
| 151 | |||
| 152 | // Otherwise manually look for the IUserManager  | 
            ||
| 153 | 		if ($this->_userManager === null) { | 
            ||
| 154 | $users = $app->getModulesByType(\Prado\Security\IUserManager::class);  | 
            ||
| 155 | 			foreach ($users as $id => $module) { | 
            ||
| 156 | $this->_userManager = $app->getModule($id);  | 
            ||
| 157 | break;  | 
            ||
| 158 | }  | 
            ||
| 159 | }  | 
            ||
| 160 | $this->_tasksInstanced = false;  | 
            ||
| 161 | |||
| 162 | //read config tasks and schedule  | 
            ||
| 163 | $this->readConfiguration($config);  | 
            ||
| 164 | |||
| 165 | //Read additional Config from Property  | 
            ||
| 166 | $this->readConfiguration($this->_additionalCronTasks);  | 
            ||
| 167 | 		$app->attachEventHandler('onAuthenticationComplete', [$this, 'registerShellAction']); | 
            ||
| 168 | |||
| 169 | 		if ($app instanceof \Prado\Shell\TShellApplication) { | 
            ||
| 170 | 			$app->registerOption('cron', [$this, 'setInCronShell'], 'If run in crontab, set this flag.  It limits tasks to the current minute, default auto-detect'); | 
            ||
| 171 | 			$app->registerOptionAlias('c', 'cron'); | 
            ||
| 172 | }  | 
            ||
| 173 | |||
| 174 | 		if (php_sapi_name() !== 'cli' && $this->getEnableRequestCron()) { | 
            ||
| 175 | 			if (100.0 * ((float) (mt_rand()) / (float) (mt_getrandmax())) <= $this->getRequestCronProbability()) { | 
            ||
| 176 | 				$app->attachEventHandler('OnEndRequest', [$this, 'processPendingTasks'], 20); | 
            ||
| 177 | }  | 
            ||
| 178 | }  | 
            ||
| 179 | $this->_initialized = true;  | 
            ||
| 180 | parent::init($config);  | 
            ||
| 181 | }  | 
            ||
| 182 | |||
| 183 | /**  | 
            ||
| 184 | * @param \Prado\Security\Permissions\TPermissionsManager $manager  | 
            ||
| 185 | * @return \Prado\Security\Permissions\TPermissionEvent[]  | 
            ||
| 186 | */  | 
            ||
| 187 | public function getPermissions($manager)  | 
            ||
| 188 | 	{ | 
            ||
| 189 | return [  | 
            ||
| 190 | new TPermissionEvent(static::PERM_CRON_SHELL, 'Activates cron shell commands.', 'dyRegisterShellAction'),  | 
            ||
| 191 | ];  | 
            ||
| 192 | }  | 
            ||
| 193 | |||
| 194 | /**  | 
            ||
| 195 | * This reads the configuration and stores the specified tasks, for lazy loading, until needed.  | 
            ||
| 196 | * @param array|\Prado\Xml\TXmlElement $config the settings for cron  | 
            ||
| 197 | * @throws TConfigurationException when a PHP configuration is not an array or two jobs have the same name.  | 
            ||
| 198 | */  | 
            ||
| 199 | protected function readConfiguration($config)  | 
            ||
| 200 | 	{ | 
            ||
| 201 | $isXml = false;  | 
            ||
| 202 | 		if (!$config) { | 
            ||
| 203 | return;  | 
            ||
| 204 | }  | 
            ||
| 205 | 		if ($config instanceof \Prado\Xml\TXmlElement) { | 
            ||
| 206 | $isXml = true;  | 
            ||
| 207 | 			$config = $config->getElementsByTagName('job'); | 
            ||
| 208 | 		} elseif (is_array($config) && isset($config['jobs'])) { | 
            ||
| 209 | $config = $config['jobs'];  | 
            ||
| 210 | }  | 
            ||
| 211 | 		foreach ($config as $properties) { | 
            ||
| 212 | 			if ($isXml) { | 
            ||
| 213 | $properties = array_change_key_case($properties->getAttributes()->toArray());  | 
            ||
| 214 | 			} else { | 
            ||
| 215 | 				if (!is_array($properties)) { | 
            ||
| 216 | 					throw new TConfigurationException('cron_task_as_array_required'); | 
            ||
| 217 | }  | 
            ||
| 218 | }  | 
            ||
| 219 | 			if (!($properties[self::NAME_KEY] ?? null)) { | 
            ||
| 220 | $class = $properties[self::TASK_KEY] ?? '';  | 
            ||
| 221 | $schedule = $properties[self::SCHEDULE_KEY] ?? '';  | 
            ||
| 222 | $name = $properties[self::NAME_KEY] = substr(md5($schedule . $class), 0, 7);  | 
            ||
| 223 | 			} else { | 
            ||
| 224 | $name = $properties[self::NAME_KEY];  | 
            ||
| 225 | }  | 
            ||
| 226 | 			if (isset($this->_tasks[$name])) { | 
            ||
| 227 | 				throw new TConfigurationException('cron_duplicate_task_name', $name); | 
            ||
| 228 | }  | 
            ||
| 229 | $this->validateTask($properties);  | 
            ||
| 230 | $this->_tasks[$name] = $properties;  | 
            ||
| 231 | }  | 
            ||
| 232 | }  | 
            ||
| 233 | |||
| 234 | /**  | 
            ||
| 235 | * Validates that schedule and task are present.  | 
            ||
| 236 | * Subclasses overload this method to add their own validation.  | 
            ||
| 237 | * @param array $properties the task as an array of properties  | 
            ||
| 238 | * @throws TConfigurationException when the schedule or task doesn't exist  | 
            ||
| 239 | */  | 
            ||
| 240 | public function validateTask($properties)  | 
            ||
| 241 | 	{ | 
            ||
| 242 | $schedule = $properties[self::SCHEDULE_KEY] ?? null;  | 
            ||
| 243 | $task = $properties[self::TASK_KEY] ?? null;  | 
            ||
| 244 | 		if (!$schedule) { | 
            ||
| 245 | 			throw new TConfigurationException('cron_schedule_required'); | 
            ||
| 246 | }  | 
            ||
| 247 | 		if (!$task) { | 
            ||
| 248 | 			throw new TConfigurationException('cron_task_required'); | 
            ||
| 249 | }  | 
            ||
| 250 | }  | 
            ||
| 251 | |||
| 252 | /**  | 
            ||
| 253 | * @param object $sender sender of this event handler  | 
            ||
| 254 | * @param null|mixed $param parameter for the event  | 
            ||
| 255 | */  | 
            ||
| 256 | public function registerShellAction($sender, $param)  | 
            ||
| 257 | 	{ | 
            ||
| 258 | 		if ($this->dyRegisterShellAction(false) !== true && ($app = $this->getApplication()) instanceof \Prado\Shell\TShellApplication) { | 
            ||
| 259 | $app->addShellActionClass(['class' => $this->_shellClass, 'CronModule' => $this]);  | 
            ||
| 260 | }  | 
            ||
| 261 | }  | 
            ||
| 262 | |||
| 263 | /**  | 
            ||
| 264 | * makes the tasks from the configuration array into task objects.  | 
            ||
| 265 | * @return \Prado\Util\Cron\TCronTask[]  | 
            ||
| 266 | */  | 
            ||
| 267 | protected function ensureTasks()  | 
            ||
| 268 | 	{ | 
            ||
| 269 | 		if (!$this->_tasksInstanced) { | 
            ||
| 270 | 			foreach ($this->_tasks as $properties) { | 
            ||
| 271 | $name = $properties[self::NAME_KEY];  | 
            ||
| 272 | $task = $properties[self::TASK_KEY];  | 
            ||
| 273 | unset($properties[self::NAME_KEY]);  | 
            ||
| 274 | unset($properties[self::TASK_KEY]);  | 
            ||
| 275 | |||
| 276 | $task = $this->instanceTask($task);  | 
            ||
| 277 | |||
| 278 | $task->setName($name);  | 
            ||
| 279 | 				foreach ($properties as $key => $value) { | 
            ||
| 280 | $task->$key = $value;  | 
            ||
| 281 | }  | 
            ||
| 282 | $this->setPersistentData($name, $task);  | 
            ||
| 283 | $this->_tasks[$name] = $task;  | 
            ||
| 284 | }  | 
            ||
| 285 | $this->_tasksInstanced = true;  | 
            ||
| 286 | }  | 
            ||
| 287 | return $this->_tasks;  | 
            ||
| 288 | }  | 
            ||
| 289 | |||
| 290 | /**  | 
            ||
| 291 | * This lazy loads the tasks from configuration array to instance.  | 
            ||
| 292 | 	 * This calls {@see ensureTasks} to get the tasks and their persistent data. | 
            ||
| 293 | * @return \Prado\Util\Cron\TCronTask[] currently active cron tasks  | 
            ||
| 294 | */  | 
            ||
| 295 | public function getTasks()  | 
            ||
| 296 | 	{ | 
            ||
| 297 | $this->ensureTasks();  | 
            ||
| 298 | return $this->_tasks;  | 
            ||
| 299 | }  | 
            ||
| 300 | |||
| 301 | /**  | 
            ||
| 302 | * These are the tasks specified in the configuration and getAdditionalCronTasks  | 
            ||
| 303 | 	 * until {@see ensureTasks} is called. | 
            ||
| 304 | * @return array[]|TCronTask[] currently active cron tasks  | 
            ||
| 305 | */  | 
            ||
| 306 | public function getRawTasks()  | 
            ||
| 307 | 	{ | 
            ||
| 308 | return $this->_tasks;  | 
            ||
| 309 | }  | 
            ||
| 310 | |||
| 311 | /**  | 
            ||
| 312 | * This lazy loads the tasks.  | 
            ||
| 313 | * @param string $name  | 
            ||
| 314 | * @return TCronTask cron tasks with a specific name  | 
            ||
| 315 | */  | 
            ||
| 316 | public function getTask($name)  | 
            ||
| 317 | 	{ | 
            ||
| 318 | $tasks = $this->getTasks();  | 
            ||
| 319 | return $tasks[$name] ?? null;  | 
            ||
| 320 | }  | 
            ||
| 321 | |||
| 322 | /**  | 
            ||
| 323 | * .  | 
            ||
| 324 | 	 * @param string $taskExec the class name or "module->method('param1')" to place | 
            ||
| 325 | 	 * into a {@see \Prado\Util\Cron\TCronMethodTask}. | 
            ||
| 326 | * @return TCronTask the instance of $taskExec  | 
            ||
| 327 | */  | 
            ||
| 328 | public function instanceTask($taskExec)  | 
            ||
| 329 | 	{ | 
            ||
| 330 | 		if (($pos = strpos($taskExec, self::METHOD_SEPARATOR)) !== false) { | 
            ||
| 331 | $module = substr($taskExec, 0, $pos);  | 
            ||
| 332 | $method = substr($taskExec, $pos + 2); //String Length of self::METHOD_SEPARATOR  | 
            ||
| 333 | $task = new TCronMethodTask($module, $method);  | 
            ||
| 334 | 		} else { | 
            ||
| 335 | $task = Prado::createComponent($taskExec);  | 
            ||
| 336 | 			if (!$task instanceof \Prado\Util\Cron\TCronTask) { | 
            ||
| 337 | 				throw new TInvalidDataTypeException("cron_not_a_crontask", $taskExec); | 
            ||
| 338 | }  | 
            ||
| 339 | }  | 
            ||
| 340 | return $task;  | 
            ||
| 341 | }  | 
            ||
| 342 | |||
| 343 | /**  | 
            ||
| 344 | * when instancing and then loading the tasks, this sets the persisting data of  | 
            ||
| 345 | * the task from the global state. When there is no instance in the global state,  | 
            ||
| 346 | * the lastExecTime is initialized.  | 
            ||
| 347 | * @param string $name name of the task.  | 
            ||
| 348 | * @param TCronTask $task the task object.  | 
            ||
| 349 | * @return bool updated the taskInfo with persistent data.  | 
            ||
| 350 | */  | 
            ||
| 351 | protected function setPersistentData($name, $task)  | 
            ||
| 352 | 	{ | 
            ||
| 353 | $tasksInfo = $this->getApplication()->getGlobalState(self::TASKS_INFO, []);  | 
            ||
| 354 | 		if (isset($tasksInfo[$name])) { | 
            ||
| 355 | $task->setLastExecTime($tasksInfo[$name]['lastExecTime']);  | 
            ||
| 356 | $task->setProcessCount($tasksInfo[$name]['processCount']);  | 
            ||
| 357 | return true;  | 
            ||
| 358 | 		} else { | 
            ||
| 359 | $task->resetTaskLastExecTime();  | 
            ||
| 360 | $task->setProcessCount(0);  | 
            ||
| 361 | $tasksInfo[$name]['lastExecTime'] = $task->getLastExecTime();  | 
            ||
| 362 | $tasksInfo[$name]['processCount'] = 0;  | 
            ||
| 363 | $this->getApplication()->setGlobalState(self::TASKS_INFO, $tasksInfo, []);  | 
            ||
| 364 | }  | 
            ||
| 365 | return false;  | 
            ||
| 366 | }  | 
            ||
| 367 | |||
| 368 | /**  | 
            ||
| 369 | * @return TCronTask[] the tasks that are pending.  | 
            ||
| 370 | */  | 
            ||
| 371 | public function getPendingTasks()  | 
            ||
| 372 | 	{ | 
            ||
| 373 | $pendingtasks = [];  | 
            ||
| 374 | 		foreach ($this->getTasks() as $name => $task) { | 
            ||
| 375 | 			if ($task->getIsPending()) { | 
            ||
| 376 | $pendingtasks[$name] = $task;  | 
            ||
| 377 | }  | 
            ||
| 378 | }  | 
            ||
| 379 | return $pendingtasks;  | 
            ||
| 380 | }  | 
            ||
| 381 | |||
| 382 | /**  | 
            ||
| 383 | * Filters the Tasks for a specific class.  | 
            ||
| 384 | * @param string $type  | 
            ||
| 385 | * @return TCronTask[] the tasks of $type  | 
            ||
| 386 | */  | 
            ||
| 387 | public function getTasksByType($type)  | 
            ||
| 388 | 	{ | 
            ||
| 389 | $matches = [];  | 
            ||
| 390 | 		foreach ($this->getTasks() as $name => $task) { | 
            ||
| 391 | 			if ($task->isa($type)) { | 
            ||
| 392 | $matches[$name] = $task;  | 
            ||
| 393 | }  | 
            ||
| 394 | }  | 
            ||
| 395 | return $matches;  | 
            ||
| 396 | }  | 
            ||
| 397 | |||
| 398 | /**  | 
            ||
| 399 | * processPendingTasks executes pending tasks  | 
            ||
| 400 | * @return int number of tasks run that were pending  | 
            ||
| 401 | */  | 
            ||
| 402 | public function processPendingTasks()  | 
            ||
| 403 | 	{ | 
            ||
| 404 | $inCronTab = (($inCron = $this->getInCronShell()) !== null) ? $inCron : TShellApplication::detectCronTabShell();  | 
            ||
| 405 | $this->filterStaleTasks();  | 
            ||
| 406 | $pendingTasks = $this->getPendingTasks();  | 
            ||
| 407 | $numtasks = count($pendingTasks);  | 
            ||
| 408 | $startMinute = floor(time() / 60);  | 
            ||
| 409 | |||
| 410 | $this->logCron($numtasks);  | 
            ||
| 411 | 		if ($numtasks) { | 
            ||
| 412 | 			foreach ($pendingTasks as $key => $task) { | 
            ||
| 413 | 				if ($inCronTab && $startMinute != floor(time() / 60)) { | 
            ||
| 414 | break;  | 
            ||
| 415 | }  | 
            ||
| 416 | $this->runTask($task);  | 
            ||
| 417 | }  | 
            ||
| 418 | }  | 
            ||
| 419 | |||
| 420 | return $numtasks;  | 
            ||
| 421 | }  | 
            ||
| 422 | |||
| 423 | /**  | 
            ||
| 424 | * @param int $numtasks number of tasks being processed  | 
            ||
| 425 | */  | 
            ||
| 426 | protected function logCron($numtasks)  | 
            ||
| 427 | 	{ | 
            ||
| 428 | 		Prado::log("Processing {$numtasks} Cron Tasks", TLogger::INFO, TCronModule::class); | 
            ||
| 429 | $this->dyLogCron($numtasks);  | 
            ||
| 430 | $this->setLastCronTime(microtime(true));  | 
            ||
| 431 | }  | 
            ||
| 432 | |||
| 433 | /**  | 
            ||
| 434 | * This removes any stale tasks in the global state.  | 
            ||
| 435 | */  | 
            ||
| 436 | protected function filterStaleTasks()  | 
            ||
| 437 | 	{ | 
            ||
| 438 | // Filter out any stale tasks in the global state that aren't in config  | 
            ||
| 439 | $app = $this->getApplication();  | 
            ||
| 440 | $tasksInfo = $app->getGlobalState(self::TASKS_INFO, []);  | 
            ||
| 441 | $count = count($tasksInfo);  | 
            ||
| 442 | $tasksInfo = array_intersect_key($tasksInfo, $this->_tasks);  | 
            ||
| 443 | 		if ($count != count($tasksInfo)) { | 
            ||
| 444 | $app->setGlobalState(self::TASKS_INFO, $tasksInfo, []);  | 
            ||
| 445 | }  | 
            ||
| 446 | }  | 
            ||
| 447 | |||
| 448 | /**  | 
            ||
| 449 | * Runs a specific task. Sets the user to the Task user or the cron module  | 
            ||
| 450 | 	 * {@see getDefaultUserName}. | 
            ||
| 451 | * @param \Prado\Util\Cron\TCronTask $task the task to run.  | 
            ||
| 452 | */  | 
            ||
| 453 | public function runTask($task)  | 
            ||
| 454 | 	{ | 
            ||
| 455 | $app = $this->getApplication();  | 
            ||
| 456 | $users = $this->getUserManager();  | 
            ||
| 457 | $defaultUsername = $username = $this->getDefaultUserName();  | 
            ||
| 458 | $restore_user = $app->getUser();  | 
            ||
| 459 | $user = null;  | 
            ||
| 460 | |||
| 461 | 		if ($users) { | 
            ||
| 462 | 			if ($nusername = $task->getUserName()) { | 
            ||
| 463 | $username = $nusername;  | 
            ||
| 464 | }  | 
            ||
| 465 | $user = $users->getUser($username);  | 
            ||
| 466 | 			if (!$user && $username !== $defaultUsername) { | 
            ||
| 467 | $user = $users->getUser($username = $defaultUsername);  | 
            ||
| 468 | }  | 
            ||
| 469 | |||
| 470 | 			if ($user) { | 
            ||
| 471 | $app->setUser($user);  | 
            ||
| 472 | 			} elseif ($restore_user) { | 
            ||
| 473 | $user = clone $restore_user;  | 
            ||
| 474 | $user->setIsGuest(true);  | 
            ||
| 475 | $app->setUser($user);  | 
            ||
| 476 | }  | 
            ||
| 477 | }  | 
            ||
| 478 | |||
| 479 | $this->logCronTask($task, $username);  | 
            ||
| 480 | $this->updateTaskInfo($task);  | 
            ||
| 481 | $task->execute($this);  | 
            ||
| 482 | $this->logCronTaskEnd($task);  | 
            ||
| 483 | |||
| 484 | 		if ($user) { | 
            ||
| 485 | 			if ($restore_user) { | 
            ||
| 486 | $app->setUser($restore_user);  | 
            ||
| 487 | 			} else { | 
            ||
| 488 | $user->setIsGuest(true);  | 
            ||
| 489 | }  | 
            ||
| 490 | }  | 
            ||
| 491 | }  | 
            ||
| 492 | |||
| 493 | /**  | 
            ||
| 494 | * Logs the cron task being run with the system log and output on cli  | 
            ||
| 495 | * @param TCronTask $task  | 
            ||
| 496 | * @param string $username the user the task is running under.  | 
            ||
| 497 | */  | 
            ||
| 498 | protected function logCronTask($task, $username)  | 
            ||
| 499 | 	{ | 
            ||
| 500 | 		Prado::log('Running cron task (' . $task->getName() . ', ' . $username . ')', TLogger::INFO, TCronModule::class); | 
            ||
| 501 | $this->dyLogCronTask($task, $username);  | 
            ||
| 502 | }  | 
            ||
| 503 | |||
| 504 | /**  | 
            ||
| 505 | * sets the lastExecTime to now and increments the processCount. This saves  | 
            ||
| 506 | * the new data to the global state.  | 
            ||
| 507 | * @param TCronTask $task  | 
            ||
| 508 | */  | 
            ||
| 509 | protected function updateTaskInfo($task)  | 
            ||
| 510 | 	{ | 
            ||
| 511 | $tasksInfo = $this->getApplication()->getGlobalState(self::TASKS_INFO, []);  | 
            ||
| 512 | $name = $task->getName();  | 
            ||
| 513 | $time = $tasksInfo[$name]['lastExecTime'] = (int) microtime(true);  | 
            ||
| 514 | $count = $tasksInfo[$name]['processCount'] = $task->getProcessCount() + 1;  | 
            ||
| 515 | $task->setProcessCount($count);  | 
            ||
| 516 | $task->setLastExecTime($time);  | 
            ||
| 517 | |||
| 518 | $this->getApplication()->setGlobalState(self::TASKS_INFO, $tasksInfo, [], true);  | 
            ||
| 519 | }  | 
            ||
| 520 | |||
| 521 | /**  | 
            ||
| 522 | * Logs the end of the task.  | 
            ||
| 523 | * @param TCronTask $task  | 
            ||
| 524 | */  | 
            ||
| 525 | protected function logCronTaskEnd($task)  | 
            ||
| 526 | 	{ | 
            ||
| 527 | 		Prado::log('Ending cron task (' . $task->getName() . ', ' . $task->getTask() . ')', TLogger::INFO, TCronModule::class); | 
            ||
| 528 | $this->dyLogCronTaskEnd($task);  | 
            ||
| 529 | }  | 
            ||
| 530 | |||
| 531 | /**  | 
            ||
| 532 | * @return float time that cron last was last run  | 
            ||
| 533 | */  | 
            ||
| 534 | public function getLastCronTime()  | 
            ||
| 535 | 	{ | 
            ||
| 536 | return $this->getApplication()->getGlobalState(self::LAST_CRON_TIME, 0);  | 
            ||
| 537 | }  | 
            ||
| 538 | |||
| 539 | /**  | 
            ||
| 540 | * @param float $time time that cron was last run  | 
            ||
| 541 | */  | 
            ||
| 542 | public function setLastCronTime($time)  | 
            ||
| 543 | 	{ | 
            ||
| 544 | $this->getApplication()->setGlobalState(self::LAST_CRON_TIME, TPropertyValue::ensureFloat($time), 0, true);  | 
            ||
| 545 | }  | 
            ||
| 546 | |||
| 547 | /**  | 
            ||
| 548 | * Objects should handle fxGetCronTasks($sender, $param)  | 
            ||
| 549 | * @param bool $forceupdate if true, ignores the caching  | 
            ||
| 550 | * @return \Prado\Util\Cron\TCronTaskInfo[]  | 
            ||
| 551 | */  | 
            ||
| 552 | public function getTaskInfos($forceupdate = false)  | 
            ||
| 553 | 	{ | 
            ||
| 554 | 		if (!$this->_tasksInfo || $forceupdate) { | 
            ||
| 555 | 			$this->_tasksInfo = $this->raiseEvent('fxGetCronTaskInfos', $this, null); | 
            ||
| 556 | }  | 
            ||
| 557 | return $this->_tasksInfo;  | 
            ||
| 558 | }  | 
            ||
| 559 | |||
| 560 | /**  | 
            ||
| 561 | * @return string the default user id of Tasks without users ids  | 
            ||
| 562 | */  | 
            ||
| 563 | public function getDefaultUserName()  | 
            ||
| 564 | 	{ | 
            ||
| 565 | return $this->_defaultUserName;  | 
            ||
| 566 | }  | 
            ||
| 567 | |||
| 568 | /**  | 
            ||
| 569 | * @param string $id the default user id of Tasks without users ids  | 
            ||
| 570 | * @throws TInvalidOperationException if the module has been initialized  | 
            ||
| 571 | */  | 
            ||
| 572 | public function setDefaultUserName($id)  | 
            ||
| 573 | 	{ | 
            ||
| 574 | 		if ($this->_initialized) { | 
            ||
| 575 | 			throw new TInvalidOperationException('cron_property_unchangeable', 'DefaultUserName'); | 
            ||
| 576 | }  | 
            ||
| 577 | $this->_defaultUserName = TPropertyValue::ensureString($id);  | 
            ||
| 578 | }  | 
            ||
| 579 | |||
| 580 | /**  | 
            ||
| 581 | * @return null|IUserManager user manager instance  | 
            ||
| 582 | */  | 
            ||
| 583 | public function getUserManager()  | 
            ||
| 584 | 	{ | 
            ||
| 585 | return $this->_userManager;  | 
            ||
| 586 | }  | 
            ||
| 587 | |||
| 588 | /**  | 
            ||
| 589 | * @param null|IUserManager|string $provider the user manager module ID or the user manager object  | 
            ||
| 590 | * @throws TInvalidOperationException if the module has been initialized  | 
            ||
| 591 | * @throws TConfigurationException if the user manager is not a string, not an instance of IUserManager, and not null  | 
            ||
| 592 | */  | 
            ||
| 593 | public function setUserManager($provider)  | 
            ||
| 602 | }  | 
            ||
| 603 | |||
| 604 | /**  | 
            ||
| 605 | * @return bool allow request cron task processing, default false  | 
            ||
| 606 | */  | 
            ||
| 607 | public function getEnableRequestCron()  | 
            ||
| 610 | }  | 
            ||
| 611 | |||
| 612 | /**  | 
            ||
| 613 | * @param mixed $allow request cron task processing  | 
            ||
| 614 | * @throws TInvalidOperationException if the module has been initialized  | 
            ||
| 615 | */  | 
            ||
| 616 | public function setEnableRequestCron($allow)  | 
            ||
| 617 | 	{ | 
            ||
| 618 | 		if ($this->_initialized) { | 
            ||
| 619 | 			throw new TInvalidOperationException('cron_property_unchangeable', 'EnableRequestCron'); | 
            ||
| 620 | }  | 
            ||
| 621 | $this->_enableRequestCron = TPropertyValue::ensureBoolean($allow);  | 
            ||
| 622 | }  | 
            ||
| 623 | |||
| 624 | /**  | 
            ||
| 625 | * @return numeric the probability 0.0 .. 100.0 of a request triggering a cron, default 1.0 (out of 100.0).  | 
            ||
| 626 | */  | 
            ||
| 627 | public function getRequestCronProbability()  | 
            ||
| 628 | 	{ | 
            ||
| 629 | return $this->_requestCronProbability;  | 
            ||
| 630 | }  | 
            ||
| 631 | |||
| 632 | /**  | 
            ||
| 633 | * @param numeric $probability the probability 0.0..100.0 of a request triggering a cron  | 
            ||
| 634 | * @throws TInvalidOperationException if the module has been initialized  | 
            ||
| 635 | */  | 
            ||
| 636 | public function setRequestCronProbability($probability)  | 
            ||
| 642 | }  | 
            ||
| 643 | |||
| 644 | /**  | 
            ||
| 645 | * @return null|bool is cli running from cron.  | 
            ||
| 646 | * @since 4.2.2  | 
            ||
| 647 | */  | 
            ||
| 648 | public function getInCronShell()  | 
            ||
| 649 | 	{ | 
            ||
| 650 | return $this->_inCronShell;  | 
            ||
| 651 | }  | 
            ||
| 652 | |||
| 653 | /**  | 
            ||
| 654 | * @param null|bool $inCronShell is cli running from cron. This limits  | 
            ||
| 655 | * pending tasks to only the current minute.  | 
            ||
| 656 | * @since 4.2.2  | 
            ||
| 657 | */  | 
            ||
| 658 | public function setInCronShell($inCronShell)  | 
            ||
| 661 | }  | 
            ||
| 662 | |||
| 663 | /**  | 
            ||
| 664 | * @return array additional tasks in a list.  | 
            ||
| 665 | */  | 
            ||
| 666 | public function getAdditionalCronTasks()  | 
            ||
| 669 | }  | 
            ||
| 670 | |||
| 671 | /**  | 
            ||
| 672 | * This will take a string that is an array of tasks that has been  | 
            ||
| 673 | * through serialize(), or json_encode, or is an xml file of additional tasks.  | 
            ||
| 674 | * If one task is set, then it is automatically placed into an array.  | 
            ||
| 675 | * @param null|array|string $tasks additional tasks in an array [0..n], or  | 
            ||
| 676 | * a single task.  | 
            ||
| 677 | * @throws TInvalidOperationException if the module has been initialized  | 
            ||
| 678 | */  | 
            ||
| 679 | public function setAdditionalCronTasks($tasks)  | 
            ||
| 702 | }  | 
            ||
| 703 | }  | 
            ||
| 704 | 
The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g.
excluded_paths: ["lib/*"], you can move it to the dependency path list as follows:For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths