hipanel\modules\finance\transaction\ApiTransactionRepository

Complexity

Total Complexity

11

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	findById()	0	16	3
A	insert()	0	4	1
A	create()	0	7	1
A	save()	0	15	2
A	callWithoutAuth()	0	9	1
A	instantiate()	0	13	2

<?php

namespace hipanel\modules\finance\transaction;

use hiqdev\hiart\ConnectionInterface;
use hiqdev\hiart\ResponseErrorException;
use hiqdev\yii2\merchant\transactions\Transaction;
use hiqdev\yii2\merchant\transactions\TransactionException;
use hiqdev\yii2\merchant\transactions\TransactionRepositoryInterface;
use ReflectionObject;
use yii\helpers\Json;

class ApiTransactionRepository implements TransactionRepositoryInterface
{
    /**
     * @var ConnectionInterface
     */
    private $connection;

    /**
     * ApiTransactionRepository constructor.
     * @param ConnectionInterface $connection
     */
    function __construct(ConnectionInterface $connection)

It is generally recommended to explicitly declare the visibility for methods.

    {
        $this->connection = $connection;
    }

    /**
     * @param string $id
     * @return Transaction
     * @throws TransactionException when transaction with the specified ID
     * does not exists
     */
    public function findById($id)
    {
        try {
            $data = $this->callWithoutAuth(function () use ($id) {
                return $this->connection->createCommand()->perform('merchantTransactionGet', null, ['id' => $id]);
            });
        } catch (ResponseErrorException $e) {
            throw new TransactionException('Failed to get transaction information');
        }

        if (empty($data)) {
            throw new TransactionException('Transaction not found');
        }

        return $this->instantiate($data);
    }

    /**
     * @inheritdoc
     */
    public function insert($transaction)
    {
        return $this->save($transaction);
    }

    /**
     * @inheritdoc
     */
    public function create($id, $merchant, $parameters)
    {
        $transaction = new Transaction($id, $merchant);
        $transaction->setParameters($parameters);

        return $transaction;
    }

    /**
     * @inheritdoc
     */
    public function save($transaction)
    {
        try {
            $data = $transaction->toArray();
            $data['parameters'] = Json::encode($data['parameters']);

            $this->callWithoutAuth(function () use ($data) {
                return $this->connection->createCommand()->perform('merchantTransactionSet', null, $data);
            });
        } catch (ResponseErrorException $e) {
            throw new TransactionException('Failed to save transaction');
        }

        return $transaction;
    }

    private function callWithoutAuth(\Closure $function)
    {
        try {
            $this->connection->disableAuth();
            return call_user_func($function);
        } finally {
            $this->connection->enableAuth();
        }
    }

    /**
     * @param $data
     * @return Transaction
     */
    protected function instantiate($data)
    {
        $transaction = $this->create($data['id'], $data['merchant'], $data['parameters']);

        if ($data['success'] !== null) {
            $successReflection = (new ReflectionObject($transaction))->getProperty('success');
            $successReflection->setAccessible(true);
            $successReflection->setValue($transaction, $data['success']);
            $successReflection->setAccessible(false);
        }

        return $transaction;
    }
}