App\Bunq\Requests\PaymentList

Complexity

Total Complexity

30

Size/Duplication

Total Lines	270
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	5
A	setDownloadIdentifier()	0	4	1
A	getDownload()	0	13	2
A	storeDownload()	0	4	1
B	getForAccount()	0	69	9
B	processBunqPayment()	0	66	6
A	hasDownload()	0	5	1
A	getPaymentList()	0	38	5

<?php

declare(strict_types=1);
/**
 * PaymentList.php
 * Copyright (c) 2020 james@firefly-iii.org.
 *
 * This file is part of the Firefly III bunq importer
 * (https://github.com/firefly-iii/bunq-importer).
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */

namespace App\Bunq\Requests;

use App\Bunq\ApiContext\ApiContextManager;
use App\Exceptions\ImportException;
use App\Services\Configuration\Configuration;
use App\Services\Sync\JobStatus\ProgressInformation;
use bunq\Model\Generated\Endpoint\Payment as BunqPayment;
use Carbon\Carbon;
use Illuminate\Contracts\Filesystem\FileNotFoundException;
use Illuminate\Support\Facades\Storage;

/**
 * Class PaymentList.
 */
class PaymentList
{
    use ProgressInformation;

    /** @var Configuration */
    private $configuration;
    /** @var int */
    private $count;
    /** @var string */
    private $downloadIdentifier;
    /** @var Carbon */
    private $notAfter;
    /** @var Carbon */
    private $notBefore;

    /**
     * PaymentList constructor.
     *
     * @param Configuration $configuration
     */
    public function __construct(Configuration $configuration)
    {
        $this->configuration = $configuration;
        $this->count         = 0;
        $this->notBefore     = null === $configuration->getDateNotBefore() ? null : Carbon::createFromFormat('Y-m-d', $configuration->getDateNotBefore());
        $this->notAfter      = null === $configuration->getDateNotAfter() ? null : Carbon::createFromFormat('Y-m-d', $configuration->getDateNotAfter());
        if (null !== $this->notBefore) {
            $this->notBefore->startOfDay();
        }
        if (null !== $this->notAfter) {
            $this->notAfter->endOfDay();
        }
        app('log')->debug('Created Requests\\PaymentList');
    }

    public function getPaymentList(): array
    {
        app('log')->debug('Start of PaymentList::getPaymentList()');

        if ($this->hasDownload()) {
            app('log')->info('Already downloaded content for this job. Return it.');
            $this->addMessage(0, 'Already had data. This is not a problem though.');

            return $this->getDownload();
        }

        $return = [];
        try {
            ApiContextManager::getApiContext();
        } catch (ImportException $e) {
            app('log')->error($e->getMessage());
            app('log')->error($e->getTraceAsString());
            $this->addError(0, $e->getMessage());

            return [];
        }
        $totalCount = 0;
        foreach (array_keys($this->configuration->getAccounts()) as $bunqAccountId) {
            $bunqAccountId = (int) $bunqAccountId;
            try {
                $return[$bunqAccountId] = $this->getForAccount($bunqAccountId);
                $totalCount             += count($return[$bunqAccountId]);
            } catch (ImportException $e) {
                app('log')->error($e->getMessage());
                app('log')->error($e->getTraceAsString());
                $this->addError(0, $e->getMessage());
            }
        }
        app('log')->notice(sprintf('Downloaded a total of %d transactions from bunq.', $totalCount));
        // store the result somewhere so it can be processed easily.
        $this->storeDownload($return);

        return $return;
    }

    /**
     * @param string $downloadIdentifier
     */
    public function setDownloadIdentifier(string $downloadIdentifier): void
    {
        $this->downloadIdentifier = $downloadIdentifier;
        $this->identifier         = $downloadIdentifier;
    }

    /**
     * @return array
     */
    private function getDownload(): array
    {
        $disk = Storage::disk('downloads');
        try {
            $content = (string) $disk->get($this->downloadIdentifier);
        } catch (FileNotFoundException $e) {
            app('log')->error('Could not store download');
            app('log')->error($e->getMessage());
            app('log')->error($e->getTraceAsString());
            $content = '[]';
        }

        return json_decode($content, true, 512, JSON_THROW_ON_ERROR);
    }

    /**
     * @param int $bunqAccountId
     *
     * @throws ImportException
     * @return array
     */
    private function getForAccount(int $bunqAccountId): array
    {
        app('log')->debug(sprintf('Now in getForAccount(%d)', $bunqAccountId));
        $hasMoreTransactions = true;
        $olderId             = null;
        $return              = [];

        /*
         * Do a loop during which we run:
         */
        while ($hasMoreTransactions && $this->count <= 45) {
            app('log')->debug(sprintf('Now in loop #%d for account %d', $this->count, $bunqAccountId));
            $previousLoop = count($return);
            /*
             * Send request to bunq.
             */
            /** @var Payment $paymentRequest */
            $paymentRequest = app(Payment::class);
            $params         = ['count' => 197, 'older_id' => $olderId];
            $response       = $paymentRequest->listing($bunqAccountId, $params);
            $pagination     = $response->getPagination();
            app('log')->debug('Params for the request to bunq are: ', $params);

            /*
             * If pagination is not null, we can go back even further.
             */
            if (null !== $pagination) {
                $olderId = $pagination->getOlderId();
                app('log')->debug(sprintf('Pagination object is not null, new olderID is "%s"', $olderId));
            }

            /*
             * Loop the results from bunq
             */
            app('log')->debug('Now looping results from bunq...');
            /** @var BunqPayment $payment */
            foreach ($response->getValue() as $index => $payment) {
                app('log')->debug(sprintf('Going to process payment on index #%d', $index));
                $array = $this->processBunqPayment($index, $payment);
                if (null !== $array) {
                    $return[] = $array;
                }
            }

            /*
             * After the loop, check if must loop again.
             */
            app('log')->debug(sprintf('Count of return is now %d', count($return)));
            $this->count++;
            if (null === $olderId) {
                app('log')->debug('Older ID is NULL, so stop looping cause we are done!');
                $hasMoreTransactions = false;
            }

            if (null === $pagination) {
                app('log')->debug('No pagination object, stop looping.');
            }
            if ($previousLoop === count($return)) {
                app('log')->info('No new transactions were added to the array.');
                $hasMoreTransactions = false;
            }

            // sleep 2 seconds to prevent hammering bunq.
            sleep(2);
        }
        // store newest and oldest tranasction ID to be used later:
        app('log')->info(sprintf('Downloaded and parsed %d transactions from bunq (from this account).', count($return)));

        return $return;
    }

    /**
     * @return bool
     */
    private function hasDownload(): bool
    {
        $disk = Storage::disk('downloads');

        return $disk->exists($this->downloadIdentifier);
    }

    /**
     * @param int         $index
     * @param BunqPayment $payment
     *
     * @return array
     */
    private function processBunqPayment(int $index, BunqPayment $payment): ?array

The parameter $index is not used and could be removed.

    {
        $created = Carbon::createFromFormat('Y-m-d H:i:s.u', $payment->getCreated());
        if (null !== $this->notBefore && $created->lte($this->notBefore)) {
            app('log')->info(
                sprintf(
                    'Skip transaction because %s is before %s',
                    $created->format('Y-m-d H:i:s'),
                    $this->notBefore->format('Y-m-d H:i:s')
                )
            );

            return null;
        }
        if (null !== $this->notAfter && $created->gte($this->notAfter)) {
            app('log')->info(
                sprintf(
                    'Skip transaction because %s is after %s',
                    $created->format('Y-m-d H:i:s'),
                    $this->notAfter->format('Y-m-d H:i:s')
                )
            );

            return null;
        }

        $transaction                                  = [
            // TODO country, bunqMe, isLight, swiftBic, swiftAccountNumber, transferwiseAccountNumber, transferwiseBankCode
            // TODO merchantCategoryCode, bunqtoStatus, bunqtoSubStatus, bunqtoExpiry, bunqtoTimeResponded
            // TODO merchantReference, batchId, scheduledId, addressShipping, addressBilling, geolocation, allowChat,
            // TODO requestReferenceSplitTheBill
            'id'              => $payment->getId(),
            'created'         => $created,
            'updated'         => Carbon::createFromFormat('Y-m-d H:i:s.u', $payment->getUpdated()),
            'bunq_account_id' => $payment->getMonetaryAccountId(),
            'amount'          => $payment->getAmount()->getValue(),
            'currency_code'   => $payment->getAmount()->getCurrency(),
            'counter_party'   => [
                'iban'         => null,
                'display_name' => null,
                'nick_name'    => null,
                'country'      => null,
            ],
            'description'     => trim($payment->getDescription()),
            'type'            => $payment->getType(),
            'sub_type'        => $payment->getSubType(),
            'balance_after'   => $payment->getBalanceAfterMutation()->getValue(),
        ];
        $counterParty                                 = $payment->getCounterpartyAlias();
        $transaction['counter_party']['iban']         = $counterParty->getIban();
        $transaction['counter_party']['display_name'] = $counterParty->getDisplayName();
        $transaction['counter_party']['nick_name']    = $counterParty->getLabelUser()->getDisplayName();
        $transaction['counter_party']['country']      = $counterParty->getCountry();
        if ('' === $transaction['description']) {
            $transaction['description'] = '(empty description)';
        }

        app('log')->debug(
            sprintf(
                'Downloaded and parsed transaction #%d (%s) "%s" (%s %s).',
                $transaction['id'], $transaction['created']->format('Y-m-d'),
                $transaction['description'], $transaction['currency_code'], $transaction['amount']
            )
        );

        return $transaction;
    }

    /**
     * @param array $data
     */
    private function storeDownload(array $data): void
    {
        $disk = Storage::disk('downloads');
        $disk->put($this->downloadIdentifier, json_encode($data, JSON_THROW_ON_ERROR, 512));
    }
}