.-.-.-.-.-

<?php
/**
 * @link https://craftcms.com/
 * @copyright Copyright (c) Pixel & Tonic, Inc.
 * @license https://craftcms.github.io/license/
 */

namespace craft\queue;

use Craft;
use craft\log\Dispatcher;
use craft\log\MonologTarget;
use Illuminate\Support\Collection;
use yii\queue\ExecEvent;

/**
 * Queue Log Behavior
 *
 * @author Pixel & Tonic, Inc. <support@pixelandtonic.com>
 * @since 3.0.0
 */
class QueueLogBehavior extends VerboseBehavior
{
    /**
     * @var float timestamp
     */
    private float $_jobStartedAt;

/**
     * @var bool Whether any jobs have executed yet
     */
    private bool $_jobExecuted = false;

/**
     * @inheritdoc
     */
    public function events(): array
    {
        return [
            Queue::EVENT_BEFORE_EXEC => 'beforeExec',
            Queue::EVENT_AFTER_EXEC => 'afterExec',
            Queue::EVENT_AFTER_ERROR => 'afterError',
        ];
    }

/**
     * @param ExecEvent $event
     */
    public function beforeExec(ExecEvent $event): void
    {
        if (!$this->_jobExecuted) {
            $this->_enableLogTarget();
        }

$this->_jobStartedAt = microtime(true);
        Craft::info(sprintf('%s - Started', parent::jobTitle($event)), __METHOD__);
    }

/**
     * @inheritdoc
     */
    public function afterExec(ExecEvent $event): void
    {
        if (isset($this->_jobStartedAt)) {
            Craft::info(sprintf('%s - Done (time: %s)', parent::jobTitle($event), $this->_formattedDuration()), __METHOD__);
        } else {
            Craft::info(sprintf('%s - Done', parent::jobTitle($event)), __METHOD__);
        }
    }

/**
     * @inheritdoc
     */
    public function afterError(ExecEvent $event): void
    {
        $message = sprintf('%s - Error', parent::jobTitle($event));

if (isset($this->_jobStartedAt)) {
            $message .= sprintf(' (time: %s)', $this->_formattedDuration());
        }

if ($event->error) {
            $message .= sprintf(': %s', $event->error->getMessage());
        }

Craft::error($message, __METHOD__);

if ($event->error) {
            Craft::$app->getErrorHandler()->logException($event->error);
        }
    }

/**
     * Enables the log target logs will get flushed to.
     */
    private function _enableLogTarget(): void
    {
        Collection::make(Craft::$app->getLog()->targets)
            ->whereInstanceOf(MonologTarget::class)
            ->filter(fn($target, $key) => in_array($key, [
                Dispatcher::TARGET_WEB,
                Dispatcher::TARGET_CONSOLE,
                Dispatcher::TARGET_QUEUE,
            ], true))
            ->each(function(MonologTarget $target): void {
                $target->enabled = $target->getLogger()->getName() === Dispatcher::TARGET_QUEUE;
            });
    }

/**
     * Returns the job execution time in seconds.
     *
     * @return string
     */
    private function _formattedDuration(): string
    {
        return sprintf('%.3f', microtime(true) - $this->_jobStartedAt) . 's';
    }
}

/srv/users/craft4/apps/craft4-newsite-space/vendor/././craftcms/cms/src/queue/QueueLogBehavior.php