kiri-core/kiri-engine/Error/LoggerProcess.php

<?php


namespace Kiri\Error;


use Exception;
use JetBrains\PhpStorm\Pure;
use Kiri\Core\Json;
use Kiri\Exception\ComponentException;
use Kiri\Kiri;
use Swoole\Coroutine;
use Swoole\Process;
use Server\Abstracts\BaseProcess;

/**
 * Class LoggerProcess
 * @package Kiri\Error
 */
class LoggerProcess extends BaseProcess
{

	/**
	 * @param Process $process
	 * @return string
	 */
	#[Pure] public function getProcessName(Process $process): string
	{
		// TODO: Implement getProcessName() method.
		return get_called_class();
	}


	/**
	 * @param Process $process
	 * @throws ComponentException
	 */
	public function onHandler(Process $process): void
	{
		// TODO: Implement onHandler() method.
		$this->message($process);
	}


	/**
	 * @param Process $process
	 * @throws ComponentException
	 * @throws Exception
	 */
	public function message(Process $process)
	{
		if ($this->checkProcessIsStop()) {
			$this->exit();
			return;
		}
		$message = Json::decode($process->read());
		if (!empty($message)) {
			Kiri::writeFile($this->getDirName($message), $message[0], FILE_APPEND);

			$this->checkLogFile($message[1]);
		}

		Coroutine\System::sleep(1);

		$this->message($process);
	}


	/**
	 * @param $message
	 * @return string
	 * @throws Exception
	 */
	private function getDirName($message): string
	{
		return storage('server-' . date('Y-m-d') . '.log', $message[1]);
	}


	/**
	 * @param $dirName
	 * @throws Exception
	 */
	private function checkLogFile($dirName)
	{
		$files = new \DirectoryIterator(storage(null, $dirName));
		if ($files->getSize() < 15) {
			return;
		}
		Coroutine\System::exec('find ' . storage(null, $dirName) . '/ -mtime +15 -name "*.log" -exec rm -rf {} \;');
	}

}