nebula\component\debug\log\logger\FileLogger

Complexity

Total Complexity

28

Size/Duplication

Total Lines	161
Duplicated Lines	0 %

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	log()	0	9	2
B	packLogFile()	0	20	7
A	getDefaultConfig()	0	9	1
A	removePackFiles()	0	5	4
A	checkSize()	0	9	3
A	save()	0	7	2
A	rollLatest()	0	12	4
A	__construct()	0	14	3
A	interpolate()	0	7	2

<?php
namespace nebula\component\debug\log\logger;

use ZipArchive;
use nebula\component\debug\ConfigTrait;
use nebula\component\debug\log\LogLevel;
use nebula\component\debug\ConfigInterface;
use nebula\component\debug\log\AbstractLogger;
use nebula\component\debug\log\logger\exception\FileLoggerException;

class FileLogger extends AbstractLogger implements ConfigInterface
{
    use ConfigTrait;

    /**
     * 文件
     *
     * @var resource
     */
    protected $temp;

    /**
     * 临时文件名
     *
     * @var string
     */
    protected $tempname;

    /**
     * 移除文件
     *
     * @var array
     */
    protected $removeFiles = [];

    /**
     * 最后的日志
     *
     * @var string
     */
    protected $latest;

    /**
     * 构建文件日志
     *
     * @throws FileLoggerException
     * @param array $config
     */
    public function __construct(array $config=[])
    {
        $this->applyConfig($config);
        $temp = tmpfile();
        if ($temp === false) {
            $this->tempname = $this->config['save-path'].'/log-'. microtime(true).'.tmp';
            $temp = fopen($this->tempname, 'w+');
        }
        if ($temp !== false) {
            $this->temp = $temp;
        }else{
            throw new FileLoggerException(__CLASS__.':'.sprintf('cannot create log file'));
        }
        $this->latest = $this->config['save-path'].'/'.$this->config['file-name'];
    }

    public function getDefaultConfig():array {
        return [
            'save-path' => './logs',
            'save-zip-path' => './logs/zip',
            'save-pack-path' => './logs/dump',
            'max-file-size' => 2097152,
            'file-name' => 'latest.log',
            'log-level' => 'debug',
            'log-format' => '[%level%] %message%',
        ];
    }
    
    protected function packLogFile()
    {
        $logFile= $this->latest;
        $path=preg_replace('/[\\\\]+/', '/', $this->config['save-zip-path'] .'/'.date('Y-m-d').'.zip');
        $zip = new ZipArchive;
        $res = $zip->open($path, ZipArchive::CREATE);
        if ($res === true) {
            if ($zip->addFile($logFile, date('Y-m-d'). '-'. $zip->numFiles .'.log')) {
                array_push($this->removeFiles, $logFile);
            }
            $it = new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($this->config['save-pack-path']));
            foreach ($it as $dumpLog) {
                if ($zip->addFile($dumpLog, 'pack/'.basename($dumpLog))) {
                    array_push($this->removeFiles, $dumpLog);
                }
            }
            $zip->close();
        } else {
            if (is_file($logFile) && file_exists($logFile)) {
                rename($logFile, $this->config['save-path'] . '/' . date('Y-m-d'). '-'. substr(md5_file($logFile), 0, 8).'.log');
            }
        }
    }

    /**
     * 检查日志文件大小
     *
     * @return boolean
     */
    protected function checkSize():bool
    {
        $logFile= $this->latest;
        if (file_exists($logFile)) {
            if (filesize($logFile) > $this->config['max-file-size']) {
                return true;
            }
        }
        return false;
    }


    public function log($level, string $message, array $context = [])
    {
        if (LogLevel::compare($level, $this->config['log-level']) >=0) {
            $replace = [];
            $message = $this->interpolate($message, $context);
            $replace['%level%'] = $level;
            $replace['%message%'] = $message;
            $write = \strtr($this->config['log-format'], $replace);
            \fwrite($this->temp, $write.PHP_EOL);
        }
    }


    public function interpolate(string $message, array $context)
    {
        $replace = [];
        foreach ($context as $key => $val) {
            $replace['{' . $key . '}'] = $val;
        }
        return strtr($message, $replace);
    }

    protected function rollLatest()
    {
        if (isset($this->latest)) {
            $size=ftell($this->temp);
            fseek($this->temp, 0);
            if ($size > 0) {
                $body=fread($this->temp, $size);
                file_put_contents($this->latest, $body, FILE_APPEND);
            }
            fclose($this->temp);
            if (isset($this->tempname)) {
                unlink($this->tempname);
            }
        }
    }

    protected function removePackFiles()
    {
        foreach ($this->removeFiles as $file) {
            if (\is_file($file) && \file_exists($file)) {
                unlink($file);
            }
        }
    }

    public function save()
    {
        if ($this->checkSize()) {
            $this->packLogFile();
        }
        $this->rollLatest();
        $this->removePackFiles();
    }
}