Bmatovu\AirtelMoney\Products\Disbursement

Complexity

Total Complexity

3

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	send()	0	21	1
A	getTransaction()	0	9	1

<?php

namespace Bmatovu\AirtelMoney\Products;

use GuzzleHttp\ClientInterface;
use Illuminate\Container\Container;
use Illuminate\Contracts\Config\Repository;
use Ramsey\Uuid\Uuid;

class Disbursement
{
    protected ClientInterface $http;

    protected Repository $config;

    public function __construct(ClientInterface $http)
    {
        $this->http = $http;
        $this->config = Container::getInstance()->make('config');
    }

    /**
     * @return array<string, mixed>
     *
     * @throws \GuzzleHttp\Exception\TransferException
     */
    public function send(string $phoneNumber, float $amount, ?string $id = null, ?string $reference = null): array
    {
        $phoneNumber = substr($phoneNumber, -9);

        $paymentUri = $this->config->get('airtel-money.disbursement.payment_uri');

        $response = $this->http->request('POST', $paymentUri, [
            'json' => [
                'payee' => [
                    'msisdn' => $phoneNumber,
                ],
                'reference' => $reference ?? 'Disbursement',
                'pin' => $this->config->get('airtel-money.encrypted_pin'),
                'transaction' => [
                    'amount' => $amount,
                    'id' => $id ?? Uuid::uuid4()->toString(),
                ],
            ],
        ]);

        return json_decode((string) $response->getBody(), true);
    }

    /**
     * @return array<string, mixed>
     *
     * @throws \GuzzleHttp\Exception\TransferException
     */
    public function getTransaction(string $transactionId): array
    {
        $transactionUri = $this->config->get('airtel-money.disbursement.transaction_uri');

        $transactionUri = str_replace(':transactionId', $transactionId, $transactionUri);

        $response = $this->http->request('GET', $transactionUri);

        return json_decode((string) $response->getBody(), true);
    }
}