Net\Bazzline\Component\Csv\Writer\Writer

Complexity

Total Complexity

18

Size/Duplication

Total Lines	157
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	4	1
A	copy()	0	13	3
A	move()	0	11	2
A	delete()	0	6	1
A	truncate()	0	7	1
A	writeAll()	0	6	1
A	writeHeadlines()	0	6	1
A	writeMany()	0	17	3
A	writeOne()	0	6	1
A	convertToArrayIfNeeded()	0	11	2
A	getFileHandlerOpenMode()	0	4	2

<?php
/**
 * @author: stev leibelt <artodeto@bazzline.net>
 * @since: 2015-04-17
 */

namespace Net\Bazzline\Component\Csv\Writer;

use Net\Bazzline\Component\Csv\AbstractBase;
use Net\Bazzline\Component\Csv\InvalidArgumentException;

/**
 * Class Writer
 * @package Net\Bazzline\Component\Csv\Writer
 */
class Writer extends AbstractBase implements WriterInterface
{
    const OPEN_MODE_APPEND      = 'a';
    const OPEN_MODE_TRUNCATE    = 'w';

    /** @var boolean */
    private $useTruncateAsOpenMode = false;

    /**
     * @param mixed|array $data
     * @return false|int
     */
    public function __invoke($data)
    {
        return $this->writeOne($data);
    }


    //begin of general
    /**
     * @param string $path
     * @param bool $setPathAsCurrentPath
     * @return bool
     * @throws InvalidArgumentException
     * @todo implement path validation
     */
    public function copy($path, $setPathAsCurrentPath = false)
    {
        $couldBeCopied = copy($this->getPath(), $path);

        if ($setPathAsCurrentPath) {
            if ($couldBeCopied) {
                $this->close();
                $this->setPath($path);
            }
        }

        return $couldBeCopied;
    }

    /**
     * @param string $path
     * @return bool
     * @todo implement path validation
     */
    public function move($path)
    {
        $couldBeMoved = rename($this->getPath(), $path);

        if ($couldBeMoved) {
            $this->close();
            $this->setPath($path);
        }

        return $couldBeMoved;
    }

    /**
     * @return bool
     */
    public function delete()
    {
        $this->close();

        return unlink($this->getPath());
    }

    public function truncate()
    {
        $this->close();
        $this->useTruncateAsOpenMode = true;
        $this->open($this->getPath());
        $this->useTruncateAsOpenMode = false;
    }

    /**
     * truncates file and writes content
     *
     * @param array $collection
     * @return false|int
     */
    public function writeAll(array $collection)
    {
        $this->truncate();

        return $this->writeMany($collection);
    }

    /**
     * @param array $headlines
     * @return false|int
     */
    public function writeHeadlines(array $headlines)
    {
        $this->setHeadline($headlines);

        return $this->writeOne($headlines);
    }

    /**
     * @param array $collection
     * @return false|int
     */
    public function writeMany(array $collection)
    {
        $lengthOfTheWrittenStrings = 0;

        foreach ($collection as $data) {
            $lengthOfTheWrittenString = $this->writeOne($data);

            if ($lengthOfTheWrittenString === false) {
                $lengthOfTheWrittenStrings = $lengthOfTheWrittenString;
                break;
            } else {
                $lengthOfTheWrittenStrings += $lengthOfTheWrittenString;
            }
        }

        return $lengthOfTheWrittenStrings;
    }

    /**
     * @param string|array $data
     * @return false|int
     */
    public function writeOne($data)
    {
        $data = $this->convertToArrayIfNeeded($data);

        return $this->getFileHandler()->fputcsv($data, $this->getDelimiter(), $this->getEnclosure());
    }
    //end of general

    /**
     * @param string|array $data
     * @return array
     */
    protected function convertToArrayIfNeeded($data)
    {
        if (!is_array($data)) {
            $data = explode($this->getDelimiter(), $data);
            $data = array_map(function($value) {
                return trim($value);
            }, $data);
        }

        return $data;
    }

    /**
     * @return string
     */
    protected function getFileHandlerOpenMode()
    {
        return ($this->useTruncateAsOpenMode) ? self::OPEN_MODE_TRUNCATE : self::OPEN_MODE_APPEND;
    }
}