Carno\Database\Chips\TransactionGuard::transaction()

Complexity

Conditions	5
Paths	9

Size

Total Lines	43
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    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;
        }