Antidot\EventSource\Infrastructure\Bus\TacticianDbalTransactionalMiddleware

Complexity

Total Complexity

3

Size/Duplication

Total Lines	23
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	execute()	0	14	2

<?php

declare(strict_types=1);

namespace Antidot\EventSource\Infrastructure\Bus;

use Doctrine\DBAL\Connection;
use League\Tactician\Middleware;
use Throwable;

class TacticianDbalTransactionalMiddleware implements Middleware
{
    private Connection $connection;

    public function __construct(Connection $connection)
    {
        $this->connection = $connection;
    }

    public function execute($command, callable $next)
    {
        $this->connection->beginTransaction();

        try {
            /** @var mixed $result */
            $result = $next($command);
            $this->connection->commit();
        } catch (Throwable $exception) {
            $this->connection->rollBack();
            throw $exception;
        }

        return $result;
    }
}