<?php

declare(strict_types=1);

namespace ZM\Logger;

use Psr\Log\AbstractLogger;
use Psr\Log\InvalidArgumentException;
use Psr\Log\LogLevel;

class ConsoleLogger extends AbstractLogger
{
    public const VERSION = '1.1.7';

    /**
     * 日志输出格式
     *
     * @var string
     */
    public static $format = '[%date%] [%level%] %body%';

    /**
     * 日志输出日期格式
     *
     * @var string
     */
    public static $date_format = 'Y-m-d H:i:s';

    /**
     * 颜色表
     *
     * @var string[][]
     */
    protected static $styles = [
        ['blink', 'white', 'bg_bright_red'], // emergency
        ['white', 'bg_bright_red'], // alert
        ['underline', 'red'], // critical
        ['red'], // error
        ['bright_yellow'], // warning
        ['cyan'], // notice
        ['green'], // info
        ['gray'], // debug
    ];

    /**
     * 等级表
     *
     * @var string[]
     */
    protected static $levels = [
        LogLevel::EMERGENCY, // 0
        LogLevel::ALERT, // 1
        LogLevel::CRITICAL, // 2
        LogLevel::ERROR, // 3
        LogLevel::WARNING, // 4
        LogLevel::NOTICE, // 5
        LogLevel::INFO, // 6
        LogLevel::DEBUG, // 7
    ];

    /**
     * 当前日志等级
     *
     * @var int
     */
    protected static $log_level;

    /**
     * 静态上下文
     *
     * @var array
     */
    protected $static_context = [];

    /**
     * 日志记录回调
     *
     * @var callable[]
     */
    protected $log_callbacks = [];

    /**
     * Stream 写入
     *
     * @var null|int|resource
     */
    protected $stream;

    /**
     * 递归保护标志 — 防止日志写入失败时错误处理器再次调用日志导致死循环 CPU 100%
     *
     * @var bool
     */
    protected static $in_log = false;

    /**
     * 是否带颜色
     *
     * @var bool
     */
    protected $decorated;

    protected $use_stderr = false;

    /**
     * 创建一个 ConsoleLogger 实例
     *
     * @param string        $level  日志等级
     * @param null|resource $stream
     */
    public function __construct(string $level = LogLevel::INFO, $stream = null, bool $decorated = true, bool $use_stderr = false)
    {
        $this->decorated = $decorated;
        self::$log_level = $this->castLogLevel($level);
        if (!$stream || !is_resource($stream) || get_resource_type($stream) !== 'stream') {
            return;
        }
        $stat = fstat($stream);
        if (!$stat) {
            return;
        }
        if (($stat['mode'] & 0170000) === 0100000) { // whether is regular file
            $this->decorated = false;
        } else {
            $this->decorated
                = PHP_OS_FAMILY !== 'Windows' // linux or unix
                && function_exists('posix_isatty')
                && posix_isatty($stream); // whether is interactive terminal
        }
        $this->stream = $stream;
        $this->use_stderr = $use_stderr;
    }

    public function setLevel(string $level): void
    {
        self::$log_level = $this->castLogLevel($level);
    }

    /**
     * 获取当前样式表
     *
     * @return string[][]
     */
    public static function getStyles(): array
    {
        return self::$styles;
    }

    /**
     * 获取版本号
     */
    public static function getVersion(): string
    {
        return self::VERSION;
    }

    /**
     * 添加静态上下文
     */
    public function addStaticContext(array $context): void
    {
        $this->static_context = array_merge($this->static_context, $context);
    }

    /**
     * 添加日志记录回调
     */
    public function addLogCallback(callable $callback): void
    {
        $this->log_callbacks[] = $callback;
    }

    /**
     * 打印执行栈
     */
    public function trace(): void
    {
        $log = 'Stack trace:' . PHP_EOL;
        $trace = debug_backtrace();
        // array_shift($trace);
        foreach ($trace as $i => $t) {
            if (!isset($t['file'])) {
                $t['file'] = 'unknown';
            }
            if (!isset($t['line'])) {
                $t['line'] = 0;
            }
            $log .= "#{$i} {$t['file']}({$t['line']}): ";
            /* @phpstan-ignore-next-line */
            if (isset($t['object']) && is_object($t['object'])) {
                $log .= get_class($t['object']) . '->';
            }
            $log .= "{$t['function']}()" . PHP_EOL;
        }
        if ($this->decorated) {
            $log = $this->colorize($log, $this->castLogLevel(LogLevel::DEBUG));
        }

        // use stream
        if ($this->stream) {
            fwrite($this->stream, $log);
            fflush($this->stream);
        } else {
            // use plain text output
            echo $log;
        }
    }

