WebStream\IO\Writer\SimpleFileWriter

Complexity

Total Complexity

10

Size/Duplication

Total Lines	67
Duplicated Lines	4.48 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	3
C	write()	3	26	7

<?php
namespace WebStream\IO\Writer;

use WebStream\IO\File;
use WebStream\IO\FileOutputStream;
use WebStream\Exception\Extend\IOException;

/**
 * SimpleFileWriter
 * @author Ryuichi TANAKA.
 * @since 2016/02/25
 * @version 0.7
 */
class SimpleFileWriter
{
    /**
     * @var string ファイルパス
     */
    private $filepath;

    /**
     * @var int バッファリングサイズ
     */
    private $bufferSize;

    /**
     * @var string 書き込みモード
     */
    private $mode;

    /**
     * constructor
     * @param string $filepath ファイルパス
     * @param int $bufferSize バッファリングサイズ
     */
    public function __construct($filepath, $bufferSize = null)
    {
        $dirname = dirname($filepath);
        $dir = new File($dirname);
        if (!$dir->isWritable()) {
            throw new IOException("Cannot writable: " . $filepath);
        }

        $this->filepath = $filepath;
        $this->bufferSize = $bufferSize;
        $this->mode = file_exists($this->filepath) ? 'ab' : 'wb';
    }

    /**
     * ファイルに書き込む
     * ファイルが存在する場合、常に追記モード
     * @param mixed $data 書き込みデータ
     */
    public function write($data)
    {
        $stream = fopen($this->filepath, $this->mode);

        if ($this->bufferSize !== null && stream_set_write_buffer($stream, $this->bufferSize) !== 0) {
            throw new IOException("Failed to change the buffer size.");
        }

        if (!is_resource($stream) || $stream === false) {
            throw new IOException("Unable open " . $this->filepath);
        }

        if (!flock($stream, LOCK_EX | LOCK_NB)) {

This code seems to be duplicated across your project.

            throw new IOException("Cannot lock file: " . $this->filepath);
        }

        if (fwrite($stream, $data) === false) {
            flock($stream, LOCK_UN);
            fclose($stream);
            throw new IOException("Failed to write stream.");
        }

        fflush($stream);
        flock($stream, LOCK_UN);
        fclose($stream);
    }
}