diff --git a/src/subdomains/supporting/log/log-job.service.ts b/src/subdomains/supporting/log/log-job.service.ts index 0c1d6e46d0..8f68d6f111 100644 --- a/src/subdomains/supporting/log/log-job.service.ts +++ b/src/subdomains/supporting/log/log-job.service.ts @@ -246,6 +246,7 @@ export class LogJobService { const olkyBank = await this.bankService.getBankInternal(IbanBankName.OLKY, 'EUR'); const yapealEurBank = await this.bankService.getBankInternal(IbanBankName.YAPEAL, 'EUR'); const yapealChfBank = await this.bankService.getBankInternal(IbanBankName.YAPEAL, 'CHF'); + const eurBankIbans = [yapealEurBank.iban, olkyBank.iban]; // pending balances const pendingOrders = await this.liquidityManagementPipelineService.getPendingTx(); @@ -384,9 +385,9 @@ export class LogJobService { eurReceiverExchangeTx, ); - // EUR: Yapeal -> Scrypt + // EUR: Bank -> Scrypt const eurSenderScryptBankTx = recentScryptBankTx.filter( - (b) => b.accountIban === yapealEurBank.iban && b.creditDebitIndicator === BankTxIndicator.DEBIT, + (b) => eurBankIbans.includes(b.accountIban) && b.creditDebitIndicator === BankTxIndicator.DEBIT, ); const eurReceiverScryptExchangeTx = recentScryptExchangeTx.filter( (k) => k.type === ExchangeTxType.DEPOSIT && k.status === 'ok' && k.currency === 'EUR', @@ -400,15 +401,15 @@ export class LogJobService { (b) => b.accountIban === yapealChfBank.iban && b.creditDebitIndicator === BankTxIndicator.CREDIT, ); - // EUR: Scrypt -> Yapeal + // EUR: Scrypt -> Bank const eurSenderScryptExchangeTx = recentScryptExchangeTx.filter( (k) => k.type === ExchangeTxType.WITHDRAWAL && k.status === 'ok' && k.currency === 'EUR', ); const eurReceiverScryptBankTx = recentScryptBankTx.filter( - (b) => b.accountIban === yapealEurBank.iban && b.creditDebitIndicator === BankTxIndicator.CREDIT, + (b) => eurBankIbans.includes(b.accountIban) && b.creditDebitIndicator === BankTxIndicator.CREDIT, ); - // sender and receiver data for Yapeal -> Scrypt + // sender and receiver data for Bank -> Scrypt const { sender: recentChfYapealScryptTx, receiver: recentChfBankTxScrypt } = this.filterSenderPendingList( chfSenderScryptBankTx, chfReceiverScryptExchangeTx, @@ -418,7 +419,7 @@ export class LogJobService { eurReceiverScryptExchangeTx, ); - // sender and receiver data for Scrypt -> Yapeal + // sender and receiver data for Scrypt -> Bank const { sender: recentChfScryptYapealTx, receiver: recentChfScryptBankTx } = this.filterSenderPendingList( chfSenderScryptExchangeTx, chfReceiverScryptBankTx,