fix(infra): include Metadata in transaction queries for added, modified, and removed transactions
This commit is contained in:
@@ -46,6 +46,7 @@ internal sealed class PlaidAddedTransactionHandler : IPlaidAddedTransactionHandl
|
|||||||
{
|
{
|
||||||
var existingTransactionIds = added.Select(t => t.TransactionId);
|
var existingTransactionIds = added.Select(t => t.TransactionId);
|
||||||
var existingTransactions = await _appDbContext.Transactions
|
var existingTransactions = await _appDbContext.Transactions
|
||||||
|
.Include(t => t.Metadata)
|
||||||
.Where(t => t.Metadata is PlaidTransactionMetadata && existingTransactionIds.Contains(((PlaidTransactionMetadata)t.Metadata).PlaidId))
|
.Where(t => t.Metadata is PlaidTransactionMetadata && existingTransactionIds.Contains(((PlaidTransactionMetadata)t.Metadata).PlaidId))
|
||||||
.ToListAsync(ct)
|
.ToListAsync(ct)
|
||||||
.ConfigureAwait(false);
|
.ConfigureAwait(false);
|
||||||
|
|||||||
@@ -46,6 +46,7 @@ internal sealed class PlaidModifiedTransactionHandler : IPlaidModifiedTransactio
|
|||||||
{
|
{
|
||||||
var modifiedTransactionIds = modified.Select(t => t.TransactionId);
|
var modifiedTransactionIds = modified.Select(t => t.TransactionId);
|
||||||
var existingModifiedTransactions = await _appDbContext.Transactions
|
var existingModifiedTransactions = await _appDbContext.Transactions
|
||||||
|
.Include(t => t.Metadata)
|
||||||
.Where(t => t.Metadata is PlaidTransactionMetadata && modifiedTransactionIds.Contains(((PlaidTransactionMetadata)t.Metadata).PlaidId))
|
.Where(t => t.Metadata is PlaidTransactionMetadata && modifiedTransactionIds.Contains(((PlaidTransactionMetadata)t.Metadata).PlaidId))
|
||||||
.ToListAsync(ct)
|
.ToListAsync(ct)
|
||||||
.ConfigureAwait(false);
|
.ConfigureAwait(false);
|
||||||
|
|||||||
@@ -43,6 +43,7 @@ internal sealed class PlaidRemovedTransactionHandler : IPlaidRemovedTransactionH
|
|||||||
try
|
try
|
||||||
{
|
{
|
||||||
removedCount = await _appDbContext.Transactions
|
removedCount = await _appDbContext.Transactions
|
||||||
|
.Include(t => t.Metadata)
|
||||||
.Where(t => t.Metadata is PlaidTransactionMetadata && removedIdsList.Contains(((PlaidTransactionMetadata)t.Metadata).PlaidId))
|
.Where(t => t.Metadata is PlaidTransactionMetadata && removedIdsList.Contains(((PlaidTransactionMetadata)t.Metadata).PlaidId))
|
||||||
.ExecuteDeleteAsync(cancellationToken)
|
.ExecuteDeleteAsync(cancellationToken)
|
||||||
.ConfigureAwait(false);
|
.ConfigureAwait(false);
|
||||||
|
|||||||
Reference in New Issue
Block a user