63 lines
1.4 KiB
PHP
63 lines
1.4 KiB
PHP
<?php
|
|
|
|
namespace SilverStripe\FullTextSearch\Utils\Logging;
|
|
|
|
use Monolog\Handler\AbstractProcessingHandler;
|
|
use Monolog\LogRecord;
|
|
use Monolog\Logger;
|
|
use Symbiote\QueuedJobs\Services\QueuedJob;
|
|
|
|
if (!interface_exists(QueuedJob::class)) {
|
|
return;
|
|
}
|
|
|
|
/**
|
|
* Handler for logging events into QueuedJob message data
|
|
*/
|
|
class QueuedJobLogHandler extends AbstractProcessingHandler
|
|
{
|
|
/**
|
|
* Job to log to
|
|
*
|
|
* @var QueuedJob
|
|
*/
|
|
protected $queuedJob;
|
|
|
|
/**
|
|
* @param QueuedJob $queuedJob Job to log to
|
|
* @param integer $level The minimum logging level at which this handler will be triggered
|
|
* @param Boolean $bubble Whether the messages that are handled can bubble up the stack or not
|
|
*/
|
|
public function __construct(QueuedJob $queuedJob, $level = Logger::DEBUG, $bubble = true)
|
|
{
|
|
parent::__construct($level, $bubble);
|
|
$this->setQueuedJob($queuedJob);
|
|
}
|
|
|
|
/**
|
|
* Set a new queuedjob
|
|
*
|
|
* @param QueuedJob $queuedJob
|
|
*/
|
|
public function setQueuedJob(QueuedJob $queuedJob)
|
|
{
|
|
$this->queuedJob = $queuedJob;
|
|
}
|
|
|
|
/**
|
|
* Get queuedjob
|
|
*
|
|
* @return QueuedJob
|
|
*/
|
|
public function getQueuedJob()
|
|
{
|
|
return $this->queuedJob;
|
|
}
|
|
|
|
protected function write(LogRecord $record): void
|
|
{
|
|
// Write formatted message
|
|
$this->getQueuedJob()->addMessage($record['formatted']);
|
|
}
|
|
}
|