Modifies job finder

app/finders/ci/jobs_finder.rb

@@ -4,37 +4,54 @@ module Ci
   class JobsFinder
     include Gitlab::Allowable
 
-    def initialize(current_user:, project: nil, params: {})
+    def initialize(current_user:, pipeline: nil, project: nil, params: {}, type: ::Ci::Build)
+      @pipeline = pipeline
       @current_user = current_user
       @project = project
       @params = params
+      @type = type
+      raise ArgumentError 'type must be a subclass of Ci::Processable' unless type < ::Ci::Processable
     end
 
     def execute
       builds = init_collection.order_id_desc
-      filter_by_scope(builds)
+
+      if params[:scope].is_a?(Array)
+        unknown = params[:scope] - ::CommitStatus::AVAILABLE_STATUSES
+        raise ArgumentError, 'Scope contains invalid value(s)' unless unknown.empty?
+        builds.where(status: params[:scope])
+      else
+        filter_by_scope(builds)
+      end
     rescue Gitlab::Access::AccessDeniedError
-      Ci::Build.none
+      type.none
     end
 
-    private
+    # private
 
-    attr_reader :current_user, :project, :params
+    attr_reader :current_user, :pipeline, :project, :params, :type
 
     def init_collection
-      project ? project_builds : all_builds
+      pipeline_jobs || project_jobs || all_jobs
     end
 
-    def all_builds
+    def all_jobs
       raise Gitlab::Access::AccessDeniedError unless current_user&.admin?
 
-      Ci::Build.all
+      type.all
     end
 
-    def project_builds
+    def project_jobs
+      return unless project
       raise Gitlab::Access::AccessDeniedError unless can?(current_user, :read_build, project)
 
-      project.builds.relevant
+      jobs_by_type(project, type).relevant
+    end
+
+    def pipeline_jobs
+      return unless pipeline
+      raise Gitlab::Access::AccessDeniedError unless can?(current_user, :read_build, pipeline)
+      jobs_by_type(pipeline, type).latest
     end
 
     def filter_by_scope(builds)
@@ -49,5 +66,16 @@ module Ci
         builds
       end
     end
+
+    def jobs_by_type(relation, type)
+      case type.name
+      when ::Ci::Build.name
+        relation.builds
+      when ::Ci::Bridge.name
+        relation.bridges
+      else
+        raise ArgumentError, "finder does not support #{type} type"
+      end
+    end
   end
 end

spec/finders/ci/jobs_finder_spec.rb

@@ -10,6 +10,7 @@ RSpec.describe Ci::JobsFinder, '#execute' do
   let_it_be(:job_1) { create(:ci_build) }
   let_it_be(:job_2) { create(:ci_build, :running) }
   let_it_be(:job_3) { create(:ci_build, :success, pipeline: pipeline) }
+  let_it_be(:bridge) { create(:ci_bridge, pipeline: pipeline) }
 
   let(:params) { {} }
 
@@ -53,6 +54,15 @@ RSpec.describe Ci::JobsFinder, '#execute' do
         it { expect(subject).to match_array([jobs[index]]) }
       end
     end
+
+    context 'scope is an array' do
+      let(:jobs) { [job_1, job_2, job_3] }
+      let(:params) {{ scope: ['running'] }}
+
+      it 'filters by the job statuses in the scope' do
+        expect(subject).to match_array([job_2])
+      end
+    end
   end
 
   context 'a project is present' do