AnimeDb\Bundle\CatalogBundle\Console\Output\Export

Complexity

Total Complexity

14

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	0	16	5
A	write()	0	5	1
A	writeln()	0	5	1
A	writeToFile()	0	15	4
A	unlock()	0	6	2
A	__destruct()	0	4	1

<?php
/**
 * AnimeDb package
 *
 * @package   AnimeDb
 * @author    Peter Gribanov <info@peter-gribanov.ru>
 * @copyright Copyright (c) 2011, Peter Gribanov
 * @license   http://opensource.org/licenses/GPL-3.0 GPL v3
 */

namespace AnimeDb\Bundle\CatalogBundle\Console\Output;

use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Filesystem\Exception\IOException;

/**
 * Export output to file
 *
 * @package AnimeDb\Bundle\CatalogBundle\Console\Output
 * @author  Peter Gribanov <info@peter-gribanov.ru>
 */
class Export extends Decorator
{
    /**
     * File handle
     *
     * @var resource
     */
    protected $handle;

    /**
     * Append to end file
     *
     * @var bool
     */
    protected $append = true;

    /**
     * @param OutputInterface $output
     * @param string $filename
     * @param bool $append
     */
    public function __construct(OutputInterface $output, $filename, $append = true)
    {
        parent::__construct($output);
        $this->append = $append;

        $dir = pathinfo($filename, PATHINFO_DIRNAME);
        if (!is_dir($dir) && true !== @mkdir($dir, 0755, true)) {
            throw new IOException('Failed to create the export directory: '.$dir);
        }
        if (!($this->handle = @fopen($filename, 'w'))) {
            throw new IOException('Failed to open the export file: '.$filename);
        }
        if (!flock($this->handle, LOCK_EX|LOCK_NB)) {
            throw new IOException('Failed to lock the export file: '.$filename);
        }
    }

    /**
     * @param array|string $messages
     * @param bool|false $newline
     * @param int $type
     */
    public function write($messages, $newline = false, $type = self::OUTPUT_NORMAL)
    {
        $this->writeToFile($messages, $newline);
        parent::write($messages, $newline, $type);
    }

    /**
     * @param array|string $messages
     * @param int $type
     */
    public function writeln($messages, $type = self::OUTPUT_NORMAL)
    {
        $this->writeToFile($messages, true);
        parent::writeln($messages, $type);
    }

    /**
     * @param string|array $messages
     * @param bool $newline
     */
    protected function writeToFile($messages, $newline)
    {
        $messages = (array)$messages;
        foreach ($messages as $key => $message) {
            $messages[$key] = strip_tags($message).($newline ? PHP_EOL : '');
        }

        // reset file
        if (!$this->append) {
            rewind($this->handle);
            ftruncate($this->handle, 0);
        }

        fwrite($this->handle, implode('', $messages));
    }

    public function unlock() {
        if (is_resource($this->handle)) {
            flock($this->handle, LOCK_UN);
            fclose($this->handle);
        }
    }

    public function __destruct()
    {
        $this->unlock();
    }
}