Ndrx\Profiler\DataSources\Memory

Complexity

Total Complexity

14

Size/Duplication

Total Lines	103
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes	7
Bugs	0	Features	1

8 Methods

Rating	Name	Duplication	Size	Complexity
A	all()	0	10	2
A	count()	0	4	1
A	getProcess()	0	8	2
A	clear()	0	4	1
A	deleteProcess()	0	6	2
A	save()	0	5	1
A	saveSummary()	0	12	3
A	initiateMemoryProcess()	0	6	2

<?php
/**
 * Created by PhpStorm.
 * User: arnaud
 * Date: 01/11/15
 * Time: 19:46
 */

namespace Ndrx\Profiler\DataSources;

use Ndrx\Profiler\DataSources\Contracts\DataSourceInterface;
use Ndrx\Profiler\Process;

/**
 * Class Memory
 *
 * @package Ndrx\Profiler\DataSources
 */
class Memory implements DataSourceInterface
{
    const SUMMARY_KEY = 'summary';

    protected $memory = [];

    /**
     * @param int $offset
     * @param int $limit
     *
     * @return mixed
     */
    public function all($offset = 0, $limit = 15)
    {
        $results = array_slice($this->memory, $offset, $limit);

        foreach ($results as $key => $value) {
            $results[$key] = json_decode($value[self::SUMMARY_KEY]);
        }

        return $results;
    }

    /**
     * @return mixed
     */
    public function count()
    {
        return count($this->memory);
    }

    /**
     * @param $processId
     *
     * @return \Generator
     */
    public function getProcess($processId)
    {
        $patchs = $this->memory[$processId];
        unset($patchs[self::SUMMARY_KEY]);
        foreach ($patchs as $patch) {
            yield $patch;
        }
    }

    /**
     * @return mixed
     */
    public function clear()
    {
        $this->memory = [];
    }

    /**
     * @param $processId
     *
     * @return mixed
     */
    public function deleteProcess($processId)
    {
        if (array_key_exists($processId, $this->memory)) {
            unset($this->memory[$processId]);
        }
    }

    /**
     * @param Process $process
     * @param array $item
     *
     * @return mixed
     */
    public function save(Process $process, array $item)
    {
        $this->initiateMemoryProcess($process);
        $this->memory[$process->getId()][] = json_encode($item);
    }

    /**
     * @param Process $process
     * @param array $item
     *
     * @return mixed
     */
    public function saveSummary(Process $process, array $item)
    {
        $this->initiateMemoryProcess($process);
        if (array_key_exists($process->getId(), $this->memory)
            && array_key_exists(self::SUMMARY_KEY, $this->memory[$process->getId()])
        ) {
            $content = (array)json_decode($this->memory[$process->getId()][self::SUMMARY_KEY]);
            $item = array_merge($content, $item);
        }

        $this->memory[$process->getId()][self::SUMMARY_KEY] = json_encode($item);
    }

    protected function initiateMemoryProcess(Process $process)
    {
        if (!array_key_exists($process->getId(), $this->memory)) {
            $this->memory[$process->getId()] = [];
        }
    }
}