Mattbit\Flat\Storage\FilesystemEngine

Complexity

Total Complexity

12

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

76.67%

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getEncoder()	0	4	1
A	put()	0	6	1
A	get()	0	6	1
A	delete()	0	4	1
A	all()	0	4	1
A	clear()	0	4	1
A	init()	0	10	2
A	has()	0	4	1
A	destroy()	0	5	1
A	path()	0	4	1

<?php

namespace Mattbit\Flat\Storage;

use Mattbit\Flat\Storage\EncoderInterface;
use Mattbit\Flat\Storage\EngineInterface;
use Mattbit\Flat\Storage\DocumentStore;

class FilesystemEngine implements EngineInterface
{
    /**
     * @var EncoderInterface
     */
    protected $encoder;

    protected $namespace;

    public function __construct($path, EncoderInterface $encoder)
    {
        $this->namespace = $path;
        $this->encoder = $encoder;
    }

    /**
     * Get the EncoderInterface instance.
     *
     * @return EncoderInterface
     */
    public function getEncoder()
    {
        return $this->encoder;
    }

    public function put($document, $id, $collection)
    {
        $data = $this->encoder->encode($document);

        return file_put_contents($this->path($id, $collection), $data) !== false;
    }

    public function get($id, $collection)
    {
        $data = file_get_contents($this->path($id, $collection));

        return $this->encoder->decode($data);
    }

    public function delete($id, $collection)
    {
        return unlink($this->path($id, $collection));
    }

    public function all($collection)
    {
        return new FilesystemIterator($this->encoder, $this->path('*', $collection));
    }

    public function clear($collection)
    {
        return array_map('unlink', glob($this->path('*', $collection)));
    }

    public function init($collection)
    {
        $dir = $this->path('', $collection, '');

        if (!file_exists($dir)) {
            return mkdir($this->path('', $collection, ''));
        }

        return true;
    }

    public function has($id, $collection)
    {
        return file_exists($this->path($id, $collection));
    }

    public function destroy($collection)
    {
        array_map('unlink', glob($this->path('*', $collection, '')));
        return rmdir($this->path('', $collection, ''));
    }

    protected function path($id, $collection, $ext = '.data')
    {
        return $this->namespace.DIRECTORY_SEPARATOR.$collection.DIRECTORY_SEPARATOR.$id.$ext;
    }
}