Gielfeldt\TransactionalPHP\Operation

Complexity

Total Complexity

19

Size/Duplication

Total Lines	224
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes	7
Bugs	3	Features	1

14 Methods

Rating	Name	Duplication	Size	Complexity
A	onCommit()	0	5	1
A	onRollback()	0	5	1
A	onBuffer()	0	5	1
A	getCommitCallbacks()	0	4	1
A	getRollbackCallbacks()	0	4	1
A	getBufferCallbacks()	0	4	1
A	setValue()	0	5	1
A	getValue()	0	4	2
A	getResult()	0	4	1
A	setIdx()	0	5	1
A	idx()	0	5	2
A	commit()	0	7	2
A	rollback()	0	7	2
A	buffer()	0	7	2

<?php

namespace Gielfeldt\TransactionalPHP;

/**
 * Class Operation
 *
 * @package Gielfeldt\TransactionalPHP
 */
class Operation
{
    /**
     * The index in the buffer, keyed by connection id.
     *
     * @var string[]
     */
    protected $idx;

    /**
     * Callback for commit.
     *
     * @var callable
     */
    protected $commit = [];

    /**
     * Callback for rollback.
     *
     * @var callable
     */
    protected $rollback = [];

    /**
     * Callback for buffer.
     *
     * @var callable
     */
    protected $buffer = [];

    /**
     * Value for operation.
     *
     * @var mixed
     */
    protected $value;

    /**
     * Result of callback execution.
     *
     * @var mixed
     */
    protected $result;

    /**
     * Set commit callback.
     *
     * @param callable $callback
     *   The callback when this operation is committed.
     *
     * @return $this
     */
    public function onCommit(callable $callback)
    {
        $this->commit[] = $callback;
        return $this;
    }

    /**
     * Set rollback callback.
     *
     * @param callable $callback
     *   The callback when this operation is rolled back.
     *
     * @return $this
     */
    public function onRollback(callable $callback)
    {
        $this->rollback[] = $callback;
        return $this;
    }

    /**
     * Set buffer callback.
     *
     * @param callable $callback
     *   The callback when this operation is buffered.
     *
     * @return $this
     */
    public function onBuffer(callable $callback)
    {
        $this->buffer[] = $callback;
        return $this;
    }

    /**
     * Get commit callback.
     *
     * @return callable|null
     */
    public function getCommitCallbacks()
    {
        return $this->commit;
    }

    /**
     * Get rollback callback.
     *
     * @return callable|null
     */
    public function getRollbackCallbacks()
    {
        return $this->rollback;
    }

    /**
     * Get buffer callback.
     *
     * @return callable|null
     */
    public function getBufferCallbacks()
    {
        return $this->buffer;
    }

    /**
     * @param mixed $value
     *   The value to set.
     *
     * @return $this
     */
    public function setValue($value)
    {
        $this->value = $value;
        return $this;
    }

    /**
     * Get value.
     *
     * @return mixed
     */
    public function getValue()
    {
        return is_callable($this->value) ? call_user_func($this->value) : $this->value;
    }

    /**
     * Get result from callback.
     *
     * @return mixed
     */
    public function getResult()
    {
        return $this->result;
    }

    /**
     * @param Connection $connection
     *   The connection to use for this id.
     * @param string $idx
     *   The id.
     *
     * @return $this
     */
    public function setIdx(Connection $connection, $idx)
    {
        $this->idx[$connection->connectionId()] = $idx;
        return $this;
    }

    /**
     * Get id.
     *
     * @param Connection $connection
     *   The connection to get id from.
     *
     * @return string|null
     */
    public function idx(Connection $connection)
    {
        $connectionId = $connection->connectionId();
        return isset($this->idx[$connectionId]) ? $this->idx[$connectionId] : null;
    }

    /**
     * Execute commit operation.
     *
     * @param Connection $connection
     *   The connection to run this operation on.
     *
     * @return mixed
     */
    public function commit($connection = null)
    {
        foreach ($this->commit as $callback) {

The expression $this->commit of type callable is not traversable.

            $this->result = call_user_func($callback, $this, $connection);
        }
        return $this->result;
    }

    /**
     * Execute rollback operation.
     *
     * @param Connection $connection
     *   The connection to run this operation on.
     *
     * @return mixed
     */
    public function rollback($connection = null)
    {
        foreach ($this->rollback as $callback) {

The expression $this->rollback of type callable is not traversable.

            $this->result = call_user_func($callback, $this, $connection);
        }
        return $this->result;
    }

    /**
     * Execute buffer operation.
     *
     * @param Connection $connection
     *   The connection to run this operation on.
     *
     * @return mixed
     */
    public function buffer($connection = null)
    {
        foreach ($this->buffer as $callback) {

The expression $this->buffer of type callable is not traversable.

            $this->result = call_user_func($callback, $this, $connection);
        }
        return $this->result;
    }
}