Shetabit\Multipay\Drivers\Payfa\Payfa

Complexity

Total Complexity

12

Size/Duplication

Total Lines	148
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	extractDetails()	0	3	2
A	pay()	0	5	1
A	createReceipt()	0	3	1
A	__construct()	0	5	1
A	verify()	0	23	2
A	purchase()	0	36	3
A	notVerified()	0	6	2

<?php

namespace Shetabit\Multipay\Drivers\Payfa;

use GuzzleHttp\Client;
use Shetabit\Multipay\Abstracts\Driver;
use Shetabit\Multipay\Contracts\ReceiptInterface;
use Shetabit\Multipay\Exceptions\InvalidPaymentException;
use Shetabit\Multipay\Exceptions\PurchaseFailedException;
use Shetabit\Multipay\Invoice;
use Shetabit\Multipay\Receipt;
use Shetabit\Multipay\RedirectionForm;
use Shetabit\Multipay\Request;

class Payfa extends Driver
{
    /**
     * Payfa Client.
     *
     * @var object
     */
    protected $client;

    /**
     * Invoice
     *
     * @var Invoice
     */
    protected $invoice;

    /**
     * Driver settings
     *
     * @var object
     */
    protected $settings;

    /**
     * Payfa constructor.
     * Construct the class with the relevant settings.
     *
     * @param Invoice $invoice
     * @param $settings
     */
    public function __construct(Invoice $invoice, $settings)
    {
        $this->invoice($invoice); // Set the invoice.
        $this->settings = (object)$settings; // Set settings.
        $this->client = new Client();
    }

    /**
     * Retrieve data from details using its name.
     *
     * @return string
     */
    private function extractDetails($name)
    {
        return empty($this->invoice->getDetails()[$name]) ? null : $this->invoice->getDetails()[$name];
    }

    public function purchase()
    {
        $mobile = $this->extractDetails('mobile');
        $cardNumber = $this->extractDetails('cardNumber');

        $data = array(
            'amount' => $this->invoice->getAmount() * ($this->settings->currency == 'T' ? 10 : 1), // convert to rial
            'callbackUrl' => $this->settings->callbackUrl,
            'mobileNumber' => $mobile,
            'invoiceId' => $this->invoice->getUuid(),
            'cardNumber' => $cardNumber
        );

        $response = $this->client->request(
            'POST',
            $this->settings->apiPurchaseUrl,
            [
                "json" => $data,
                "http_errors" => false,
                "headers" => [
                    "X-API-Key" => $this->settings->apiKey,
                    'Content-Type' => 'application/json',
                ]
            ]
        );
        $body = json_decode($response->getBody()->getContents(), true);


        if ($response->getStatusCode() != 200) {
            throw new PurchaseFailedException($body["title"]);
        }

        $this->invoice->transactionId($body['paymentId']);

        // return the transaction's id
        return $this->invoice->getTransactionId();
    }

    /**
     * Pay the Invoice
     *
     * @return RedirectionForm
     */
    public function pay(): RedirectionForm
    {
        $payUrl = $this->settings->apiPaymentUrl . $this->invoice->getTransactionId();

        return $this->redirectWithForm($payUrl, [], 'GET');
    }


    /**
     * Verify payment
     *
     * @return ReceiptInterface
     *
     * @throws InvalidPaymentException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function verify(): ReceiptInterface
    {
        $paymentId = $this->invoice->getTransactionId() ?? Request::input('paymentId');


        $response = $this->client->request(
            'POST',
            $this->settings->apiVerificationUrl . $paymentId,
            [
                "http_errors" => false,
                "headers" => [
                    "X-API-Key" => $this->settings->apiKey,
                    'Content-Type' => 'application/json',
                ]
            ]
        );
        $body = json_decode($response->getBody()->getContents(), true);

        if ($response->getStatusCode() != 200) {
            $this->notVerified($body["message"], $response->getStatusCode());
        }

        return $this->createReceipt($body['transactionId']);
    }

    protected function createReceipt($referenceId)
    {
        return new Receipt('payfa', $referenceId);
    }

    /**
     * Trigger an exception
     *
     * @param $message
     * @throws InvalidPaymentException
     */
    private function notVerified($message, $status)
    {
        if (empty($message)) {
            throw new InvalidPaymentException('خطای ناشناخته ای رخ داده است.', (int)$status);
        } else {
            throw new InvalidPaymentException($message, (int)$status);
        }
    }
}