From 96518966032c7f76b3f71c324b0a9e23c8c4ef2c Mon Sep 17 00:00:00 2001 From: Crimson Thompson Date: Fri, 7 Nov 2025 17:30:07 +0100 Subject: [PATCH] Allow missing balance in Atlar account response --- .../connectors/atlar/task_fetch_accounts.go | 32 ++++++++++--------- 1 file changed, 17 insertions(+), 15 deletions(-) diff --git a/components/payments/cmd/connectors/internal/connectors/atlar/task_fetch_accounts.go b/components/payments/cmd/connectors/internal/connectors/atlar/task_fetch_accounts.go index 30021dbf7c..ec70ef4476 100644 --- a/components/payments/cmd/connectors/internal/connectors/atlar/task_fetch_accounts.go +++ b/components/payments/cmd/connectors/internal/connectors/atlar/task_fetch_accounts.go @@ -157,22 +157,24 @@ func ingestAccountsBatch( RawData: raw, }) - balance := account.Balance - balanceTimestamp, err := ParseAtlarTimestamp(balance.Timestamp) - if err != nil { - return err + if account.Balance != nil { + balance := account.Balance + balanceTimestamp, err := ParseAtlarTimestamp(balance.Timestamp) + if err != nil { + return err + } + balanceBatch = append(balanceBatch, &models.Balance{ + AccountID: models.AccountID{ + Reference: *account.ID, + ConnectorID: connectorID, + }, + Asset: currency.FormatAsset(supportedCurrenciesWithDecimal, *balance.Amount.Currency), + Balance: big.NewInt(*balance.Amount.Value), + CreatedAt: balanceTimestamp, + LastUpdatedAt: time.Now().UTC(), + ConnectorID: connectorID, + }) } - balanceBatch = append(balanceBatch, &models.Balance{ - AccountID: models.AccountID{ - Reference: *account.ID, - ConnectorID: connectorID, - }, - Asset: currency.FormatAsset(supportedCurrenciesWithDecimal, *balance.Amount.Currency), - Balance: big.NewInt(*balance.Amount.Value), - CreatedAt: balanceTimestamp, - LastUpdatedAt: time.Now().UTC(), - ConnectorID: connectorID, - }) } if err := ingester.IngestAccounts(ctx, accountsBatch); err != nil {