Symbiote\QueuedJobs\Services\QueuedJobHandler

Complexity

Total Complexity

4

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getJob()	0	4	1
A	getJobDescriptor()	0	4	1
A	write()	0	6	1

<?php

namespace Symbiote\QueuedJobs\Services;

use Monolog\Handler\AbstractProcessingHandler;
use SilverStripe\Core\Injector\Injectable;
use Symbiote\QueuedJobs\DataObjects\QueuedJobDescriptor;

/**
 * Writes log output to a job descriptor
 */
class QueuedJobHandler extends AbstractProcessingHandler
{
    use Injectable;

    /** @var QueuedJob */
    protected $job;

    /** @var QueuedJobDescriptor */
    protected $jobDescriptor;

    public function __construct(QueuedJob $job, QueuedJobDescriptor $jobDescriptor)
    {
        parent::__construct($job, $jobDescriptor);

$job is of type object<Symbiote\QueuedJobs\Services\QueuedJob>, but the function expects a integer.

$jobDescriptor is of type object<Symbiote\QueuedJobs\DataObjects\QueuedJobDescriptor>, but the function expects a boolean.

        $this->job = $job;
        $this->jobDescriptor = $jobDescriptor;
    }

    /**
     * @return QueuedJob
     */
    public function getJob()
    {
        return $this->job;
    }

    /**
     * @return QueuedJobDescriptor
     */
    public function getJobDescriptor()
    {
        return $this->jobDescriptor;
    }

    /**
     * Writes the record down to the log of the implementing handler
     *
     * @param  array $record
     * @return void
     * @throws \SilverStripe\ORM\ValidationException
     */
    protected function write(array $record)
    {
        $this->job->addMessage($record['message']);
        $this->jobDescriptor->SavedJobMessages = serialize($this->job->getJobData()->messages);
        $this->jobDescriptor->write();
    }
}