WebStream\Log\Outputter\FileOutputter

Complexity

Total Complexity

17

Size/Duplication

Total Lines	120
Duplicated Lines	0 %

Coupling/Cohesion

Components

1

Test Coverage

Coverage

80.48%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	hp$0 ➔ __call()	0	1	1
A	__construct()	0	14	1
A	enableLazyWrite()	0	7	2
A	write()	0	12	3
A	flush()	0	6	3
A	__destruct()	0	10	3
A	enableDirectWrite()	0	9	3
A	writeLog()	0	4	1

<?php
namespace WebStream\Log\Outputter;

use WebStream\Cache\Driver\ICache;
use WebStream\Cache\Driver\CacheDriverFactory;
use WebStream\Container\Container;
use WebStream\IO\Writer\SimpleFileWriter;
use WebStream\Log\LoggerCache;

/**
 * FileOutputter
 * @author Ryuichi Tanaka
 * @since 2016/01/26
 * @version 0.7
 */
class FileOutputter implements IOutputter, ILazyWriter
{
    /**
     * @var ICache キャッシュドライバ
     */
    private $driver;

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

    /**
     * @var bool 遅延書き出しフラグ
     */
    private $isLazyWrite;

    /**
     * @var SimpleFileWriter Writerオブジェクト
     */
    private $writer;

    /**
     * @var LoggerCache ログキャッシュ
     */
    private $cache;

    /**
     * constructor
     * @param string $logPath ログファイルパス
     * @param int $bufferSize バッファリングサイズ
     */
    public function __construct(string $logPath, int $bufferSize = 1000)
    {
        $config = new Container(false);
        $config->classPrefix = "logger_cache";
        $factory = new CacheDriverFactory();
        $driver = $factory->create("WebStream\Cache\Driver\Apcu", $config);

        // LoggerCacheの中ではログは取らない
        $driver->inject('logger', new class() { function __call($name, $args) {} });

It is generally recommended to explicitly declare the visibility for methods.

        $this->driver = $driver;
        $this->bufferSize = $bufferSize;
        $this->enableLazyWrite();
        $this->writer = new SimpleFileWriter($logPath);
    }

    /**
     * destructor
     */
    public function __destruct()
    {
        try {
            if ($this->isLazyWrite) {
                $this->writeLog(implode("", $this->cache->get()));
            }
        } catch (\Exception $ignore) {
            // デストラクタで例外が発生すると致命的なエラーとなる
        }
    }

    /**
     * {@inheritdoc}
     */
    public function enableLazyWrite()
    {
        if ($this->driver !== null) {
            $this->isLazyWrite = true;
            $this->cache = new LoggerCache($this->driver);
        }
    }

    /**
     * {@inheritdoc}
     */
    public function enableDirectWrite()
    {
        if ($this->isLazyWrite && $this->cache->length() > 0) {
            $this->writeLog(implode("", $this->cache->get()));
        }

        $this->isLazyWrite = false;
        $this->cache = null;
    }

    /**
     * {@inheritdoc}
     */
    public function write($message)
    {
        if ($this->isLazyWrite) {
            if ($this->cache->length() >= $this->bufferSize) {
                $this->flush();
                $this->clear();

The method clear() does not seem to exist on object<WebStream\Log\Outputter\FileOutputter>.

            }
            $this->cache->add($message);
        } else {
            $this->writeLog($message);
        }
    }

    /**
     * バッファをログ出力する
     */
    private function flush()
    {
        if ($this->isLazyWrite && $this->cache->length() > 0) {
            $this->writeLog(implode("", $this->cache->get()));
        }
    }

    /**
     * ログファイルに書き出す
     * @param string $message ログメッセージ
     */
    private function writeLog($message)
    {
        $this->writer->write($message);
    }
}