From 6a21e92aa6f584720dc5e1e5a2b95736787fc441 Mon Sep 17 00:00:00 2001 From: Stevan Freeborn <65925598+StevanFreeborn@users.noreply.github.com> Date: Thu, 12 Mar 2026 16:42:39 -0500 Subject: [PATCH] fix(infra): include Metadata in transaction queries for added, modified, and removed transactions --- .../Transactions/Plaid/PlaidAddedTransactionHandler.cs | 1 + .../Transactions/Plaid/PlaidModifiedTransactionHandler.cs | 1 + .../Transactions/Plaid/PlaidRemovedTransactionHandler.cs | 1 + 3 files changed, 3 insertions(+) diff --git a/src/FiscalOS.Infra/Transactions/Plaid/PlaidAddedTransactionHandler.cs b/src/FiscalOS.Infra/Transactions/Plaid/PlaidAddedTransactionHandler.cs index 8f8ccfb..e587ae0 100644 --- a/src/FiscalOS.Infra/Transactions/Plaid/PlaidAddedTransactionHandler.cs +++ b/src/FiscalOS.Infra/Transactions/Plaid/PlaidAddedTransactionHandler.cs @@ -46,6 +46,7 @@ internal sealed class PlaidAddedTransactionHandler : IPlaidAddedTransactionHandl { var existingTransactionIds = added.Select(t => t.TransactionId); var existingTransactions = await _appDbContext.Transactions + .Include(t => t.Metadata) .Where(t => t.Metadata is PlaidTransactionMetadata && existingTransactionIds.Contains(((PlaidTransactionMetadata)t.Metadata).PlaidId)) .ToListAsync(ct) .ConfigureAwait(false); diff --git a/src/FiscalOS.Infra/Transactions/Plaid/PlaidModifiedTransactionHandler.cs b/src/FiscalOS.Infra/Transactions/Plaid/PlaidModifiedTransactionHandler.cs index f9ab09a..c917fef 100644 --- a/src/FiscalOS.Infra/Transactions/Plaid/PlaidModifiedTransactionHandler.cs +++ b/src/FiscalOS.Infra/Transactions/Plaid/PlaidModifiedTransactionHandler.cs @@ -46,6 +46,7 @@ internal sealed class PlaidModifiedTransactionHandler : IPlaidModifiedTransactio { var modifiedTransactionIds = modified.Select(t => t.TransactionId); var existingModifiedTransactions = await _appDbContext.Transactions + .Include(t => t.Metadata) .Where(t => t.Metadata is PlaidTransactionMetadata && modifiedTransactionIds.Contains(((PlaidTransactionMetadata)t.Metadata).PlaidId)) .ToListAsync(ct) .ConfigureAwait(false); diff --git a/src/FiscalOS.Infra/Transactions/Plaid/PlaidRemovedTransactionHandler.cs b/src/FiscalOS.Infra/Transactions/Plaid/PlaidRemovedTransactionHandler.cs index 571bc9f..93aba0e 100644 --- a/src/FiscalOS.Infra/Transactions/Plaid/PlaidRemovedTransactionHandler.cs +++ b/src/FiscalOS.Infra/Transactions/Plaid/PlaidRemovedTransactionHandler.cs @@ -43,6 +43,7 @@ internal sealed class PlaidRemovedTransactionHandler : IPlaidRemovedTransactionH try { removedCount = await _appDbContext.Transactions + .Include(t => t.Metadata) .Where(t => t.Metadata is PlaidTransactionMetadata && removedIdsList.Contains(((PlaidTransactionMetadata)t.Metadata).PlaidId)) .ExecuteDeleteAsync(cancellationToken) .ConfigureAwait(false);