LoggerFactory.php

<?php

declare(strict_types=1);

namespace Phenix\Logging;

use Amp\ByteStream;
use Amp\Cluster\Cluster;
use Amp\Log\ConsoleFormatter;
use Amp\Log\StreamHandler;
use Monolog\Formatter\LineFormatter;
use Monolog\Level;
use Monolog\Logger;
use Monolog\Processor\PsrLogMessageProcessor;
use Phenix\Constants\ServerMode;
use Phenix\Contracts\Makeable;
use Phenix\Exceptions\RuntimeError;
use Phenix\Facades\Config;
use Phenix\Facades\File;

class LoggerFactory implements Makeable
{
    public static function make(string $key, ServerMode $serverMode = ServerMode::SINGLE): Logger
    {
        /** @var int|string|null $levelConfig */
        $levelConfig = Config::get('app.debug_level');
        $level = Level::tryFrom((int) $levelConfig) ?? Level::Debug;

        if ($serverMode === ServerMode::CLUSTER && Cluster::isWorker()) {
            $logHandler = Cluster::createLogHandler($level);
        } else {
            $logHandler = match ($key) {
                'file' => self::fileHandler($level),
                'stream' => self::streamHandler($level),
                default => throw new RuntimeError("Unsupported logging channel: {$key}"),
            };
        }

        $logger = new Logger(self::buildName($serverMode));
        $logger->pushHandler($logHandler);

        return $logger;
    }

    private static function streamHandler(Level $level): StreamHandler
    {
        $logHandler = new StreamHandler(ByteStream\getStdout(), $level);
        $logHandler->pushProcessor(new PsrLogMessageProcessor());
        $logHandler->setFormatter(new ConsoleFormatter());

        return $logHandler;
    }

    private static function fileHandler(Level $level): StreamHandler
    {
        $path = Config::get('logging.path');

        if (! File::exists($path)) {
            File::put($path, '');
        }

        $file = File::openFile($path, 'a');

        $logHandler = new StreamHandler($file, $level);
        $logHandler->pushProcessor(new PsrLogMessageProcessor());
        $logHandler->setFormatter(new LineFormatter());

        return $logHandler;
    }

    private static function buildName(ServerMode $serverMode = ServerMode::SINGLE): string
    {
        if ($serverMode === ServerMode::CLUSTER && Cluster::isWorker()) {
            return 'phenix-worker-' . (Cluster::getContextId() ?? getmypid());
        }

        return 'phenix';
    }
}