Samerior\MobileMoney\Equity\Library\Transactor

Complexity

Total Complexity

19

Size/Duplication

Total Lines	292
Duplicated Lines	3.42 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

15 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	process()	0	8	1
A	initialize()	0	7	1
A	setBearer()	0	16	2
A	handle()	0	6	1
A	checkPaymentStatus()	0	8	1
A	createPayment()	0	20	1
A	setTimestamp()	0	9	2
A	setPayBill()	0	6	1
A	setupKeys()	0	14	1
A	getTransactionNumber()	0	5	1
A	generateTransactionNumber()	10	10	2
A	validateKeys()	0	4	1
A	send()	0	8	1
A	validateResponse()	0	15	2

<?php

namespace Samerior\MobileMoney\Equity\Library;

use Carbon\Carbon;
use Samerior\MobileMoney\Exceptions\EquityException;
use DOMDocument;
use GuzzleHttp\Client;
use Ixudra\Curl\Facades\Curl;

/**
 * Class Transactor
 * @package Samerior\MobileMoney\Equity\Library
 */
class Transactor
{
    protected $bearer;
    /**
     * The hashed password.
     *
     * @var string
     */
    protected $password;
    /**
     * The transaction timestamp.
     *
     * @var int
     */
    protected $timestamp;
    /**
     * The transaction reference id
     *
     * @var int
     */
    protected $referenceId;
    /**
     * The amount to be deducted
     *
     * @var int
     */
    protected $amount;
    /**
     * The Mobile Subscriber number to be billed.
     * Must be in format 2547XXXXXXXX.
     *
     * @var int
     */
    protected $number;
    /**
     * The keys and data to fill in the request body.
     *
     * @var array
     */
    protected $keys;
    /**
     * The request to be sent to the endpoint
     *
     * @var string
     */
    protected $request;
    /**
     * The generated transaction number by the Transactable implementer.
     *
     * @var string
     */
    protected $transactionNumber;
    /**
     * The Guzzle Client used to make the request to the endpoint.
     *
     * @var Client
     */
    private $client;
    /**
     * @var EquityRepository
     */
    private $repository;

    /**
     * Transactor constructor.
     * @param EquityRepository $repository
     */
    public function __construct(EquityRepository $repository)
    {
        $this->client = new Client([
            'verify' => false,
            'timeout' => 60,
            'allow_redirects' => false,
            'expect' => false,
        ]);
        $this->repository = $repository;
    }

    /**
     * Process the transaction request.
     *
     * @param $amount
     * @param $number
     * @param $referenceId
     *
     * @return mixed|\Psr\Http\Message\ResponseInterface
     */
    public function process($amount, $number, $referenceId)
    {
        $this->amount = $amount;
        $this->number = $number;
        $this->referenceId = $referenceId;
        $this->initialize();
        return $this->handle();
    }

    /**
     * Initialize the transaction.
     */
    protected function initialize()
    {
        $this->setTimestamp();
        $this->getTransactionNumber();
        $this->setBearer();
//        $this->setupKeys();
    }

    /**
     * @throws EquityException
     */
    private function setBearer()
    {
        $response = Curl::to($this->repository->endpoint->identity . '/token')
            ->withHeader('Authorization: Basic ' . $this->repository->authBasic)->returnResponseObject()
            ->withData([
                'username' => $this->repository->username,
                'password' => $this->repository->password,
                'grant_type' => 'password'])
            ->post();
        $data = json_decode($response->content);
        if (!empty($data->access_token)) {
            $this->bearer = $data->access_token;
        } else {
            throw  new EquityException("Authentication Failed");
        }
    }

    /**
     * Validate and execute the transaction.
     * @todo Check Payment Status
     * @return mixed|\Psr\Http\Message\ResponseInterface
     */
    protected function handle()
    {
        $result = $this->createPayment();
        $status = $this->checkPaymentStatus($result->content);
        return (object)['result' => $result->content, 'status' => json_decode($status->content), 'reference' => $this->transactionNumber];
    }

    public function checkPaymentStatus($result)
    {
        $ref = $result->transactionRef;
        $url = $this->repository->endpoint->transaction . '/payments/' . $ref;
        return Curl::to($url)
            ->withHeader('Authorization: Bearer ' . $this->bearer)
            ->returnResponseObject()->get();
    }

