PoolPort.php

<?php

namespace PoolPort;

use PoolPort\AP\AP;
use PoolPort\Pay\Pay;
use PoolPort\PNA\PNA;
use PoolPort\Saman\Saman;
use PoolPort\Sadad\Sadad;
use PoolPort\JiBit\JiBit;
use PoolPort\IDPay\IDPay;
use PoolPort\BitPay\BitPay;
use PoolPort\Mellat\Mellat;
use PoolPort\Vandar\Vandar;
use PoolPort\PayPing\PayPing;
use PoolPort\Saderat\Saderat;
use PoolPort\Payline\Payline;
use PoolPort\Parsian\Parsian;
use PoolPort\Pasargad\Pasargad;
use PoolPort\Zarinpal\Zarinpal;
use PoolPort\JahanPay\JahanPay;
use PoolPort\IranKish\IranKish;
use PoolPort\Exceptions\RetryException;
use PoolPort\PortSimulator\PortSimulator;
use PoolPort\Exceptions\PortNotFoundException;
use PoolPort\Exceptions\InvalidRequestException;
use PoolPort\Exceptions\NotFoundTransactionException;

class PoolPort
{
    const P_MELLAT = 1;

    const P_SADAD = 2;

    const P_ZARINPAL = 3;

    const P_PAYLINE = 4;

    const P_JAHANPAY = 5;

    const P_PARSIAN = 6;

    const P_PASARGAD = 7;

    const P_SADERAT = 8;

    const P_IRANKISH = 9;

    const P_SIMULATOR = 10;

    const P_SAMAN = 11;

    const P_PAY = 12;

    const P_JIBIT = 13;

    const P_AP = 14;

    const P_BITPAY = 15;

    const P_IDPAY = 16;

    const P_PAYPING = 17;

    const P_VANDAR = 18;

    const P_PNA = 19;

    /**
     * @var Config
     */
    public $config;

    /**
     * @var DataBaseManager
     */
    protected $db;

    /**
     * Keep current port driver
     *
     * @var PortAbstract
     */
    protected $portClass;

    /**
     * Path of config file
     *
     * @var null|string
     */
    private $configFilePath = null;

    /**
     * @param null|string $port
     * @param null|string $configFile
     */
    public function __construct($port = null, $configFile = null)
    {
        $this->configFilePath = $configFile;

        $this->config = new Config($this->configFilePath);
        $this->db = new DataBaseManager($this->config);

        if (!empty($this->config->get('timezone')))
            date_default_timezone_set($this->config->get('timezone'));

        if (!is_null($port)) $this->buildPort($port);
    }

    /**
     * Get supported ports
     *
     * @return array
     */
    public function getSupportedPorts()
    {
        return array(self::P_MELLAT, self::P_SADAD, self::P_ZARINPAL,
            self::P_PAYLINE, self::P_JAHANPAY, self::P_PARSIAN, self::P_PASARGAD,
            self::P_SADERAT, self::P_IRANKISH, self::P_SIMULATOR, self::P_SAMAN,
            self::P_PAY, self::P_JIBIT, self::P_AP, self::P_BITPAY, self::P_IDPAY,
            self::P_PAYPING, self::P_VANDAR, self::P_PNA);
    }

    /**
     * Call methods of current driver
     *
     * @return mixed
     */
    public function __call($name, $arguments)
    {
        return call_user_func_array([$this->portClass, $name], $arguments);
    }

    /**
     * Verify transaction, use verifyLock for security reason
     *
     * @return $this->portClass
     *
     * @throws InvalidRequestException
     * @throws NotFoundTransactionException
     * @throws PortNotFoundException
     * @throws RetryException
     */
    public function verify()
    {
        if (!isset($_GET['u']))
            throw new InvalidRequestException;

        $uniqeId = $_GET['u'];
        $transaction = $this->db->find($uniqeId);

        if (!$transaction)
            throw new NotFoundTransactionException;

        if (!PortAbstract::checkVerifyKey($transaction))
            throw new InvalidRequestException;

        if ($transaction->status == PortAbstract::TRANSACTION_SUCCEED || $transaction->status == PortAbstract::TRANSACTION_FAILED)
            throw new RetryException;

        $this->buildPort($transaction->port_id);

        return $this->portClass->verify($transaction);
    }

