Karson\MpesaPhpSdk\Mpesa

Complexity

Total Complexity

16

Size/Duplication

Total Lines	181
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
A	setPublicKey()	0	3	1
A	setApiKey()	0	3	1
A	setEnv()	0	5	2
A	c2b()	0	13	1
A	transactionReversal()	0	14	1
A	status()	0	14	1
A	getToken()	0	15	3
A	makeRequest()	0	40	3
A	getHeader()	0	10	1

<?php
namespace Karson\MpesaPhpSdk;


class Mpesa {

    private $api_url = 'https://api.sandbox.vm.co.mz';
    private $api_port;
    public $public_key;
    public $api_key;

    public function __construct($config = [])
    {
        if (is_array($config)) {
            $this->setPublicKey($config['public_key']);
            $this->setApiKey($config['api_key']);
            $this->setEnv($config['env']);
        }
    }

    public function setPublicKey($public_key){
        $this->public_key = trim($public_key);
    }

    public function setApiKey($api_key){
        $this->api_key = $api_key;
    }

    public function setEnv($env){
        if ($env == 'live') {
            $this->api_url = 'https://api.vm.co.mz';
        }
    }


    /* Standard customer-to-business transaction
     *
     * @param string $transactionReference This is the reference of the transaction for the customer or business making the * transaction. This can be a smartcard number for a TV subscription or a reference number of a utility bill.
     * @param string $customerMSISDN  MSISDN of the customer for the transaction
     * @param string $amount The amount for the transaction.
     * @param string $thirdPartReferece This is the unique reference of the third party system. When there are queries about transactions, this will usually be used to track a transaction.
     * @param string $serviceCode Shortcode of the business where funds will be credited to.
     * @return \stdClass
     */
    function c2b($transactionReference, $customerMSISDN, $amount, $thirdPartReferece, $serviceCode){

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

        $fields = [
            "input_TransactionReference"=> $transactionReference,
            "input_CustomerMSISDN"=> $customerMSISDN,
            "input_Amount"=> $amount,
            "input_ThirdPartyReference"=> $thirdPartReferece,
            "input_ServiceProviderCode" => $serviceCode
        ];

        return $this->makeRequest(':18352/ipg/v1x/c2bPayment/singleStage/', 'POST', $fields);

    }

    /**
     * @param $transactionID
     * @param $securityCredential
     * @param $initiatorIdentifier
     * @param $thirdPartyReference
     * @param $serviceProviderCode
     * @param $reversalAmount
     * @return \stdClass
     */
    public function transactionReversal($transactionID, $securityCredential, $initiatorIdentifier, $thirdPartyReference, $serviceProviderCode, $reversalAmount)
    {
        $fields = [
            "input_TransactionID" => $transactionID,
             "input_SecurityCredential" => $securityCredential,
             "input_InitiatorIdentifier" => $initiatorIdentifier,
             "input_ThirdPartyReference" => $thirdPartyReference,
             "input_ServiceProviderCode" => $serviceProviderCode,
             "input_ReversalAmount" => $reversalAmount
        ];
         return $this->makeRequest(':18354/ipg/v1x/reversal/', 'POST', $fields);


    }

    /**
     * @param $thirdPartyReference
     * @param $queryReference
     * @param $serviceProviderCode
     * @return \stdClass
     */
    public function status($thirdPartyReference, $queryReference, $serviceProviderCode)
    {

        $fields = [
             'input_ThirdPartyReference' => $thirdPartyReference,
             'input_QueryReference' => $queryReference,
             'input_ServiceProviderCode' => $serviceProviderCode
        ];



        return $this->makeRequest(':18353/ipg/v1x/queryTransactionStatus/', 'GET', $fields);

    }

    /**
     * Generates a base64 encoded token
     */
    public function getToken()
    {

        if (!empty($this->public_key) && !empty($this->api_key))
        {
            $key = "-----BEGIN PUBLIC KEY-----\n";
            $key .= wordwrap($this->public_key, 60, "\n", true);
            $key .= "\n-----END PUBLIC KEY-----";
            $pk = openssl_get_publickey($key);
            openssl_public_encrypt($this->api_key, $token, $pk, OPENSSL_PKCS1_PADDING);

            return base64_encode($token);
        }
        return 'error';
    }

    /**
     * @param string $url
     * @param string $method
     * @param array $fields
     * @return \stdClass
     */
    private function makeRequest(string $url,string $method, array $fields = [])
    {
        $url = $this->api_url.$url;

        $ch = curl_init();

        if($method == 'POST')
        {
            $fieldsString = json_encode($fields);
            curl_setopt($ch, CURLOPT_POST, 1);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $fieldsString);
        }
        else
        {
            $fieldsString = http_build_query($fields);
            $url .= '?'.$fieldsString;
        }
        $header = $this->getHeader();


        curl_setopt($ch, CURLOPT_POST, count($fields));
        curl_setopt($ch, CURLOPT_PORT, $this->api_port);
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_TIMEOUT, 90);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);

        $result = curl_exec($ch);

        $return = new \stdClass();
        $return->response = json_decode($result);

        if ($return->response == false)
            $return->response = $result;

        $return->status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);
        return $return;
    }

    /**
     * @return array
     */
    private function getHeader()
    {
        $header = [
            'Content-Type: application/json',
            'Authorization: Bearer ' . $this->getToken(),
            'origin: developer.mpesa.vm.co.mz',
            'Connection: keep-alive'
        ];
        return $header;
    }


}