# IssuableFinder # # Used to filter Issues and MergeRequests collections by set of params # # Arguments: # klass - actual class like Issue or MergeRequest # current_user - which user use # params: # scope: 'created-by-me' or 'assigned-to-me' or 'all' # state: 'open' or 'closed' or 'all' # group_id: integer # project_id: integer # milestone_title: string # assignee_id: integer # search: string # label_name: string # sort: string # require_relative 'projects_finder' class IssuableFinder NONE = '0' attr_accessor :current_user, :params def initialize(current_user, params) @current_user = current_user @params = params end def execute items = init_collection items = by_scope(items) items = by_state(items) items = by_group(items) items = by_project(items) items = by_search(items) items = by_milestone(items) items = by_assignee(items) items = by_author(items) items = by_label(items) sort(items) end def group return @group if defined?(@group) @group = if params[:group_id].present? Group.find(params[:group_id]) else nil end end def project return @project if defined?(@project) @project = if params[:project_id].present? Project.find(params[:project_id]) else nil end end def search params[:search].presence end def milestones? params[:milestone_title].present? end def no_milestones? milestones? && params[:milestone_title] == Milestone::None.title end def milestones return @milestones if defined?(@milestones) @milestones = if milestones? Milestone.where(title: params[:milestone_title]) else nil end end def assignee? params[:assignee_id].present? end def assignee return @assignee if defined?(@assignee) @assignee = if assignee? && params[:assignee_id] != NONE User.find(params[:assignee_id]) else nil end end def author? params[:author_id].present? end def author return @author if defined?(@author) @author = if author? && params[:author_id] != NONE User.find(params[:author_id]) else nil end end private def init_collection table_name = klass.table_name if project if Ability.abilities.allowed?(current_user, :read_project, project) project.send(table_name) else [] end elsif current_user && params[:authorized_only].presence && !current_user_related? klass.of_projects(current_user.authorized_projects).references(:project) else klass.of_projects(ProjectsFinder.new.execute(current_user)).references(:project) end end def by_scope(items) case params[:scope] when 'created-by-me', 'authored' then items.where(author_id: current_user.id) when 'all' then items when 'assigned-to-me' then items.where(assignee_id: current_user.id) else raise 'You must specify default scope' end end def by_state(items) case params[:state] when 'closed' items.closed when 'merged' items.respond_to?(:merged) ? items.merged : items.closed when 'all' items when 'opened' items.opened else raise 'You must specify default state' end end def by_group(items) items = items.of_group(group) if group items end def by_project(items) items = items.of_projects(project.id) if project items end def by_search(items) items = items.search(search) if search items end def sort(items) items.sort(params[:sort]) end def by_milestone(items) if milestones? if no_milestones? items = items.where(milestone_id: [-1, nil]) else items = items.where(milestone_id: milestones.try(:pluck, :id)) end end items end def by_assignee(items) if assignee? items = items.where(assignee_id: assignee.try(:id)) end items end def by_author(items) if author? items = items.where(author_id: author.try(:id)) end items end def by_label(items) if params[:label_name].present? if params[:label_name] == Label::None.title item_ids = LabelLink.where(target_type: klass.name).pluck(:target_id) items = items.where('id NOT IN (?)', item_ids) else label_names = params[:label_name].split(",") item_ids = LabelLink.joins(:label). where('labels.title in (?)', label_names). where(target_type: klass.name).pluck(:target_id) items = items.where(id: item_ids) end end items end def current_user_related? params[:scope] == 'created-by-me' || params[:scope] == 'authored' || params[:scope] == 'assigned-to-me' end end