Method processTransactions

reconciliation.go:536–576

processTransactions processes the transactions in batches, applying the reconciliation logic for each transaction. Parameters: - ctx: The context controlling the request. - uploadID: The ID of the uploaded transaction file to reconcile. - processor: The transaction processor handling the reconciliat

(ctx context.Context, uploadID string, processor *transactionProcessor, strategy string)

// Returns:
// - error: If any error occurs during processing.
func (s *LedgerForge) processTransactions(ctx context.Context, uploadID string, processor *transactionProcessor, strategy string) error {
	conf, err := config.Fetch()
	if err != nil {
		return err
	}
	processedCount := 0
	var transactionProcessor getTxns
	// Use different transaction retrieval methods depending on the strategy.
	if strategy == "many_to_one" {
		transactionProcessor = s.getInternalTransactionsPaginated
	} else {
		transactionProcessor = s.getExternalTransactionsPaginated
	}

	// Process the transactions in batches.
	_, err = s.ProcessTransactionInBatches(
		ctx,
		uploadID,
		big.NewInt(0),
		conf.Transaction.MaxWorkers,
		false, // Stream mode is disabled.
		transactionProcessor,
		func(ctx context.Context, txns <-chan *model.Transaction, results chan<- BatchJobResult, wg *sync.WaitGroup, _ *big.Int) {
			defer wg.Done()
			for txn := range txns {
				if err := processor.process(ctx, txn); err != nil {
					logrus.Errorf("Error processing transaction %s: %v", txn.TransactionID, err)
					results <- BatchJobResult{Error: err}
					return
				}
				processedCount++
				if processedCount%10 == 0 {
					logrus.Infof("Processed %d transactions", processedCount)
				}
				results <- BatchJobResult{}
			}
		},
	)
	logrus.Infof("Total transactions processed: %d", processedCount)
	return err
}

// finalizeReconciliation finalizes the reconciliation process by updating its status and recording the final match/unmatch counts.
// Parameters: