Function fetchTransactions

database/balance.go:1494–1515

fetchTransactions retrieves transactions for a balance within a specific time range using effective_date if available, otherwise falling back to created_at

(ctx context.Context, tx *sql.Tx, balanceID string, startTime, targetTime time.Time)

// fetchTransactions retrieves transactions for a balance within a specific time range
// using effective_date if available, otherwise falling back to created_at
func fetchTransactions(ctx context.Context, tx *sql.Tx, balanceID string, startTime, targetTime time.Time) (*sql.Rows, error) {
	logrus.WithFields(logrus.Fields{
		"balance_id": balanceID,
		"start_time": startTime,
		"end_time":   targetTime,
	}).Debug("querying transactions")
	rows, err := tx.QueryContext(ctx, `
        SELECT precise_amount, source, destination, created_at, 
               COALESCE(effective_date, created_at) as effective_date
        FROM ledgerforge.transactions
        WHERE (source = $1 OR destination = $1)
        AND COALESCE(effective_date, created_at) > $2
        AND COALESCE(effective_date, created_at) <= $3
        AND status = 'APPLIED'
        ORDER BY COALESCE(effective_date, created_at) ASC
    `, balanceID, startTime, targetTime)
	if err != nil {
		return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to get transactions", err)
	}

	return rows, nil
}

// applyTransaction applies a single transaction to update balance totals
func applyTransaction(txn struct {