BEAR\Resource\SemanticLog\SemanticResourceInvokerAdapter

Complexity

Total Complexity

5

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	invoke()	0	49	4
A	__construct()	0	5	1

<?php

declare(strict_types=1);

namespace BEAR\Resource\SemanticLog;

use BEAR\Resource\AbstractRequest;
use BEAR\Resource\InvokerInterface;
use BEAR\Resource\ResourceObject;
use Koriym\SemanticLogger\SemanticLoggerInterface;

The type Koriym\SemanticLogger\SemanticLoggerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Override;
use Ray\Di\Di\Named;
use Throwable;

use function array_merge;
use function get_class;
use function is_array;
use function property_exists;
use function strtolower;
use function ucfirst;

final class SemanticResourceInvokerAdapter implements InvokerInterface
{
    public function __construct(
        #[Named('Original')]
        private InvokerInterface $invoker,
        private SemanticLoggerInterface $semanticLogger,
    ) {
    }

    #[Override]
    public function invoke(AbstractRequest $request): ResourceObject
    {
        // Use resource class name for better traceability
        $resourceClass = get_class($request->resourceObject);

        // Convert HTTP method to resource method (GET -> onGet)
        $resourceMethod = 'on' . ucfirst(strtolower($request->method));

        // Combine query and body parameters for complete parameter context
        $parameters = array_merge(
            $request->query,
            property_exists($request, 'body') && is_array($request->body) ? $request->body : [],
        );

        /** @var array<string, mixed> $parameters */
        $context = new ResourceOpenContext(
            $resourceClass,
            $resourceMethod,
            $parameters,
        );

        $openId = $this->semanticLogger->open($context);

        try {
            $result = $this->invoker->invoke($request);

            $closeContext = new ResourceCompleteContext(
                $resourceClass,
                $resourceMethod,
                $result->code,
                /** @var array<string, mixed> */
                (array) $result->body,
            );

            $this->semanticLogger->close($closeContext, $openId);

            return $result;
        } catch (Throwable $e) {
            $errorContext = new ResourceErrorContext(
                $resourceClass,
                $resourceMethod,
                $e::class,
                $e->getMessage(),
            );

            $this->semanticLogger->close($errorContext, $openId);

            throw $e;
        }
    }
}