Balloon\Async\WorkerFactory

Complexity

Total Complexity

8

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	build()	0	7	1
B	setErrorHandler()	0	35	6

<?php

declare(strict_types=1);

/**
 * balloon
 *
 * @copyright   Copryright (c) 2012-2018 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Balloon\Async;

use Balloon\Bootstrap\ContainerBuilder;
use Composer\Autoload\ClassLoader as Composer;
use ErrorException;
use MongoDB\BSON\ObjectId;
use MongoDB\Database;
use Psr\Log\LoggerInterface;
use TaskScheduler\Scheduler;
use TaskScheduler\Worker;
use TaskScheduler\WorkerFactoryInterface;

class WorkerFactory implements WorkerFactoryInterface
{
    /**
     * Composer.
     *
     * @var Composer
     */
    protected $composer;

    /**
     * Construct.
     */
    public function __construct(Composer $composer)
    {
        $this->composer = $composer;
    }

    /**
     * {@inheritdoc}
     */
    public function build(ObjectId $id): Worker
    {
        $dic = ContainerBuilder::get($this->composer);
        $this->setErrorHandler($dic->get(LoggerInterface::class));

        return new Worker($id, $dic->get(Scheduler::class), $dic->get(Database::class), $dic->get(LoggerInterface::class), $dic);
    }

    /**
     * Set error handler.
     */
    protected function setErrorHandler(LoggerInterface $logger): self
    {
        set_error_handler(function ($severity, $message, $file, $line) use ($logger) {
            $log = $message.' in '.$file.':'.$line;

            switch ($severity) {
                case E_ERROR:
                case E_USER_ERROR:
                    $logger->error($log, [
                        'category' => get_class($this),
                    ]);

                break;
                case E_WARNING:
                case E_USER_WARNING:
                    $logger->warning($log, [
                        'category' => get_class($this),
                    ]);

                break;
                default:
                    $logger->debug($log, [
                        'category' => get_class($this),
                    ]);

                break;
            }

            if (error_reporting() !== 0) {
                throw new ErrorException($message, 0, $severity, $file, $line);
            }
        });

        return $this;
    }
}