lav45\activityLogger\Manager

Complexity

Total Complexity

12

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	10
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	createMiddleware()	0	7	2
A	throwException()	0	6	2
A	delete()	0	8	2
A	setMiddlewares()	0	7	2
A	createMessageBuilder()	0	5	1
A	log()	0	8	2

<?php
/**
 * @link https://github.com/lav45/yii2-activity-logger
 * @copyright Copyright (c) 2017 LAV45
 * @author Aleksey Loban <lav451@gmail.com>
 * @license http://opensource.org/licenses/BSD-3-Clause
 */

namespace lav45\activityLogger;

use lav45\activityLogger\middlewares\Middleware;
use lav45\activityLogger\middlewares\MiddlewarePipeline;
use lav45\activityLogger\storage\DeleteCommand;
use lav45\activityLogger\storage\MessageData;
use lav45\activityLogger\storage\StorageInterface;
use Throwable;
use Yii;
use yii\base\BaseObject;

class Manager extends BaseObject implements ManagerInterface
{
    public bool $debug = YII_DEBUG;

    /** @var Middleware[] */
    private array $middlewares = [];

    private StorageInterface $storage;

    public function __construct(
        StorageInterface $storage,
        array            $config = []
    )
    {
        parent::__construct($config);
        $this->storage = $storage;
    }

    /**
     * @param array{string, array, Middleware} $middlewares

The doc comment array{string, array, Middleware} at position 2 could not be parsed: Expected ':' at position 2, but found 'string'.

     * @return void
     */
    public function setMiddlewares(array $middlewares): void
    {
        $result = [];
        foreach ($middlewares as $middleware) {
            $result[] = $this->createMiddleware($middleware);
        }
        $this->middlewares = $result;
    }

    /**
     * @param string|array|Middleware $middleware
     * @return Middleware
     */
    protected function createMiddleware($middleware): Middleware
    {
        if (is_object($middleware)) {
            return $middleware;
        }
        /** @var Middleware */
        return Yii::createObject($middleware);
    }

    public function createMessageBuilder(string $entityName): MessageBuilderInterface
    {
        $pipeline = new MiddlewarePipeline(...$this->middlewares);
        $builder = new MessageBuilder($entityName);
        return $pipeline->handle($builder);
    }

    public function log(MessageData $message): bool
    {
        try {
            $this->storage->save($message);
            return true;
        } catch (Throwable $e) {
            $this->throwException($e);
            return false;
        }
    }

    public function delete(DeleteCommand $command): bool
    {
        try {
            $this->storage->delete($command);
            return true;
        } catch (Throwable $e) {
            $this->throwException($e);
            return false;
        }
    }

    private function throwException(Throwable $e): void
    {
        if ($this->debug) {
            throw $e;
        }
        Yii::error($e->getMessage(), static::class);
    }
}