Method GetAllLedgersWithFilterAndOptions

database/ledger.go:242–330

GetAllLedgersWithFilterAndOptions retrieves ledgers with filtering, sorting, and optional count. It uses the filter package to build SQL WHERE and ORDER BY conditions. Parameters: - ctx: Context for the database operation. - filters: A QueryFilterSet containing the filter conditions. - opts: Query

(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, limit, offset int)

// - *int64: Optional total count of matching records (if opts.IncludeCount is true).
// - error: An error if the query fails or if there's an issue processing the results.
func (d Datasource) GetAllLedgersWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, limit, offset int) ([]model.Ledger, *int64, error) {
	if limit <= 0 || limit > 100 {
		limit = 20
	}

	if opts == nil {
		opts = &filter.QueryOptions{}
	}
	if err := filter.ValidateSortByForTable(opts, "ledgers"); err != nil {
		return nil, nil, apierror.NewAPIError(apierror.ErrBadRequest, "Invalid sort_by field", nil)
	}

	result, err := filter.BuildWithOptions(filters, "ledgers", "", 1, opts)
	if err != nil {
		return nil, nil, apierror.NewAPIError(apierror.ErrBadRequest, fmt.Sprintf("Invalid filter: %s", err.Error()), err)
	}

	// Determine select fields based on whether count is requested
	selectFields := "ledger_id, name, created_at, meta_data"
	if opts != nil && opts.IncludeCount {
		selectFields = "ledger_id, name, created_at, meta_data, COUNT(*) OVER() AS total_count"
	}

	// Build base query
	baseQuery := fmt.Sprintf(`
		SELECT %s
		FROM ledgerforge.ledgers
	`, selectFields)

	var args []interface{}
	args = append(args, result.Args...)
	argPos := result.NextArgPos

	// Add WHERE clause if filters are provided
	if len(result.Conditions) > 0 {
		logicalOperator := filter.LogicalAnd
		if filters != nil {
			logicalOperator = filters.LogicalOperator
		}
		baseQuery += " WHERE " + filter.BuildConditionExpression(result.Conditions, logicalOperator)
	}

	// Add ORDER BY clause
	baseQuery += " ORDER BY " + result.OrderBy

	// Add pagination
	baseQuery += fmt.Sprintf(" LIMIT $%d OFFSET $%d", argPos, argPos+1)
	args = append(args, limit, offset)

	rows, err := d.Conn.QueryContext(ctx, baseQuery, args...)
	if err != nil {
		return nil, nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to retrieve ledgers", err)
	}
	defer func() { _ = rows.Close() }()

	ledgers := []model.Ledger{}
	var totalCount *int64