    /**
     * 根据日志等级将样式应用至指定字符串
     *
     * @param mixed $string 日志内容
     * @param int   $level  日志等级
     */
    public function colorize($string, int $level): string
    {
        $string = $this->stringify($string);
        $styles = self::$styles[$level] ?? [];
        return ConsoleColor::apply($styles, $string)->__toString();
    }

    public function log($level, $message, array $context = []): void
    {
        $level = $this->castLogLevel($level);

        $log_replace = [
            '%date%' => date(self::$date_format),
            '%level_long%' => strtoupper(self::$levels[$level]),
            '%level%' => strtoupper(substr(self::$levels[$level], 0, 4)),
            '%body%' => $message,
            '%level_short%' => strtoupper(substr(self::$levels[$level], 0, 1)),
        ];

        $output = str_replace(array_keys($log_replace), array_values($log_replace), self::$format);
        $output = $this->interpolate($output, array_merge($this->static_context, $context));

        foreach ($this->log_callbacks as $callback) {
            if ($callback($level, $output, $message, $context, $this->shouldLog($level)) === false) {
                return;
            }
        }

        if (!$this->shouldLog($level)) {
            return;
        }

        if ($this->decorated) {
            $output = $this->colorize($output, $level) . PHP_EOL;
        } else {
            $output = $output . PHP_EOL;
        }
        // 递归保护：如果上一次日志写入触发了错误（如终端关闭后 STDOUT/STDERR 破损），
        // 跳过本次输出，防止错误处理器递归调用导致 CPU 100% 空耗
        if (self::$in_log) {
            return;
        }
        self::$in_log = true;
        try {
            // use stream
            if ($this->stream) {
                @fwrite($this->stream, $output);
                @fflush($this->stream);
            } else {
                if ($level <= 4 && $this->use_stderr) {
                    @fwrite(STDERR, $output);
                } else {
                    // use plain text output
                    @echo $output;
                }
            }
        } finally {
            self::$in_log = false;
        }
    }

    public function setDecorated(bool $decorated): void
    {
        $this->decorated = $decorated;
    }

    /**
     * 转换日志等级
     */
    protected function castLogLevel(string $level): int
    {
        if (in_array($level, self::$levels, true)) {
            return array_flip(self::$levels)[$level];
        }

        throw new InvalidArgumentException('Invalid log level: ' . $level);
    }

    /**
     * 将日志内容转换为字符串
     *
     * @param mixed $item 日志内容
     */
    protected function stringify($item): string
    {
        switch (true) {
            case is_callable($item):
                if (is_array($item)) {
                    if (is_object($item[0])) {
                        return get_class($item[0]) . '@' . $item[1];
                    }
                    return $item[0] . '::' . $item[1];
                }
                return 'closure';
            case is_string($item):
                return $item;
            case is_array($item):
                return 'array' . (extension_loaded('json') ? json_encode($item, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_LINE_TERMINATORS) : '');
            case is_object($item):
                return get_class($item);
            case is_resource($item):
                return 'resource(' . get_resource_type($item) . ')';
            case is_null($item):
                return 'null';
            case is_bool($item):
                return $item ? 'true' : 'false';
            case is_float($item):
            case is_int($item):
                return (string) $item;
            default:
                return 'unknown';
        }
    }

    /**
     * 判断是否应该记录该等级日志
     */
    protected function shouldLog(int $level): bool
    {
        return $level <= self::$log_level;
    }

    /**
     * 插入变量到日志内容中
     *
     * @param string $message 日志内容
     * @param array  $context 变量列表
     */
    protected function interpolate(string $message, array $context = []): string
    {
        $replace = [];
        foreach ($context as $key => $value) {
            $replace['{' . $key . '}'] = $this->stringify($value);
        }

        return strtr($message, $replace);
    }
}