From 48ac0a92d49f7d466374a118c0509882f28b89b0 Mon Sep 17 00:00:00 2001 From: David Bomba Date: Mon, 18 Mar 2024 10:21:17 +1100 Subject: [PATCH] Add delays to nordigen for rate limits --- app/Jobs/Bank/ProcessBankTransactionsNordigen.php | 2 ++ app/Jobs/Ninja/BankTransactionSync.php | 9 ++++++++- 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/app/Jobs/Bank/ProcessBankTransactionsNordigen.php b/app/Jobs/Bank/ProcessBankTransactionsNordigen.php index dd7c6c657b9e..8ff86efd14a5 100644 --- a/app/Jobs/Bank/ProcessBankTransactionsNordigen.php +++ b/app/Jobs/Bank/ProcessBankTransactionsNordigen.php @@ -85,6 +85,8 @@ class ProcessBankTransactionsNordigen implements ShouldQueue $this->bank_integration->company->notification(new GenericNinjaAdminNotification($content))->ninja(); + sleep(5); + throw $e; } if (!$this->nordigen_account) { diff --git a/app/Jobs/Ninja/BankTransactionSync.php b/app/Jobs/Ninja/BankTransactionSync.php index 6e5ca84d69e8..a0d077a570c8 100644 --- a/app/Jobs/Ninja/BankTransactionSync.php +++ b/app/Jobs/Ninja/BankTransactionSync.php @@ -90,7 +90,14 @@ class BankTransactionSync implements ShouldQueue if ((Ninja::isSelfHost() || (Ninja::isHosted() && $account->isEnterprisePaidClient()))) { $account->bank_integrations()->where('integration_type', BankIntegration::INTEGRATION_TYPE_NORDIGEN)->where('auto_sync', true)->where('disabled_upstream', 0)->cursor()->each(function ($bank_integration) { - (new ProcessBankTransactionsNordigen($bank_integration))->handle(); + try { + (new ProcessBankTransactionsNordigen($bank_integration))->handle(); + } + catch(\Exception $e) { + sleep(20); + } + + sleep(5); }); }