Maketok\DataMigration\Storage\Filesystem\ResourceTest

Complexity

Total Complexity

9

Size/Duplication

Total Lines	144
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	4	1
A	testOpenClose()	0	10	1
A	testWrite()	0	10	1
A	testRead()	0	10	1
A	testRewind()	0	15	1
A	testIsActive()	0	11	1
A	testCleanup()	0	14	1
A	testCleanupNotEmpty()	0	15	1
A	testIsEmptyDir()	0	19	1

<?php

namespace Maketok\DataMigration\Storage\Filesystem;

use org\bovigo\vfs\vfsStream;
use org\bovigo\vfs\vfsStreamDirectory;

class ResourceTest extends \PHPUnit_Framework_TestCase
{
    /**
     * @var vfsStreamDirectory
     */
    private $root;

    public function setUp()
    {
        $this->root = vfsStream::setup('root');
    }

    /**
     * @test
     * @expectedException \RuntimeException
     * @expectedExceptionMessage failed to open stream
     */
    public function testOpenClose()
    {
        $filesystem = new Resource();
        $filesystem->open(vfsStream::url('root/file1'), 'w');
        $filesystem->close();
        $this->assertFileExists(vfsStream::url('root/file1'));

        // should fail
        $filesystem->open(vfsStream::url('root/file2'), 'r');
    }

    /**
     * @depends testOpenClose
     */
    public function testWrite()
    {
        $filesystem = new Resource();
        $filesystem->open(vfsStream::url('root/file1'), 'w');
        $filesystem->writeRow(['name', 'age', 'address']);
        $filesystem->close();

        $fileObject = new \SplFileObject(vfsStream::url('root/file1'), 'r');
        $this->assertSame(['name', 'age', 'address'], $fileObject->fgetcsv());
    }

    /**
     * @depends testOpenClose
     */
    public function testRead()
    {
        $fileObject = new \SplFileObject(vfsStream::url('root/file1'), 'w');
        $fileObject->fputcsv(['name', 'age', 'address']);

        $filesystem = new Resource();
        $filesystem->open(vfsStream::url('root/file1'), 'r');
        $this->assertSame(['name', 'age', 'address'], $filesystem->readRow());
        $filesystem->close();
    }

    /**
     * @depends testRead
     */
    public function testRewind()
    {
        $fileObject = new \SplFileObject(vfsStream::url('root/file1'), 'w');
        $fileObject->fputcsv(['name', 'age', 'address']);
        $fileObject->fputcsv(['Oleg', '3', 'Universe']);

        $filesystem = new Resource();
        $filesystem->open(vfsStream::url('root/file1'), 'r');
        $this->assertSame(['name', 'age', 'address'], $filesystem->readRow());
        $this->assertSame(['Oleg', '3', 'Universe'], $filesystem->readRow());
        $this->assertEmpty($filesystem->readRow());
        $filesystem->rewind();
        $this->assertSame(['name', 'age', 'address'], $filesystem->readRow());
        $filesystem->close();
    }

    /**
     * @depends testOpenClose
     */
    public function testIsActive()
    {
        $filesystem = new Resource();
        $filesystem->open(vfsStream::url('root/file1'), 'w');
        $this->assertTrue($filesystem->isActive());
        $filesystem->close();
        $this->assertFalse($filesystem->isActive());
        $filesystem->open(vfsStream::url('root/file1'), 'w');
        $this->assertTrue($filesystem->isActive());
        $filesystem->close();
    }

    public function testCleanup()
    {
        $dir = vfsStream::newDirectory('tmp');
        $dir->at($this->root);
        vfsStream::newFile('file1')->at($dir);

        $this->assertTrue(file_exists(vfsStream::url('root/tmp/file1')));

        $filesystem = new Resource();
        $filesystem->cleanUp(vfsStream::url('root/tmp/file1'));

        $this->assertFalse(file_exists(vfsStream::url('root/tmp/file1')));
        $this->assertFalse(file_exists(vfsStream::url('root/tmp')));
    }

    public function testCleanupNotEmpty()
    {
        $dir = vfsStream::newDirectory('tmp');
        $dir->at($this->root);
        vfsStream::newFile('file1')->at($dir);
        vfsStream::newFile('file2')->at($dir);

        $this->assertTrue(file_exists(vfsStream::url('root/tmp/file1')));

        $filesystem = new Resource();
        $filesystem->cleanUp(vfsStream::url('root/tmp/file1'));

        $this->assertFalse(file_exists(vfsStream::url('root/tmp/file1')));
        $this->assertTrue(file_exists(vfsStream::url('root/tmp')));
    }

    /**
     * @test
     */
    public function testIsEmptyDir()
    {
        $dir1 = vfsStream::newDirectory('tmp');
        $dir1->at($this->root);
        $dir2 = vfsStream::newDirectory('tmp_locked', 0111);
        $dir2->at($this->root);
        $file1 = vfsStream::newFile('tmpfile');
        $file1->at($this->root);
        $dir3 = vfsStream::newDirectory('tmp2');
        $dir3->at($this->root);
        $file2 = vfsStream::newFile('tmpfile2');
        $file2->at($dir3);

        $filesystem = new Resource();
        $this->assertSame(true, $filesystem->isEmptyDir(vfsStream::url('root/tmp')));
        $this->assertSame(null, $filesystem->isEmptyDir(vfsStream::url('root/tmp_locked')));
        $this->assertSame(null, $filesystem->isEmptyDir(vfsStream::url('root/tmpfile')));
        $this->assertSame(false, $filesystem->isEmptyDir(vfsStream::url('root/tmp2')));
    }
}