Dazzle\PgSQL\Transaction\Transaction

Complexity

Total Complexity

11

Size/Duplication

Total Lines	95
Duplicated Lines	21.05 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	isOpen()	0	4	1
A	query()	0	4	1
A	execute()	0	4	1
A	begin()	0	14	3
A	commit()	10	10	2
A	rollback()	10	10	2

<?php
namespace Dazzle\PgSQL\Transaction;

use Dazzle\Event\BaseEventEmitter;
use Dazzle\Event\EventEmitterInterface;
use Dazzle\PgSQL\Result\CommandResultStatement;
use Dazzle\Promise\Promise;
use Dazzle\PgSQL\Connection\ConnectorInterface;

class Transaction extends BaseEventEmitter implements TransactionInterface
{
    /**
     * @var ConnectorInterface
     */
    protected $connector;

    /**
     * @var bool
     */
    protected $open;

    /**
     * @param ConnectorInterface $connector
     * @param EventEmitterInterface $emitter
     */
    public function __construct(ConnectorInterface $connector, EventEmitterInterface $emitter)
    {
        $this->connector = $connector;
        $this->emitter = $emitter;

The property emitter does not seem to exist. Did you mean emitterBlocked?

        $this->open = false;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function isOpen()
    {
        return $this->open;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function query($sql, array $sqlParams = [])
    {
        return $this->connector->query($sql, $sqlParams);
    }

    /**
     * @override
     * @inheritDoc
     */
    public function execute($sql, array $sqlParams = [])
    {
        return $this->connector->execute($sql, $sqlParams);
    }

    public function begin()
    {
        if ($this->isOpen()) {
            return Promise::doResolve($this);
        }

        return $this->connector->execute('BEGIN')->success(function (CommandResultStatement $result) {
            if ($result) {
                $this->emitter->emit('transaction:begin');

The property emitter does not seem to exist. Did you mean emitterBlocked?

            }

            return $this;
        });
    }

    /**
     * @override
     * @inheritDoc
     */
    public function commit()

This method seems to be duplicated in your project.

    {
       return $this->connector->execute('COMMIT')->success(function (CommandResultStatement $result) {
           if ($result) {
               $this->emitter->emit('transaction:end');

The property emitter does not seem to exist. Did you mean emitterBlocked?

           }

           return $result;
       });
    }

    /**
     * @override
     * @inheritDoc
     */
    public function rollback()

This method seems to be duplicated in your project.

    {
       return $this->connector->execute('ROLLBACK')->success(function (CommandResultStatement $result) {
           if ($result) {
               $this->emitter->emit('transaction:end');    

The property emitter does not seem to exist. Did you mean emitterBlocked?

           }

           return $result;
       });
    }
}