    /**
     * Create Payment Payload
     */
    private function createPayment()
    {
        $url = $this->repository->endpoint->transaction . '/payments';
        return Curl::to($url)
            ->withHeader('Authorization: Bearer ' . $this->bearer)
            ->returnResponseObject()
            ->withData([
                'customer' => [
                    'mobileNumber' => '254763555289'
                ],
                'transaction' => [
                    "amount" => "50000",
                    "description" => "Payment",
                    "type" => "StkRequest Payment",
                    "auditNumber" => $this->transactionNumber,
                ]
            ])
            ->asJson()
            ->post();
    }

    /**
     * Set the transaction timestamp.
     */
    private function setTimestamp()
    {
        if ($this->repository->demo) {
            $this->timestamp = '20160510161908';

The property $timestamp was declared of type integer, but '20160510161908' is of type string. Maybe add a type cast?

            return $this->timestamp;
        }
        $this->timestamp = Carbon::now()->format('YmdHis');

The property $timestamp was declared of type integer, but \Carbon\Carbon::now()->format('YmdHis') is of type string. Maybe add a type cast?

        return $this->timestamp;
    }

    /**
     * Override the config pay bill number and pass key.
     *
     * @param $payBillNumber
     * @param $payBillPassKey
     *
     * @return $this
     */
    public function setPayBill($payBillNumber, $payBillPassKey)
    {
        $this->repository->paybillNumber = $payBillNumber;
        $this->repository->passkey = $payBillPassKey;
        return $this;
    }


    /**
     * Map the document fields with the transaction details.
     * @throws \Exception
     */
    protected function setupKeys()
    {
        $this->keys = [
            // 'VA_PAYBILL' => $this->repository->paybillNumber,
            'VA_PASSWORD' => $this->password,
            'VA_TIMESTAMP' => $this->timestamp,
            'VA_TRANS_ID' => $this->getTransactionNumber(),
            'VA_REF_ID' => $this->referenceId,
            'VA_AMOUNT' => $this->amount,
            'VA_NUMBER' => $this->number,
            'VA_CALL_URL' => $this->repository->callbackUrl,
            'VA_CALL_METHOD' => $this->repository->callbackMethod,
        ];
    }

    /**
     * Get the transaction number from the  implementer.
     *
     * @return string
     */
    private function getTransactionNumber(): string
    {
        $this->transactionNumber = $this->generateTransactionNumber();
        return $this->transactionNumber;
    }

    /**
     * @return string
     */
    private function generateTransactionNumber(): string

This method seems to be duplicated in your project.

    {
        $characters = '0123456789';
        $charactersLength = strlen($characters);
        $randomString = '';
        for ($i = 0; $i < 10; $i++) {
            $randomString .= $characters[random_int(0, $charactersLength - 1)];
        }
        return $randomString;
    }

    /**
     * Validate the required fields
     */
    private function validateKeys()

This method is not used, and could be removed.

    {
        Validator::validate($this->keys);
    }


    /**
     * Execute the request.
     *
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    private function send()

This method is not used, and could be removed.

    {
        $response = $this->client->request('POST', $this->repository->endpoint, [
            'body' => $this->request
        ]);
        $this->validateResponse($response);

$response is of type object<Psr\Http\Message\ResponseInterface>, but the function expects a object<Samerior\MobileMoney\Equity\Library\Response>.

        return $response;
    }

    /**
     * Validate the response is a success, throw error if not.
     *
     * @param Response $response
     *
     * @throws TransactionException
     * @throws EquityException
     */
    private function validateResponse($response)
    {
        $message = $response->getBody()->getContents();
        $response->getBody()->rewind();
        $doc = new DOMDocument();
        $doc->loadXML($message);
        $responseCode = $doc->getElementsByTagName('RETURN_CODE')->item(0)->nodeValue;
        if ($responseCode != '00') {
            $responseDescription = $doc
                ->getElementsByTagName('DESCRIPTION')
                ->item(0)
                ->nodeValue;
            throw new EquityException('Failure - ' . $responseDescription);
        }
    }
}