Method LoadReconciliationProgress

database/reconciliation.go:703–722

LoadReconciliationProgress retrieves the progress of a reconciliation process from the database. If the reconciliation progress is not found, it returns an empty ReconciliationProgress object. Parameters: - ctx: Context for managing the request and tracing. - reconciliationID: The ID of the reconcil

(ctx context.Context, reconciliationID string)

// Returns:
// - A ReconciliationProgress object containing the current progress, or an error wrapped in an APIError if any issues occur.
func (d Datasource) LoadReconciliationProgress(ctx context.Context, reconciliationID string) (model.ReconciliationProgress, error) {
	ctx, span := otel.Tracer("reconciliation.database").Start(ctx, "Loading reconciliation progress from db")
	defer span.End()

	var progress model.ReconciliationProgress
	err := d.Conn.QueryRowContext(ctx, `
		SELECT processed_count, last_processed_external_txn_id
		FROM ledgerforge.reconciliation_progress
		WHERE reconciliation_id = $1
	`, reconciliationID).Scan(&progress.ProcessedCount, &progress.LastProcessedExternalTxnID)
	// Handle potential errors
	if err != nil {
		if err == sql.ErrNoRows {
			return model.ReconciliationProgress{}, nil // Return empty progress if not found
		}
		return model.ReconciliationProgress{}, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to load reconciliation progress", err)
	}

	return progress, nil
}

// FetchAndGroupExternalTransactions retrieves external transactions from the database based on a specific grouping criterion and paginates the results.
// The function first checks if the results are available in cache, and if not, fetches the data from the database, groups it by the specified criterion, and stores the result in cache.