Unsubscribe message now takes filter definition instead of filter_id, reducing
[arvados.git] / services / api / lib / load_param.rb
1 # Mixin module for reading out query parameters from request params.
2 #
3 # Expects:
4 #   +params+ Hash
5 # Sets:
6 #   @where, @filters, @limit, @offset, @orders
7 module LoadParam
8
9   # Default limit on number of rows to return in a single query.
10   DEFAULT_LIMIT = 100
11
12   # Load params[:where] into @where
13   def load_where_param
14     if params[:where].nil? or params[:where] == ""
15       @where = {}
16     elsif params[:where].is_a? Hash
17       @where = params[:where]
18     elsif params[:where].is_a? String
19       begin
20         @where = Oj.load(params[:where])
21         raise unless @where.is_a? Hash
22       rescue
23         raise ArgumentError.new("Could not parse \"where\" param as an object")
24       end
25     end
26     @where = @where.with_indifferent_access
27   end
28
29   # Load params[:filters] into @filters
30   def load_filters_param
31     @filters ||= []
32     if params[:filters].is_a? Array
33       @filters += params[:filters]
34     elsif params[:filters].is_a? String and !params[:filters].empty?
35       begin
36         f = Oj.load params[:filters]
37         raise unless f.is_a? Array
38         @filters += f
39       rescue
40         raise ArgumentError.new("Could not parse \"filters\" param as an array")
41       end
42     end
43   end
44
45   # Load params[:limit], params[:offset] and params[:order]
46   # into @limit, @offset, @orders
47   def load_limit_offset_order_params
48     if params[:limit]
49       unless params[:limit].to_s.match(/^\d+$/)
50         raise ArgumentError.new("Invalid value for limit parameter")
51       end
52       @limit = params[:limit].to_i
53     else
54       @limit = DEFAULT_LIMIT
55     end
56
57     if params[:offset]
58       unless params[:offset].to_s.match(/^\d+$/)
59         raise ArgumentError.new("Invalid value for offset parameter")
60       end
61       @offset = params[:offset].to_i
62     else
63       @offset = 0
64     end
65
66     @orders = []
67     if params[:order]
68       params[:order].split(',').each do |order|
69         attr, direction = order.strip.split " "
70         direction ||= 'asc'
71         if attr.match /^[a-z][_a-z0-9]+$/ and
72             model_class.columns.collect(&:name).index(attr) and
73             ['asc','desc'].index direction.downcase
74           @orders << "#{table_name}.#{attr} #{direction.downcase}"
75         end
76       end
77     end
78     if @orders.empty?
79       @orders << "#{table_name}.modified_at desc"
80     end
81   end
82
83
84 end