Johmanx10\Transaction\Exception\OperationExceptionFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	createFromThrowable()	0	27	4

<?php
/**
 * Copyright MediaCT. All rights reserved.
 * https://www.mediact.nl
 */

namespace Johmanx10\Transaction\Exception;

use Johmanx10\Transaction\Formatter\ExceptionFormatter;
use Johmanx10\Transaction\Formatter\ExceptionFormatterInterface;
use Johmanx10\Transaction\Formatter\FailedRollbackFormatter;
use Johmanx10\Transaction\Formatter\FailedRollbackFormatterInterface;
use Johmanx10\Transaction\Formatter\RollbackFormatter;
use Johmanx10\Transaction\Formatter\RollbackFormatterInterface;
use Throwable;

class OperationExceptionFactory implements OperationExceptionFactoryInterface
{
    /** @var RollbackFormatterInterface */
    private $rollbackFormatter;

    /** @var FailedRollbackFormatterInterface */
    private $failedFormatter;

    /** @var ExceptionFormatterInterface */
    private $exceptionFormatter;

    /**
     * Constructor.
     *
     * @param RollbackFormatterInterface|null       $rollbackFormatter
     * @param FailedRollbackFormatterInterface|null $failedFormatter
     * @param ExceptionFormatterInterface|null      $exceptionFormatter
     */
    public function __construct(
        RollbackFormatterInterface $rollbackFormatter = null,
        FailedRollbackFormatterInterface $failedFormatter = null,
        ExceptionFormatterInterface $exceptionFormatter = null
    ) {
        $this->rollbackFormatter  = $rollbackFormatter ?? new RollbackFormatter();
        $this->failedFormatter    = $failedFormatter ?? new FailedRollbackFormatter();
        $this->exceptionFormatter = $exceptionFormatter ?? new ExceptionFormatter();
    }

    /**
     * Create an operation exception from the given throwable.
     *
     * @param Throwable $subject
     *
     * @return OperationExceptionInterface
     */
    public function createFromThrowable(
        Throwable $subject
    ): OperationExceptionInterface {
        if ($subject instanceof TransactionRolledBackExceptionInterface) {
            [$failure] = $subject->getFailures() + [null];

            return new OperationException(
                $this->rollbackFormatter->format($subject),
                $failure
                    ? $failure->getOperation()
                    : null,
                $subject
            );
        }

        if ($subject instanceof FailedRollbackExceptionInterface) {
            return new OperationException(
                $this->failedFormatter->format($subject),
                $subject->getOperation(),
                $subject
            );
        }

        return new OperationException(
            $this->exceptionFormatter->format($subject),
            null,
            $subject
        );
    }
}