kiri-core/kiri-engine/Abstracts/Logger.php

<?php

namespace Kiri\Abstracts;

use DirectoryIterator;
use Exception;
use Kiri\Events\EventProvider;
use Kiri\Exception\ConfigException;
use Kiri;
use Kiri\Server\Events\OnWorkerStop;
use Psr\Log\LoggerInterface;
use ReflectionException;


/**
 *
 */
class Logger implements LoggerInterface
{
	
	const EMERGENCY = 'emergency';
	const ALERT = 'alert';
	const CRITICAL = 'critical';
	const ERROR = 'error';
	const WARNING = 'warning';
	const NOTICE = 'notice';
	const INFO = 'info';
	const DEBUG = 'debug';
	
	
	const LOGGER_LEVELS = [Logger::EMERGENCY, Logger::ALERT, Logger::CRITICAL, Logger::ERROR, Logger::WARNING, Logger::NOTICE, Logger::INFO, Logger::DEBUG];
	
	
	/**
	 * @param string $message
	 * @param array $context
	 * @throws ConfigException
	 *
	 * 紧急情况
	 */
	public function emergency($message, array $context = [])
	{
		// TODO: Implement emergency() method.
		$this->log(Logger::EMERGENCY, $message, $context);
	}
	
	
	/**
	 * @param string $message
	 * @param array $context
	 * @throws ConfigException
	 *
	 * 应该警惕的
	 */
	public function alert($message, array $context = [])
	{
		// TODO: Implement alert() method.
		$this->log(Logger::ALERT, $message, $context);
	}
	
	
	/**
	 * @param string $message
	 * @param array $context
	 * @throws ConfigException
	 *
	 * 关键性的日志
	 */
	public function critical($message, array $context = [])
	{
		// TODO: Implement critical() method.
		$this->log(Logger::CRITICAL, $message, $context);
	}
	
	
	/**
	 * @param string $message
	 * @param array $context
	 * @throws ConfigException
	 */
	public function error($message, array $context = [])
	{
		// TODO: Implement error() method.
		$this->log(Logger::ERROR, $message, $context);
	}
	
	
	/**
	 * @param string $message
	 * @param array $context
	 * @throws ConfigException
	 */
	public function warning($message, array $context = [])
	{
		// TODO: Implement warning() method.
		$this->log(Logger::WARNING, $message, $context);
	}
	
	/**
	 * @param string $message
	 * @param array $context
	 * @throws ConfigException
	 */
	public function notice($message, array $context = [])
	{
		// TODO: Implement notice() method.
		$this->log(Logger::NOTICE, $message, $context);
	}
	
	
	/**
	 * @param string $message
	 * @param array $context
	 * @throws ConfigException
	 */
	public function info($message, array $context = [])
	{
		// TODO: Implement info() method.
		$this->log(Logger::INFO, $message, $context);
	}
	
	
	/**
	 * @param string $message
	 * @param array $context
	 * @throws ConfigException
	 */
	public function debug($message, array $context = [])
	{
		// TODO: Implement debug() method.
		$this->log(Logger::DEBUG, $message, $context);
	}
	
	
	/**
	 * @param mixed $level
	 * @param string $message
	 * @param array $context
	 * @throws ConfigException
	 * @throws Exception
	 */
	public function log($level, $message, array $context = [])
	{
		// TODO: Implement log() method.
		$levels = Config::get('log.level', Logger::LOGGER_LEVELS);
		if (!in_array($level, $levels) || str_contains($message, 'Event::rshutdown')) {
			return;
		}
		
		$_string = '[' . now() . ']' . PHP_EOL . $level . ': ' . $message . PHP_EOL;
		if (!empty($context)) {
			$_string .= $this->_string($context);
		}
		file_put_contents('php://output', $_string);
		
		$filename = storage('log-' . date('Y-m-d') . '.log', 'log/');
		
		file_put_contents($filename, $_string, FILE_APPEND);
	}
	
	
	/**
	 * @return void
	 * @throws Exception
	 */
	public function flush(): void
	{
		$this->removeFile(storage());
	}
	
	
	/**
	 * @param string $dirname
	 * @return void
	 */
	private function removeFile(string $dirname): void
	{
		$paths = new DirectoryIterator($dirname);
		/** @var DirectoryIterator $path */
		foreach ($paths as $path) {
			if ($path->isDot() || str_starts_with($path->getFilename(), '.')) {
				continue;
			}
			if ($path->isDir()) {
				$directory = rtrim($path->getRealPath(), '/');
				$this->removeFile($directory);
			}
			@unlink($path->getRealPath());
		}
	}
	
	
	/**
	 * @param $context
	 * @return string
	 */
	private function _string($context): string
	{
		if ($context instanceof \Throwable) {
			$context = ['file' => $context->getFile(), 'line' => $context->getLine()];
		}
		if (is_array($context) && isset($context[0]) && $context[0] instanceof \Throwable) {
			$context = ['file' => $context[0]->getFile(), 'line' => $context[0]->getLine()];
		}
		return print_r($context, true) . PHP_EOL;
	}
}