ldc-arcadia-api/src/Infra/Usecase/LaravelExecutor.php

75 lines
2.3 KiB
PHP

<?php
declare(strict_types=1);
namespace Infra\Usecase;
use Illuminate\Database\DatabaseManager;
use Psr\Log\LoggerInterface;
use Shared\DDD\Security\UserDetailsProvider;
use Shared\DDD\Usecase\Builder\UsecaseExecutor;
use Shared\DDD\Usecase\Input;
use Shared\DDD\Usecase\Presenter;
use Shared\DDD\Usecase\Usecase;
final readonly class LaravelExecutor implements UsecaseExecutor
{
public function __construct(
private DatabaseManager $database,
private LoggerInterface $logger,
private ?UserDetailsProvider $userDetailsProvider = null,
) {
}
/**
* @template TInput of Input
* @template TOutput of \Shared\DDD\Usecase\Output
* @template TView of object
*
* @param Usecase<TInput, TOutput> $usecase
* @param TInput $input
* @param Presenter<TOutput, TView> $presenter
* @return TView
*/
#[\Override]
public function execute(Usecase $usecase, Input $input, Presenter $presenter): object
{
$currentUser = $this->userDetailsProvider?->currentUser();
$context = [
'usecase' => $usecase::class,
'input' => $input::class,
'presenter' => $presenter::class,
'user' => $currentUser ? [
'id' => $currentUser->id(),
'name' => $currentUser->name(),
'type' => $currentUser->type()->type(),
'identifier' => $currentUser->identifier(),
] : null,
];
$this->logger->debug('Starting usecase execution', $context);
try {
$result = $this->database->transaction(function () use ($usecase, $input, $presenter): object {
$output = $usecase->execute($input);
return $presenter->present($output);
});
$this->logger->info('Usecase executed successfully', $context);
/** @var TView */
return $result;
} catch (\Throwable $e) {
$this->logger->error('Usecase execution failed: ' . $e->getMessage(), [
...$context,
'exception' => $e::class,
'file' => $e->getFile(),
'line' => $e->getLine(),
]);
throw $e;
}
}
}