Carno\Database\Chips\TransactionGuard

Complexity

Total Complexity

5

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	transaction()	0	43	5

<?php
/**
 * Transaction guard
 * User: moyo
 * Date: 03/11/2017
 * Time: 11:35 AM
 */

namespace Carno\Database\Chips;

use Carno\Database\Contracts\Executable;
use Carno\Database\Contracts\Transaction as TransAPI;
use Carno\Database\Exception\TransactionException;
use Carno\Database\Programs\Transaction as TransEXE;
use Carno\Pool\Pool;
use Carno\Pool\Poolable;
use Carno\Promise\Promise;
use Closure;
use Throwable;

trait TransactionGuard
{
    /**
     * @param Closure $program
     * @return mixed
     * @throws TransactionException
     */
    public function transaction(Closure $program)
    {
        /**
         * @var Pool $pool
         * @var TransAPI|Executable|Poolable $link
         */
        $pool = $this->assigned();

It seems like assigned() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        $link = yield $pool->select();

        // assigned waiters
        $start = Promise::deferred();
        $commit = Promise::deferred();
        $rollback = Promise::deferred();

        // automatic release after commit
        $commit->then(static function () use ($link) {
            $link->release();

The method release() does not exist on Carno\Database\Contracts\Transaction. It seems like you code against a sub-type of Carno\Database\Contracts\Transaction such as Carno\Database\Connectors\MySQL.

The method release() does not exist on Carno\Database\Contracts\Executable. It seems like you code against a sub-type of Carno\Database\Contracts\Executable such as Carno\Database\Connectors\MySQL.

        });

        // automatic release after rollback
        $rollback->then(static function () use ($link) {
            $link->release();
        });

        // create session for transaction
        $session = new TransEXE($link, $start, $commit, $rollback);

It seems like $link can also be of type Carno\Database\Contracts\Executable and Carno\Pool\Poolable; however, parameter $link of Carno\Database\Programs\Transaction::__construct() does only seem to accept Carno\Database\Contracts\Transaction, maybe add an additional type check?

        // wait for transaction started
        yield $session->begin();

        // flows
        try {
            // call user program
            $finished = yield $program($session);
            // automatic commit
            $commit->pended() && $rollback->pended() && yield $session->commit();
            // finished
            return $finished;
        } catch (Throwable $e) {
            // automatic rollback
            $rollback->pended() && yield $session->rollback();
            // throw to next
            throw $e;
        }
    }
}