    /**
     * Verify transaction, preventing duplicate request at the same time
     *
     * @return $this->portClass
     *
     * @throws InvalidRequestException
     * @throws NotFoundTransactionException
     * @throws PortNotFoundException
     * @throws RetryException
     */
    public function verifyLock()
    {
        if (!isset($_GET['u']))
            throw new InvalidRequestException;

        $uniqeId = $_GET['u'];

        try {
            $this->db->beginTransaction();

            $transaction = $this->db->find($uniqeId, true);

            if (!$transaction)
                throw new NotFoundTransactionException;

            if (!PortAbstract::checkVerifyKey($transaction))
                throw new InvalidRequestException;

            if ($transaction->status != PortAbstract::TRANSACTION_INIT)
                throw new RetryException;

            $this->buildPort($transaction->port_id);
            $this->portClass->transactionPending($transaction->id);

            $this->db->commit();
        } catch(\Exception $e) {
            $this->db->rollBack();
            throw $e;
        }

        return $this->portClass->verify($transaction);
    }

    /**
     * Create new object from port class
     *
     * @param int $port
     * @throws PortNotFoundException
     */
    protected function buildPort($port)
    {
        switch ($port) {
            case self::P_MELLAT:
                $this->portClass = new Mellat($this->config, $this->db, self::P_MELLAT);
                break;

            case self::P_SADAD:
                $this->portClass = new Sadad($this->config, $this->db, self::P_SADAD);
                break;

            case self::P_ZARINPAL:
                $this->portClass = new Zarinpal($this->config, $this->db, self::P_ZARINPAL);
                break;

            case self::P_PAYLINE:
                $this->portClass = new Payline($this->config, $this->db, self::P_PAYLINE);
                break;

            case self::P_JAHANPAY:
                $this->portClass = new JahanPay($this->config, $this->db, self::P_JAHANPAY);
                break;

            case self::P_PARSIAN:
                $this->portClass = new Parsian($this->config, $this->db, self::P_PARSIAN);
                break;

            case self::P_PASARGAD:
                $this->portClass = new Pasargad($this->config, $this->db, self::P_PASARGAD);
                break;

            case self::P_SADERAT:
                $this->portClass = new Saderat($this->config, $this->db, self::P_SADERAT);
                break;

            case self::P_IRANKISH;
                $this->portClass = new IranKish($this->config, $this->db, self::P_IRANKISH);
                break;

            case self::P_SIMULATOR;
                $this->portClass = new PortSimulator($this->config, $this->db, self::P_SIMULATOR);
                break;

            case self::P_SAMAN;
                $this->portClass = new Saman($this->config, $this->db, self::P_SAMAN);
                break;

            case self::P_PAY:
                $this->portClass = new Pay($this->config, $this->db, self::P_PAY);
                break;

            case self::P_JIBIT:
                $this->portClass = new JiBit($this->config, $this->db, self::P_JIBIT);
                break;

            case self::P_AP:
                $this->portClass = new AP($this->config, $this->db, self::P_AP);
                break;

	        case self::P_BITPAY:
	        	$this->portClass = new BitPay($this->config, $this->db, self::P_BITPAY);
	        	break;

            case self::P_IDPAY:
                $this->portClass = new IDPAY($this->config, $this->db, self::P_IDPAY);
                break;

            case self::P_PAYPING:
                $this->portClass = new PayPing($this->config, $this->db, self::P_PAYPING);
                break;

            case self::P_VANDAR:
                $this->portClass = new Vandar($this->config, $this->db, self::P_VANDAR);
                break;

            case self::P_PNA:
                $this->portClass = new PNA($this->config, $this->db, self::P_PNA);
                break;

            default:
                throw new PortNotFoundException;
                break;
        }
    }
}