WebStream\Log\Outputter\FileOutputter

Complexity

Total Complexity

17

Size/Duplication

Total Lines	124
Duplicated Lines	14.52 %

Coupling/Cohesion

Components

1

Importance

Changes	4
Bugs	0	Features	0

8 Methods

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

<?php
namespace WebStream\Log\Outputter;

use WebStream\IO\Writer\SimpleFileWriter;
use WebStream\Cache\LoggerCache;
use WebStream\Cache\Driver\ICache;
use WebStream\Module\Utility\LoggerUtils;
use WebStream\Module\Utility\CacheUtils;

/**
 * FileOutputter
 * @author Ryuichi Tanaka
 * @since 2016/01/26
 * @version 0.7
 */
class FileOutputter implements IOutputter, ILazyWriter
{
    use LoggerUtils, CacheUtils;

    /**
     * @var string ログファイルパス
     */
    private $logPath;

    /**
     * @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)
    {
        $this->logPath = $logPath;
        $driver = $this->getCacheDriver("apcu");
        // 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 code seems to be duplicated across your project.

            $this->writeLog(implode("", $this->cache->get()));
        }

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

    /**
     * {@inheritdoc}
     */
    public function write($message)

This method seems to be duplicated in your project.

    {
        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 code seems to be duplicated across your project.

            $this->writeLog(implode("", $this->cache->get()));
        }
    }

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