Method createTransactionProcessor

reconciliation.go:432–445

createTransactionProcessor creates a new transaction processor for the reconciliation. Parameters: - reconciliation: The reconciliation object representing the current process. - progress: The current progress of the reconciliation. - reconciler: The reconciler function to apply. Returns: - *transac

(reconciliation model.Reconciliation, progress model.ReconciliationProgress, reconciler func(ctx context.Context, txns []*model.Transaction) ([]model.Match, []string))

// Returns:
// - *transactionProcessor: The created transaction processor.
func (s *LedgerForge) createTransactionProcessor(reconciliation model.Reconciliation, progress model.ReconciliationProgress, reconciler func(ctx context.Context, txns []*model.Transaction) ([]model.Match, []string)) *transactionProcessor {
	conf, err := config.Fetch()
	if err != nil {
		logrus.Errorf("Error fetching configuration: %v", err)
	}
	return &transactionProcessor{
		reconciliation:    reconciliation,
		progress:          progress,
		reconciler:        reconciler,
		datasource:        s.datasource,
		progressSaveCount: conf.Reconciliation.ProgressInterval,
		ledgerforge:       s,
	}
}

// process handles individual transaction processing, applying the reconciliation logic and recording results.
// It also updates internal transaction metadata asynchronously when matches are found.