Doyo\Bridge\CodeCoverage\Session\AbstractSession

Complexity

Total Complexity

27

Size/Duplication

Total Lines	242
Duplicated Lines	0 %

Test Coverage

Coverage

65.25%

Importance

Changes

0

19 Methods

Rating	Name	Duplication	Size	Complexity
A	getProcessor()	0	3	1
A	reset()	0	6	1
A	start()	0	24	3
A	stop()	0	14	2
A	setTestCase()	0	3	1
A	getName()	0	3	1
A	serialize()	0	5	1
A	createContainer()	0	4	1
A	save()	0	8	1
A	toCache()	0	9	2
A	fromCache()	0	4	2
A	init()	0	7	1
A	refresh()	0	11	2
A	unserialize()	0	4	1
A	addException()	0	7	2
A	__construct()	0	9	1
A	getExceptions()	0	3	1
A	shutdown()	0	6	2
A	hasExceptions()	0	3	1

<?php

/*
 * This file is part of the doyo/code-coverage project.
 *
 * (c) Anthonius Munthi <https://itstoni.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Doyo\Bridge\CodeCoverage\Session;

use Doyo\Bridge\CodeCoverage\ContainerFactory;
use Doyo\Bridge\CodeCoverage\Exception\SessionException;
use Doyo\Bridge\CodeCoverage\ProcessorInterface;
use Doyo\Bridge\CodeCoverage\TestCase;
use Psr\Container\ContainerInterface;
use Symfony\Component\Cache\Adapter\FilesystemAdapter;

abstract class AbstractSession implements SessionInterface, \Serializable
{
    const CACHE_KEY = 'session';

    /**
     * @var string
     */
    protected $name;

    /**
     * @var TestCase|null
     */
    protected $testCase;

    /**
     * @var FilesystemAdapter|null
     */
    protected $adapter;

    /**
     * @var ProcessorInterface
     */
    protected $processor;

    /**
     * @var array
     */
    protected $exceptions = [];

    /**
     * @var array
     */
    protected $config = [];

    /**
     * @var ContainerInterface|null
     */
    protected $container;

    /**
     * @var ProcessorInterface|null
     */
    protected $currentProcessor;

    protected $cachedProperties = [
        'name',
        'processor',
        'exceptions',
        'config',
        'testCase',
    ];

    private $started = false;

    /**
     * AbstractSession constructor.
     *
     * @param string $name
     * @param array  $config
     */
    public function __construct(string $name)
    {
        $dir           = sys_get_temp_dir().'/doyo/code-coverage/sessions';
        $this->adapter = new FilesystemAdapter($name, 0, $dir);
        $this->refresh();

        $this->name = $name;

        register_shutdown_function([$this, 'shutdown']);
    }

    public function init(array $config)
    {
        $this->config = $config;
        $this->createContainer($config);
        $this->processor = $this->container->get('factory')->createProcessor(true);
        $this->reset();
        $this->save();
    }

    public function serialize()
    {
        $data = $this->toCache();

        return serialize($data);
    }

    public function unserialize($serialized)
    {
        $cache = unserialize($serialized);
        $this->fromCache($cache);
    }

    /**
     * {@inheritdoc}
     */
    public function getName(): string
    {
        return $this->name;
    }

    /**
     * {@inheritdoc}
     */
    public function getProcessor()
    {
        return $this->processor;
    }

    public function refresh()
    {
        $adapter = $this->adapter;

        $cached = $adapter->getItem(static::CACHE_KEY)->get();

The method getItem() does not exist on null.

        if(!is_null($cached)){
            $this->fromCache($cached);
        }

        $this->createContainer($this->config);
    }

    private function createContainer($config)
    {
        $container       = (new ContainerFactory($config))->getContainer();
        $this->container = $container;
    }

    private function toCache()
    {
        $data = [];

        foreach ($this->cachedProperties as $property) {
            $data[$property] = $this->{$property};
        }

        return $data;
    }

    private function fromCache(array $cache)
    {
        foreach ($cache as $name => $value) {
            $this->{$name} = $value;
        }
    }

    public function save()
    {
        $adapter = $this->adapter;
        $item    = $adapter->getItem(static::CACHE_KEY);
        $data    = $this->toCache();

        $item->set($data);
        $adapter->save($item);
    }

    public function reset()
    {
        $this->testCase   = null;
        $this->exceptions = [];

        $this->processor->clear();
    }

    public function hasExceptions()
    {
        return \count($this->exceptions) > 0;
    }

    public function getExceptions()
    {
        return $this->exceptions;
    }

    public function addException(\Exception $exception)
    {
        $message = $exception->getMessage();
        $id      = md5($message);

        if (!isset($this->exceptions[$id])) {
            $this->exceptions[$id] = $exception;
        }
    }

    public function setTestCase(TestCase $testCase)
    {
        $this->testCase = $testCase;
    }

    /**
     * @throws SessionException If TestCase is null
     */
    public function start()
    {
        if (null === $this->testCase) {
            throw new SessionException('Can not start coverage with null TestCase');
        }

        try {
            $container = $this->container;
            $testCase  = $this->testCase;
            $processor = $container->get('factory')->createProcessor();

The method get() does not exist on null.

            $processor->start($testCase);

            $this->currentProcessor = $processor;
            $this->started = true;
        } catch (\Exception $exception) {
            $this->started = false;
            $message = sprintf(
                "Can not start coverage on session %s. Error message:\n%s",
                $this->getName(),
                $exception->getMessage()
            );
            $exception = new  SessionException($message);
            $this->addException($exception);
        }
    }

    public function stop()
    {
        try{
            $this->currentProcessor->stop();

The method stop() does not exist on null.

            $this->processor->merge($this->currentProcessor);
            $this->started = false;
        }catch (\Exception $exception){
            $message = sprintf(
                "Can not stop coverage on session <comment>%s</comment>. Error message:\n<error>%s</error>",
                $this->name,
                $exception->getMessage()
            );
            $e = new SessionException($message);
            $this->addException($e);
        }
    }

    public function shutdown()
    {
        if ($this->started) {
            $this->stop();
        }
        $this->save();
    }
}