Shetabit\Multipay\Drivers\Payping\Payping

Complexity

Total Complexity

26

Size/Duplication

Total Lines	394
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	convertStatusCodeToMessage()	0	14	1
A	createMultiRequest()	0	40	3
A	purchase()	0	46	3
A	createSingleRequest()	0	43	3
A	__construct()	0	5	1
A	verify()	0	33	3
A	notVerified()	0	3	1
A	pay()	0	5	1
A	extractDetails()	0	3	2
A	createReceipt()	0	5	1
A	verifyPayment()	0	30	2
A	getClientUserProfile()	0	26	3
A	call()	0	7	2

<?php

namespace Shetabit\Multipay\Drivers\Payping;

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

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

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

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

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

    /**
     * Payping constructor.
     * Construct the class with the relevant settings.
     *
     * @param Invoice $invoice
     * @param $settings
     */
    public function __construct(Invoice $invoice, $settings)
    {
        $this->invoice($invoice);
        $this->settings = (object) $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];
    }

    /**
     * Create payment request as single.
     *
     * @return data

The type Shetabit\Multipay\Drivers\Payping\data was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    private function createSingleRequest($data = array())
    {
        $data = [
            'payerName' => 'bdok',
            'amount'         => $data['amount'],
            'payerIdentity' => $data['userName'],
            'returnUrl'     => $data['returnUrl'],
            'clientRefId' => $data['clientRefId'],
            'description' => $data['description']
        ];

        $response = $this
            ->client
            ->request(
                'POST',
                'https://api.payping.ir/v1/pay',
                [
                    'json' => $data,
                    "headers" => [
                        "Accept" => "application/json",
                        "Authorization" => sprintf('Bearer %s', $this->settings->accessToken),
                    ],
                    "http_errors" => false,
                ]
            );

        $responseBody = mb_strtolower($response->getBody()->getContents());
        $body = @json_decode($responseBody, true);
        $statusCode = (int) $response->getStatusCode();

        if ($statusCode !== 200) {
            // some error has happened
            $message = is_array($body) ? array_pop($body) : $this->convertStatusCodeToMessage($statusCode);
            throw new PurchaseFailedException($message);
        }

        $minutes = now()->addSecond(60 * 5);

The function now was not found. Maybe you did not declare it correctly or list all dependencies?

        cache(['transactionId' => $body['code']], $minutes);

The function cache was not found. Maybe you did not declare it correctly or list all dependencies?

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

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

The expression return $this->invoice->getTransactionId() returns the type string which is incompatible with the documented return type Shetabit\Multipay\Drivers\Payping\data.

    }

    /**
     * Verify payment.
     *
     * @return data
     */
    private function verifyPayment($data = array())
    {
        $pAccessToken = $data['pAccessToken'];
        $data = [
            'refId' => $data['refid'],
            'amount' => $data['orgAmount']
        ];
        $response = $this
            ->client
            ->request(
                'POST',
                'https://api.payping.ir/v1/pay/verify',
                [
                    'json' => $data,
                    "headers" => [
                        "Accept" => "application/json",
                        "Authorization" => sprintf('Bearer %s', $pAccessToken),
                    ],
                    "http_errors" => false,
                ]
            );

        $responseBody = mb_strtolower($response->getBody()->getContents());
        $body = @json_decode($responseBody, true);
        $statusCode = (int) $response->getStatusCode();

        if ($statusCode != 200)
            return 'err';

The expression return 'err' returns the type string which is incompatible with the documented return type Shetabit\Multipay\Drivers\Payping\data.

        return $body;
    }

    /**
     * Create request payment as multi request.
     *
     * @return data
     */
    private function createMultiRequest($data = array())
    {
        $data = [
            'payerName' => 'bdok',
            'pairs'         => $data['pairs'],
            'returnUrl'     => $data['returnUrl'],
            'clientRefId' => $data['clientRefId']
        ];

        $response = $this
            ->client
            ->request(
                'POST',
                'https://api.payping.ir/v1/pay',
                [
                    'json' => $data,
                    "headers" => [
                        "Accept" => "application/json",
                        "Authorization" => sprintf('Bearer %s', $this->settings->accessToken),
                    ],
                    "http_errors" => false,
                ]
            );

        $responseBody = mb_strtolower($response->getBody()->getContents());
        $body = @json_decode($responseBody, true);
        $statusCode = (int) $response->getStatusCode();

        if ($statusCode !== 200) {
            $message = is_array($body) ? array_pop($body) : $this->convertStatusCodeToMessage($statusCode);
            throw new PurchaseFailedException($message);
        }

        $minutes = now()->addSecond(60 * 5);

The function now was not found. Maybe you did not declare it correctly or list all dependencies?

        cache(['transactionId' => $body['code']], $minutes);

The function cache was not found. Maybe you did not declare it correctly or list all dependencies?

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

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

The expression return $this->invoice->getTransactionId() returns the type string which is incompatible with the documented return type Shetabit\Multipay\Drivers\Payping\data.

    }

    /**
     * Get client user profile.
     *
     * @return data
     */
    private function getClientUserProfile($data = array())
    {
        $response = $this
            ->client
            ->request(
                'GET',
                'https://oauth.payping.ir/connect/userinfo',
                [
                    "headers" => [
                        "Accept" => "application/json",
                        "Authorization" => sprintf('Bearer %s', $this->settings->accessToken),
                    ],
                    "http_errors" => false,
                ]
            );

        $responseBody = mb_strtolower($response->getBody()->getContents());
        $body = @json_decode($responseBody);
        $statusCode = (int) $response->getStatusCode();

        if ($statusCode !== 200) {
            // some error has happened
            $message = is_array($body) ? array_pop($body) : $this->convertStatusCodeToMessage($statusCode);
            throw new PurchaseFailedException($message);
        }
        return $body;
    }

    /**
     * Cal custome function.
     *
     * @return data
     */
    public function call($method, $data = array())
    {
        if (method_exists($this, $method))
        {
            return $this->$method($data);
        }
        return false;

The expression return false returns the type false which is incompatible with the documented return type Shetabit\Multipay\Drivers\Payping\data.

    }

    /**
     * Purchase Invoice.
     *
     * @return string
     *
     * @throws PurchaseFailedException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function purchase()
    {
        $name = $this->extractDetails('name');
        $mobile = $this->extractDetails('mobile');
        $email = $this->extractDetails('email');
        $description = $this->extractDetails('description');

        $data = array(
            "payerName" => $name,
            "amount" => $this->invoice->getAmount(),
            "payerIdentity" => $mobile ?? $email,
            "returnUrl" => $this->settings->callbackUrl,
            "description" => $description,
            "clientRefId" => $this->invoice->getUuid(),
        );

        $response = $this
            ->client
            ->request(
                'POST',
                $this->settings->apiPurchaseUrl,
                [
                    "json" => $data,
                    "headers" => [
                        "Accept" => "application/json",
                        "Authorization" => "bearer ".$this->settings->merchantId,
                    ],
                    "http_errors" => false,
                ]
            );

        $responseBody = mb_strtolower($response->getBody()->getContents());
        $body = @json_decode($responseBody, true);
        $statusCode = (int) $response->getStatusCode();

        if ($statusCode !== 200) {
            // some error has happened
            $message = is_array($body) ? array_pop($body) : $this->convertStatusCodeToMessage($statusCode);

            throw new PurchaseFailedException($message);
        }

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

        // 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
    {
        $refId = Request::input('refid');
        $data = [
            'amount' => $this->invoice->getAmount(),
            'refId'  => $refId,
        ];

        $response = $this->client->request(
            'POST',
            $this->settings->apiVerificationUrl,
            [
                'json' => $data,
                "headers" => [
                    "Accept" => "application/json",
                    "Authorization" => "bearer ".$this->settings->merchantId,
                ],
                "http_errors" => false,
            ]
        );

        $responseBody = mb_strtolower($response->getBody()->getContents());
        $body = @json_decode($responseBody, true);

        $statusCode = (int) $response->getStatusCode();

        if ($statusCode !== 200) {
            $message = is_array($body) ? array_pop($body) : $this->convertStatusCodeToMessage($statusCode);

            $this->notVerified($message);
        }

        return $this->createReceipt($refId);
    }

    /**
     * Generate the payment's receipt
     *
     * @param $referenceId
     *
     * @return Receipt
     */
    protected function createReceipt($referenceId)
    {
        $receipt = new Receipt('payping', $referenceId);

        return $receipt;
    }

    /**
     * Trigger an exception
     *
     * @param $message
     *
     * @throws InvalidPaymentException
     */
    private function notVerified($message)
    {
        throw new InvalidPaymentException($message);
    }

    /**
     * Retrieve related message to given status code
     *
     * @param $statusCode
     *
     * @return string
     */
    private function convertStatusCodeToMessage(int $statusCode) : string
    {
        $messages = [
            400 => 'مشکلی در ارسال درخواست وجود دارد',
            401 => 'عدم دسترسی',
            403 => 'دسترسی غیر مجاز',
            404 => 'آیتم درخواستی مورد نظر موجود نمی باشد',
            500 => 'مشکلی در سرور درگاه پرداخت رخ داده است',
            503 => 'سرور درگاه پرداخت در حال حاضر قادر به پاسخگویی نمی باشد',
        ];

        $unknown = 'خطای ناشناخته ای در درگاه پرداخت رخ داده است';

        return $messages[$statusCode] ?? $unknown;
    }
}