Method processReconciliation

reconciliation.go:334–369

processReconciliation manages the full reconciliation process by executing each step: updating the status, fetching rules, processing transactions, and finalizing the reconciliation. Parameters: - ctx: The context controlling the process. - reconciliation: The reconciliation object representing the

(ctx context.Context, reconciliation model.Reconciliation, strategy string, groupCriteria string, matchingRuleIDs []string)

// Returns:
// - error: If any step in the reconciliation process fails.
func (s *LedgerForge) processReconciliation(ctx context.Context, reconciliation model.Reconciliation, strategy string, groupCriteria string, matchingRuleIDs []string) error {
	// Update the reconciliation status to "in progress".
	if err := s.updateReconciliationStatus(ctx, reconciliation.ReconciliationID, StatusInProgress); err != nil {
		return fmt.Errorf("failed to update reconciliation status: %w", err)
	}

	// Retrieve the matching rules that apply to the reconciliation.
	matchingRules, err := s.getMatchingRules(ctx, matchingRuleIDs)
	if err != nil {
		return fmt.Errorf("failed to get matching rules: %w", err)
	}

	// Initialize the reconciliation progress.
	progress, err := s.initializeReconciliationProgress(ctx, reconciliation.ReconciliationID)
	if err != nil {
		return fmt.Errorf("failed to initialize reconciliation progress: %w", err)
	}

	// Create the reconciler function based on the strategy and rules.
	reconciler := s.createReconciler(strategy, reconciliation.UploadID, groupCriteria, matchingRules)

	// Create a transaction processor to handle the reconciliation logic.
	processor := s.createTransactionProcessor(reconciliation, progress, reconciler)

	// Process the transactions for reconciliation based on the chosen strategy.
	err = s.processTransactions(ctx, reconciliation.UploadID, processor, strategy)
	if err != nil {
		return fmt.Errorf("failed to process transactions: %w", err)
	}

	// After processing, retrieve the results (matched and unmatched counts).
	matched, unmatched := processor.getResults()

	// Finalize the reconciliation by updating the status and recording the results.
	return s.finalizeReconciliation(ctx, reconciliation, matched, unmatched)
}

// updateReconciliationStatus updates the status of a reconciliation process in the database.
// Parameters: