Method process

reconciliation.go:454–494

process handles individual transaction processing, applying the reconciliation logic and recording results. It also updates internal transaction metadata asynchronously when matches are found. Parameters: - ctx: The context controlling the request. - txn: The transaction to process. Returns: - error

(ctx context.Context, txn *model.Transaction)

// Returns:
// - error: If processing or recording results fails.
func (tp *transactionProcessor) process(ctx context.Context, txn *model.Transaction) error {
	// Reconcile the batch of transactions and get matches and unmatched transactions.
	batchMatches, batchUnmatched := tp.reconciler(ctx, []*model.Transaction{txn})

	// Increment the counters for matched and unmatched transactions.
	tp.matches += len(batchMatches)
	tp.unmatched += len(batchUnmatched)

	// If the reconciliation is not a dry run, record the matches and unmatched transactions.
	if !tp.reconciliation.IsDryRun {
		if len(batchMatches) > 0 {
			// Record the matched transactions.
			if err := tp.datasource.RecordMatches(ctx, tp.reconciliation.ReconciliationID, batchMatches); err != nil {
				return err
			}

			// Asynchronously update the metadata for each matched internal transaction
			go tp.updateMatchedTransactionsMetadata(context.Background(), batchMatches)
		}

		if len(batchUnmatched) > 0 {
			// Record the unmatched transactions.
			if err := tp.datasource.RecordUnmatched(ctx, tp.reconciliation.ReconciliationID, batchUnmatched); err != nil {
				return err
			}
		}
	}

	// Update the progress with the last processed transaction ID and increment the processed count.
	tp.progress.LastProcessedExternalTxnID = txn.TransactionID
	tp.progress.ProcessedCount++

	// Periodically save the reconciliation progress.
	if tp.progress.ProcessedCount%tp.progressSaveCount == 0 {
		if err := tp.datasource.SaveReconciliationProgress(ctx, tp.reconciliation.ReconciliationID, tp.progress); err != nil {
			logrus.Errorf("Error saving reconciliation progress: %v", err)
		}
	}

	return nil
}

// updateMatchedTransactionsMetadata updates the metadata for internal transactions that were matched.
// This function adds reconciliation information to the internal transaction's metadata.