WebStream\IO\Writer\SimpleFileWriter

Complexity

Total Complexity

13

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

<?php
class SimpleFileWriter extends OutputStreamWriter
{
    /**
     * @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)) {
            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);
    }

    /**
     * {@inheritdoc}
     */
    public function close()
    {
        // Nothing to do
    }

    /**
     * {@inheritdoc}
     */
    public function flush()
    {
        // Nothing to do
    }

    /**
     * {@inheritdoc}
     */
    public function newLine()
    {
        $this->write(PHP_EOL);
    }
}