mimmi20/monolog-factory

<?php

/**
 * This file is part of the mimmi20/monolog-factory package.
 *
 * Copyright (c) 2022-2024, Thomas Mueller <mimmi20@live.de>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types = 1);

namespace Mimmi20\MonologFactory;

use Laminas\ServiceManager\AbstractPluginManager;
use Laminas\ServiceManager\Exception\ServiceNotCreatedException;
use Laminas\ServiceManager\Exception\ServiceNotFoundException;
use Monolog\LogRecord;
use Monolog\Processor\ProcessorInterface;
use Psr\Container\ContainerExceptionInterface;

use function array_key_exists;
use function assert;
use function is_callable;
use function sprintf;

trait CreateProcessorTrait
{
    /**
     * @param array<string, array<string, mixed>|bool|string>|callable $processorConfig
     * @phpstan-param (callable(LogRecord): LogRecord)|array{enabled?: bool, type?: string, options?: array<mixed>} $processorConfig
     * @phpstan-param AbstractPluginManager<ProcessorInterface> $monologProcessorPluginManager
     *
     * @phpstan-return (callable(LogRecord): LogRecord)|null
     *
     * @throws ServiceNotCreatedException
     * @throws ServiceNotFoundException
     */
    private function createProcessor(
        array | callable $processorConfig,
        AbstractPluginManager $monologProcessorPluginManager,
    ): callable | null {
        if (is_callable($processorConfig)) {
            return $processorConfig;
        }

        if (array_key_exists('enabled', $processorConfig) && !$processorConfig['enabled']) {
            return null;
        }

        if (!array_key_exists('type', $processorConfig)) {
            throw new ServiceNotCreatedException('Options must contain a type for the processor');
        }

        try {
            $processor = $monologProcessorPluginManager->get(
                $processorConfig['type'],
                $processorConfig['options'] ?? [],
            );
        } catch (ContainerExceptionInterface $e) {
            throw new ServiceNotFoundException(
                sprintf('Could not find service %s', $processorConfig['type']),
                0,
                $e,
            );
        }

        assert(is_callable($processor) || $processor === null);

        return $processor;
    }
}