Method TakeBalanceSnapshots

database/balance.go:1396–1412

TakeBalanceSnapshots creates daily snapshots of balances in batches. It uses the PostgreSQL function to process balances in chunks to avoid memory issues with large datasets. Parameters: - ctx: Context for the operation, allowing for timeouts and cancellation - batchSize: The number of balances to

(ctx context.Context, batchSize int)

// - int: The total number of snapshots created
// - error: Returns an APIError if the operation fails
func (d Datasource) TakeBalanceSnapshots(ctx context.Context, batchSize int) (int, error) {
	var totalProcessed int

	// Call the PostgreSQL function to take snapshots in batches
	err := d.Conn.QueryRowContext(ctx, `
        SELECT ledgerforge.take_daily_balance_snapshots_batched($1)
    `, batchSize).Scan(&totalProcessed)
	if err != nil {
		return 0, apierror.NewAPIError(
			apierror.ErrInternalServer,
			"Failed to take balance snapshots",
			err,
		)
	}

	return totalProcessed, nil
}

// validateBalanceTimeParams validates the input parameters for GetBalanceAtTime
func validateBalanceTimeParams(balanceID string, targetTime time.Time) error {