Nuevo plugin Additionals 2.0.20

plugins/additionals/app/models/additionals_query.rb

@@ -0,0 +1,150 @@
+module AdditionalsQuery
+  def self.included(base)
+    base.send :include, InstanceMethods
+  end
+
+  module InstanceMethods
+    def initialize_ids_filter(options = {})
+      if options[:label]
+        add_available_filter 'ids', type: :integer, label: options[:label]
+      else
+        add_available_filter 'ids', type: :integer, name: '#'
+      end
+    end
+
+    def sql_for_ids_field(_field, operator, value)
+      if operator == '='
+        # accepts a comma separated list of ids
+        ids = value.first.to_s.scan(/\d+/).map(&:to_i)
+        if ids.present?
+          "#{queried_table_name}.id IN (#{ids.join(',')})"
+        else
+          '1=0'
+        end
+      else
+        sql_for_field('id', operator, value, queried_table_name, 'id')
+      end
+    end
+
+    def initialize_project_filter(options = {})
+      if project.nil?
+        add_available_filter('project_id', order: options[:position],
+                                           type: :list,
+                                           values: -> { project_values })
+      end
+      return if project.nil? || project.leaf? || subproject_values.empty?
+
+      add_available_filter('subproject_id', order: options[:position],
+                                            type: :list_subprojects,
+                                            values: -> { subproject_values })
+    end
+
+    def initialize_created_filter(options = {})
+      add_available_filter 'created_on', order: options[:position],
+                                         type: :date_past,
+                                         label: options[:label].presence
+    end
+
+    def initialize_updated_filter(options = {})
+      add_available_filter 'updated_on', order: options[:position],
+                                         type: :date_past,
+                                         label: options[:label].presence
+    end
+
+    def initialize_tags_filter(options = {})
+      values = if project
+                 queried_class.available_tags(project: project.id)
+               else
+                 queried_class.available_tags
+               end
+      return if values.blank?
+
+      add_available_filter 'tags', order: options[:position],
+                                   type: :list,
+                                   values: values.collect { |t| [t.name, t.name] }
+    end
+
+    def initialize_author_filter(options = {})
+      return if author_values.empty?
+
+      add_available_filter('author_id', order: options[:position],
+                                        type: :list_optional,
+                                        values: options[:no_lambda].nil? ? author_values : -> { author_values })
+    end
+
+    def initialize_assignee_filter(options = {})
+      return if author_values.empty?
+
+      add_available_filter('assigned_to_id', order: options[:position],
+                                             type: :list_optional,
+                                             values: options[:no_lambda] ? author_values : -> { author_values })
+    end
+
+    def initialize_watcher_filter(options = {})
+      return if watcher_values.empty? || !User.current.logged?
+
+      add_available_filter('watcher_id', order: options[:position],
+                                         type: :list,
+                                         values: options[:no_lambda] ? watcher_values : -> { watcher_values })
+    end
+
+    def watcher_values
+      watcher_values = [["<< #{l(:label_me)} >>", 'me']]
+      watcher_values += users.collect { |s| [s.name, s.id.to_s] } if User.current.allowed_to?(:manage_public_queries, project, global: true)
+      watcher_values
+    end
+
+    def sql_for_watcher_id_field(field, operator, value)
+      watchable_type = queried_class == User ? 'Principal' : queried_class.to_s
+
+      db_table = Watcher.table_name
+      "#{queried_table_name}.id #{operator == '=' ? 'IN' : 'NOT IN'}
+        (SELECT #{db_table}.watchable_id FROM #{db_table} WHERE #{db_table}.watchable_type='#{watchable_type}' AND " +
+        sql_for_field(field, '=', value, db_table, 'user_id') + ')'
+    end
+
+    def sql_for_tags_field(field, _operator, value)
+      AdditionalsTag.sql_for_tags_field(queried_class, operator_for(field), value)
+    end
+
+    def sql_for_is_private_field(_field, operator, value)
+      if bool_operator(operator, value)
+        return '1=1' if value.count > 1
+
+        "#{queried_table_name}.is_private = #{self.class.connection.quoted_true}"
+      else
+        return '1=0' if value.count > 1
+
+        "#{queried_table_name}.is_private = #{self.class.connection.quoted_false}"
+      end
+    end
+
+    # use for list fields with to values 1 (true) and 0 (false)
+    def bool_operator(operator, values)
+      operator == '=' && values.first == '1' || operator != '=' && values.first != '1'
+    end
+
+    # use for list
+    def bool_values
+      [[l(:general_text_yes), '1'], [l(:general_text_no), '0']]
+    end
+
+    def query_count
+      objects_scope.count
+    rescue ::ActiveRecord::StatementInvalid => e
+      raise StatementInvalid, e.message
+    end
+
+    def results_scope(options = {})
+      order_option = [group_by_sort_order, (options[:order] || sort_clause)].flatten.reject(&:blank?)
+
+      objects_scope(options)
+        .order(order_option)
+        .joins(joins_for_order_statement(order_option.join(',')))
+        .limit(options[:limit])
+        .offset(options[:offset])
+    rescue ::ActiveRecord::StatementInvalid => e
+      raise StatementInvalid, e.message
+    end
+  end
+end