LokiLoggerAttachment.php

<?php

namespace libLokiLogger;

use pocketmine\thread\Thread;
use pocketmine\thread\Worker;
use pocketmine\utils\TextFormat;
use ReflectionClass;
use ThreadedLoggerAttachment;

class LokiLoggerAttachment extends ThreadedLoggerAttachment
{
    /** @var LokiLoggerThread */
    private LokiLoggerThread $lokiInstance;

    public function __construct()
    {
        $this->lokiInstance = LokiLoggerThread::getInstance();
    }

    public function log($level, $message)
    {
        $thread = Thread::getCurrentThread();
        if ($thread === null) {
            $threadName = "Server thread";
        } elseif ($thread instanceof Thread or $thread instanceof Worker) {
            $threadName = $thread->getThreadName() . " thread";
        } else {
            $threadName = (new ReflectionClass($thread))->getShortName() . " thread";
        }

        $this->lokiInstance->write(preg_filter('/^\[(.*?)] /', '', TextFormat::clean($message)), ['level' => $level, 'thread' => $threadName]);
    }
}